活动 MQ 消息在网络代理设置中卡住

Question

我在网络设置中有两个ActiveMQ代理。客户端配置为randomize=true，并且能够良好连接。但是，消息不会从一个代理转发到另一个代理，而是保留在队列中。例如，我有一个特定的队列，它有多个生产者和一个消费者。如果我查看一个消费者连接到的代理上的队列，所有消息都会立即退出队列。但是，在另一个代理上，消息会排队，不会被排出。

下面列出的是我为两个代理设置的网络连接器和传输连接器。我尝试过添加双工=“true”以及将网络TTL更改为1，这些似乎没有任何区别。

经纪公司a:

<networkConnectors>
    <networkConnector name="LocalBrokerToB"                    
                    networkTTL="2"
                    uri="static:(tcp://hostnameB:61617)"/>
</networkConnectors>

<transportConnectors>
    <transportConnector name="nioConnectorFront" uri="nio://hostnameA:61616?maximumConnections=1024 "/>
    <transportConnector name="nioConnectorBack" uri="tcp://hostnameA:61617?maximumConnections=1024 "/>
</transportConnectors>

经纪人B：

<networkConnectors>
    <networkConnector name="LocalBrokerToA"                    
                    networkTTL="2"
                    uri="static:(tcp://hostnameA:61617)"/>
</networkConnectors>

<transportConnectors>
    <transportConnector name="nioConnectorFront" uri="nio://hostnameB:61616?maximumConnections=1024 "/>
    <transportConnector name="nioConnectorBack" uri="tcp://hostnameB:61617?maximumConnections=1024 "/>
</transportConnectors>

你知道问题出在哪里吗？某人正在使用的配置示例将会很有帮助。

Answer 1

您应该将networkConnector连接到另一个代理的传输连接器。在您的示例中，这是端口61616，而不是61617。

您应该在代理日志中或通过 Web 控制台/JMX 验证网络连接是否实际建立。

添加 duplex=“true” 让我们的一个代理启动连接，这在防火墙等情况下非常有用。就您而言，这应该无关紧要。