带有 Activemq 的 Amqp 协议答案

【问题标题】：Amqp protocol with Activemq带有 Activemq 的 Amqp 协议
【发布时间】：2016-05-04 20:52:50
【问题描述】：

对不起，我之前的帖子。我正在尝试使用 Jmeter 发送消息，我已经在 github 上下载了它，并带有用于 rabbitmq 的 AMQP 插件。在我的 activemq 中，我设置 amqp 协议并在 Jmeter 中得到 100% 的错误，在日志中我看到了这个错误，以及关于 qpid 质子的一些东西。原因：

org.apache.qpid.proton.engine.TransportException: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 0, expecting 1. In state: HEADER5
        at org.apache.qpid.proton.engine.TransportResultFactory$TransportResultImpl.checkIsOk(TransportResultFactory.java:116)
        at org.apache.qpid.proton.engine.impl.TransportImpl.input(TransportImpl.java:220)
        at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:230)

in 是什么意思？以及我该如何解决这个问题。谢谢

【问题讨论】：

请在您的问题中提供更多信息，以及您尝试了什么以及出了什么问题。

标签： activemq amqp

【解决方案1】：

很难用如此有限的信息来判断，但我猜你正在尝试使用说 AMQP 0.10 或更早版本的客户端连接到代理，而 ActiveMQ 代理只说 AMQP v1.0。使用 AMQP 1.0 客户端发送消息，它可能会工作。

【讨论】：

所以我需要安装amqp v1.0？还是新版本的 qpid proton？我以为activemq 5.10使用amqp 1.0
ActiveMQ 正在使用 AMQP 1.0 它看起来就像你用来连接它的任何东西都不是。
好的，我可能会尝试为 jmeter 找到另一个 amqp 库 v1.0，然后再次测试。
从 aactivemq/example/amqp/python 运行 python 脚本，是同样的错误，所以我只是安装 qpid proton，然后再次运行脚本，在我的 webconsole 中，我看到这是创建主题和一个侦听器，我发送了 5000 条消息，但它们没有出现在控制台中。所以..我认为我的 jmeter 不能与 activemq amqp 协议正常工作。
嗯不明白为什么当发送 100 条消息时，webconsole 是空的，并且侦听器没有关闭，但是当我在脚本中设置发送... 5 或 25 条消息有时是 50 时，它们会出现在控制台和侦听器中关闭。为什么会这样？

【解决方案2】：

我会推荐支持 AMQPv1.0 的 Qpid AMQP 客户端库

【讨论】：