在同一台机器上同时运行 ActiveMQ 和 RabbitMQ 时 AMQP 协议版本不匹配答案

【问题标题】：AMQP protocol version mismach when running ActiveMQ and RabbitMQ in a same machine simultanueously在同一台机器上同时运行 ActiveMQ 和 RabbitMQ 时 AMQP 协议版本不匹配
【发布时间】：2016-03-22 16:58:09
【问题描述】：

我一直在尝试开发一个同时使用 activeMQ 和 rabbitMQ 的项目。我在 pom.xml 中添加的依赖项如下：

    <dependency>
        <groupId>org.springframework.amqp</groupId>
        <artifactId>spring-rabbit</artifactId>
        <version>1.4.6.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jms</artifactId>
        <version>4.2.3.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.apache.activemq</groupId>
        <artifactId>activemq-broker</artifactId>
        <version>5.13.0</version>
    </dependency>

另外，我同时运行apache-activemq-5.13.0 和rabbitmq-server-3.5.6。但不幸的是，我遇到了一个与 AMQP 相关的错误，如下所示：

java.io.IOException
    at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)
    at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)
    at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:350)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:648)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:678)
    at org.hafiz.framework.common.rabbit.filter.ReceiveRabbitMessageFilter.init(ReceiveRabbitMessageFilter.java:33)
    at org.hafiz.common.filter.PrmTarrifTypeMessageFilter.init(PrmTarrifTypeMessageFilter.java:21)

    at org.apache.catalina.core.ApplicationFilterConfig.initFilter(ApplicationFilterConfig.java:279)
    at org.apache.catalina.core.ApplicationFilterConfig.getFilter(ApplicationFilterConfig.java:260)
    at org.apache.catalina.core.ApplicationFilterConfig.<init>(ApplicationFilterConfig.java:105)
    at org.apache.catalina.core.StandardContext.filterStart(StandardContext.java:4854)
    at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5546)
    at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
    at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:901)
    at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:877)
    at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:652)

    at org.apache.catalina.startup.HostConfig.deployDirectory(HostConfig.java:1263)

    at org.apache.catalina.startup.HostConfig$DeployDirectory.run(HostConfig.java:1948)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    at java.util.concurrent.FutureTask.run(FutureTask.java:262)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error
    at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67)
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:37)

    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:367)
    at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:293)
    ... 20 more
Caused by: com.rabbitmq.client.MalformedFrameException: AMQP protocol version mismatch; we are version 0-9-1, server sent signature 0,1,0,0
    at com.rabbitmq.client.impl.Frame.protocolVersionMismatch(Frame.java:174)
    at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:111)

    at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:139)
    at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:536)
    ... 1 more
java.lang.NullPointerException
    at org.hafiz.framework.common.rabbit.filter.ReceiveRabbitMessageFilter.receiveMessage(ReceiveRabbitMessageFilter.java:61)
    at org.hafiz.common.filter.PrmTarrifTypeMessageFilter$1.run(PrmTarrifTypeMessageFilter.java:29)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    at java.util.concurrent.FutureTask.run(FutureTask.java:262)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)

如果有人帮助我解决此错误，我将不胜感激。

【问题讨论】：

您是否将它们配置为使用不同的端口？
@Kenney 我已经在 rabbitMQ 安装目录的 etc 文件夹中查找了配置文件。但我发现的唯一文件名为“rabbitmq.config.example”。因此，我将该文件中的端口号更改为 5673。但是我认为这不是要更改的正确文件。
你见过rabbitmq configure - 似乎使用环境变量。如果失败，您可以更改activemq transport configuration。毕竟，只有其中一个需要更改。
@Kenney 感谢您的回复，我按照您告诉的链接中的说明更改了 RabbitMQ 端口。不幸的是，错误还没有改变。
@Kenney 我终于成功解决了这个问题。我不知道为什么，但我无法更改 RabbitMQ 端口。因此，我改为更改了 ActiveMQ 的默认端口。感谢您的帮助。

标签： java spring rabbitmq activemq amqp

【解决方案1】：

解决方案只是更改其中一个消息代理端口号。由于它们都在同一个端口 (5672) 上工作，您只需更改其中一个的配置即可。

对于rabbitMQ，您可以按照here 的说明进行操作，就像@Kenney 所说的设置环境变量一样简单。

注意：在设置变量时不要忘记重新安装 RabbitMQ 服务。

在 Windows 中，您可以通过在命令提示符下运行以下命令来执行此操作：

cd进入RabbitMQ服务器安装目录下的sbin文件夹，运行rabbitmq-service.bat remove
设置 RABBITMQ_NODE_PORT=xxxx
rabbitmq-service.bat 安装

此外，如果它不起作用，您可以简单地将 ActiveMQ 的默认端口更改为 amqp。为此，您应该在位于 ActiveMQ 服务器安装目录的 conf 文件夹中查找文件名 activemq.xml。我希望这对你有用。

【讨论】：

感谢您的宝贵回答，但就像我告诉@Kenney 一样，虽然我已经按照您的建议做了，但错误并没有改变。
我终于成功解决了这个问题，就像你说的改变了ActiveMQ的默认端口号。非常感谢您。 @Reza

【解决方案2】：

协议 AMQP 在端口 5672 上工作，两个消息代理都支持此协议。只需将其中一个移到另一台机器上即可。

【讨论】：