amazon-web-services - 使用 golang 连接到 Active MQ

Question

Amazon MQ (Active MQ) 说它可以与 amqp 一起使用，这里有一个 go 包 https://github.com/streadway/amqp但是当我尝试 Dial() 我得到这个错误

Exception (501) Reason: "Exception (501) Reason: \"frame could not be parsed\""

我怀疑这是因为虽然这是一个 amqp 包，并且 Amazon MQ 接受 amqp，但这具体是一个 RabbitMQ amqp 包......这有意义吗？

另一个选项是 STOMP，我已经尝试使用此处的示例 https://github.com/go-stomp/stomp/blob/master/examples/client_test/main.go
但是 Dial() 给了我这个 super 无用的错误:“无效命令”

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

Answer 1

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

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

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