Stomp和ActiveMQ之间的连接失败

Question

php STOMP连接和运行在不同服务器上的ActiveMQ代理之间的通信出现问题。布局如下；

$stomp = new Stomp('tcp://<ServerB>:61550');

服务器B有一个AMQ代理，运行以下transportConnector设置；

<transportConnectors>
    <transportConnector name="tcp" uri="tcp://0.0.0.0:61500"/>
    <transportConnector name="stomp" uri="stomp://0.0.0.0:61550"/>
    <transportConnector name="ssl" uri="ssl://0.0.0.0:61700?needClientAuth=true"/>
</transportConnectors>

服务器B还有一个Java客户机，充当许多队列的使用者。

问题是，当我们在ServerA上运行脚本时，它会失败，出现以下错误；

致命错误：未捕获的异常“stompexception”，消息为“服务器没有响应”

在ServerB上的ActiveMQ日志中，我们得到；

2014-07-01 11:33:32,754警告传输连接到：tcp：//servera:48692失败：java.io.ioException：未知数据类型：69 org.apache.ActiveMQ.broker.transportConnection.Transport ActiveMQ传输：tcp：///servera:48692@61500

2014-07-01 11:33:32,755警告传输连接到：tcp：//servera：48692失败：org.apache.activemq.Transport.inactivityioException：无法发送，通道已失败：tcp：//servera：48692 org.apache.activemq.broker.transportConnection.Transport异步异常处理程序

我推断出失败的原因是，由于某种原因，来自A的STOMP请求被端口61500上的TCP侦听器而不是端口61550上的STOMP侦听器接收，并且由于协议不匹配而失败。

我尝试将端口61500的tcp transportConnector更改为stomp连接器，这解决了问题。但是许多其他应用程序依赖于61500作为tcp，所以它不是一个解决方案。

我已经和我们的系统管理员谈过了，他们肯定防火墙设置正确，即使这样，他们也完全禁用了服务器上的防火墙，同样的问题也发生了，所以我不知道这是否是问题的一部分。我们有另一个服务器，它的activemq配置设置几乎相同（tcp在61500上，stomp在61550上），它工作得很好，不同的是它有一个用于activemq web工具的jetty配置。

我不知道该尝试什么，也不知道这是如何发生的。如果任何人有任何建议或可以在任何方面提供帮助，将不胜感激。

可能有关，但我不知道这些是什么意思，这里是telnet输出；

telnet serverB 61550
Trying <serverB address>...
Connected to serverB.
Escape character is '^]'.
ðActiveMQ       Þ
MaxFrameSizÿÿÿ  CacheSize
CacheEnabledSizePrefixDisabled  MaxInactivityDurationInitalDelay'TcpNoDelayEnabledMaxInactivityDurationu0TightEncodingEnabledStackTraceEnabled

telnet serverB 61500
Trying <serverB address>...
Connected to serverB.
Escape character is '^]'.
ðActiveMQ       Þ
MaxFrameSizÿÿÿ  CacheSize
CacheEnabledSizePrefixDisabled MaxInactivityDurationInitalDelay'TcpNoDelayEnabledMaxInactivityDurationu0TightEncodingEnabledStackTraceEnabledConnection closed by foreign host.

telnet localhost 61550
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
^]
telnet> quit
Connection closed.

telnet localhost 61500
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
ðActiveMQ       Þ
MaxFrameSizÿÿÿ  CacheSize
CacheEnabledSizePrefixDisabled MaxInactivityDurationInitalDelay'TcpNoDelayEnabledMaxInactivityDurationu0TightEncodingEnabledStackTraceEnabledPuTTYConnection closed by foreign host.

我能在web上找到的关于这些字符的唯一提及是这个post ActiveMQ远程连接被拒绝，尽管broker URL中有0.0.0.0。

不幸的是，我们不运行卡拉夫，我不知道它将如何适用于我们。我在61550上找不到其他监听的东西。

netstat -tulpn | grep 61550
tcp6       0      0 :::61550                :::*                    LISTEN      12870/java

感谢所有阅读过这一切的人，他们试图提供尽可能多的信息。

Answer 1

您似乎使用错误的URI连接到STOMP连接器。

替换$Stomp=new Stomp('tcp:// :61550')；

与