使用 golang 连接到 Active MQ

Bob*_*sta 6 activemq-classic stomp amqp amazon-web-services

Amazon MQ(Active MQ)说它适用于 amqp,这里有一个 go 包https://github.com/streadway/amqp但是当我尝试 Dial() 时我收到这个错误

Exception (501) Reason: "Exception (501) Reason: \"frame could not be parsed\""
Run Code Online (Sandbox Code Playgroud)

我怀疑这是因为虽然这是一个 amqp 包,而且 Amazon MQ 接受 amqp,但这是一个 RabbitMQ amqp 包……这有意义吗?

另一种选择是 STOMP,我已经尝试使用这里的示例https://github.com/go-stomp/stomp/blob/master/examples/client_test/main.go 但是 Dial() 给我这个超级没有帮助错误:“无效命令”

问如何连接很尴尬,但这就是我被卡住的地方。提前致谢

Pet*_*der 4

AMQP 0.x (RabbitMQ) 是与 AMQP 1.0(ActiveMQ 等)非常不同的协议。AMQP 1.0 不向后兼容。

您需要一个支持 AMQP 1.0 的客户端库。

我还没有测试过它,但这个库声称可以工作。 https://github.com/vcabbage/amqp

  • 看来微软已经在他们的分支中接管了这个项目的维护:https://github.com/Azure/go-amqp (2认同)