ActiveMQ不在代理之间分发消息

Question

我在完整图形拓扑上有一个代理网络，在不同服务器上有3个节点：A，B和C。每个代理都附加了一个生产者，并且出于测试目的，在代理 C 上只有一个非代理使用者。由于我使用的是完整图拓扑，因此每个代理还为其他每个节点都有一个代理使用者。

问题是：A收到一些消息。我希望它将这些消息转发给代理C，该代理连接了一个“真实”消费者。这不会发生，代理A存储这些消息，直到一个“真实”消费者连接到它。

我的配置（或理解）有什么问题？

我正在使用ActiveMQ 5.9.0。

这是我对经纪人A的活跃.xml。对于 B 和 C 也是如此，只是更改了名称：

<beans
    xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="broker-A" dataDirectory="${activemq.data}">

    <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry topic="tokio.>">
                    <subscriptionRecoveryPolicy>
                        <noSubscriptionRecoveryPolicy/>
                    </subscriptionRecoveryPolicy>
                    <pendingMessageLimitStrategy>
                        <constantPendingMessageLimitStrategy limit="1000"/>
                    </pendingMessageLimitStrategy>
                </policyEntry>
            </policyEntries>
        </policyMap>
    </destinationPolicy>

    <managementContext>
        <managementContext createConnector="true"/>
    </managementContext>

    <persistenceAdapter>
        <kahaDB directory="${activemq.data}/kahadb"/>
    </persistenceAdapter>

    <systemUsage>
        <systemUsage>
            <memoryUsage>
                <memoryUsage percentOfJvmHeap="70" />
            </memoryUsage>
            <storeUsage>
                <storeUsage limit="40 gb"/>
            </storeUsage>
            <tempUsage>
                <tempUsage limit="10 gb"/>
            </tempUsage>
        </systemUsage>
    </systemUsage>

    <networkConnectors>
        <networkConnector name="linkTo-broker-B"
                          uri="static:(tcp://SRVMSG01:61616)"
                          duplex="true"
                />
        <networkConnector name="linkTo-broker-C"
                          uri="static:(tcp://SRVMSG03:61616)"
                          duplex="true"
                />
    </networkConnectors>

    <transportConnectors>
        <transportConnector uri="tcp://localhost:0" discoveryUri="multicast://default"/>
        <transportConnector name="nio" uri="nio://0.0.0.0:61616" />
    </transportConnectors>

</broker>

</beans>

Answer 1

默认情况下，networkTTL 为 1（请参阅文档），因此，当 B 上的创建者发布消息时，如果它采用路径到 A（它将在您的配置中执行 50% 的时间，因为您已将代理设置为使用者之间的轮循机制，稍后会详细介绍），则不允许将其转发到 C。您可以通过增加网络TTL的值来解决此问题，但更好的解决方案是设置 reduceNetworkConsumerPriority=true（请参阅与上面相同的链接中的文档），以确保消息始终尽可能直接地发送给它们所针对的使用者。

但是，请注意，如果您的消费者在网格中移动，这可能会捆绑消息，因为networkTTL值不允许额外的转发，也因为不允许将消息重新发送到它们已经通过的代理。您可以通过将networkTTL设置为更大的值（如20，以完全安全）并应用replayWhenNo消费者=true策略设置来解决这些问题，该策略设置在同一留档页面的“Stuck Messages”部分中描述。这些设置都不是绝对必要的，只要您确定您的消费者永远不会移动到另一个代理，或者您可以在发生这种情况时丢失一些消息。