使用stompngo客户端订阅消息

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《使用stompngo客户端订阅消息》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

我正在使用 stompngo 客户端库连接并订阅作为 stomp 发布的 activemq 中的主题。 我没有看到将 destination 指定为 topic 的规定，并且默认情况下订阅似乎在 activemq 中注册为 queue。是否需要任何特定步骤来具体指向某个主题？

func subscribe() {  netconn, err := net.Dial("tcp", "localhost:61613")
    check(err)
    h := stompngo.Headers{stompngo.HK_ACCEPT_VERSION, "1.1",
        stompngo.HK_HOST, "localhost"}
    conn, err := stompngo.Connect(netconn, h)
    check(err)
    subHead := stompngo.Headers{stompngo.HK_DESTINATION, "MY_TOPIC"}
    sub, err := conn.Subscribe(subHead)
    check(err)
    for {
        msg := <-sub

        log.Println("Message : ", msg.Message.BodyString())

    }
}

解决方案

您可以通过以下方式尝试：

h := stompngo.Headers{stompngo.HK_DESTINATION, "/topic/MY_TOPIC"}

来源 - https://github.com/gmallard/stompngo/blob/dev/send.go#L35

今天关于《使用stompngo客户端订阅消息》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！