通过STOMP in Go连接到ActiveMQ

Question

试图通过＜code＞github连接到AWS上的ActiveMQ实例。com/go-stomp/stomplibrary。

以下代码抛出＜code＞无效命令

func (s *STOMP) Init() error {
    netConn, err := stomp.Dial("tcp", "host:61614")
    if err != nil {
        return errors.Wrap(err, "dial to server")
    }

    s.conn = netConn

    return nil
}

Answer 1

AmazonMQ使用stomp ssl协议，因此连接到它的正确方法是首先在您自己的网络上设置TLS连接：

func (s *STOMP) Init() error {
    netConn, err := tls.Dial("tcp", "host:61614", &tls.Config{})
    if err != nil {
        return errors.Wrap(err, "dial tls")
    }
    stompConn, err := stomp.Connect(netConn)
    if err != nil {
        return errors.Wrap(err, "dial to server")
    }

    s.conn = stompConn

    return nil
}

https://github.com/go-stomp/stomp/wiki/Connect-using-TLS