active-mq artemis springboot集群主题负载平衡（循环）问题

Question

在花费大量时间配置和尝试大量解决方案使Artemis在集群模式下工作之后，就像发布-订阅（主题）中的本地模式一样。因此，我在不同的节点上准备了3个消费者和一个只在一个节点上发布消息的生产者。我希望3个消费者收到他们自己的消息副本，如在这里所描述的！

问题是集群（核心桥）仍然在3个节点之间循环消息。

我的项目Github回购

spring-boot-artemis-clustered-topic

代理集群配置

<!-- Using STRICT is like setting the legacy forward-when-no-consumers 
parameter to true--> 
<!-- Using ON_DEMAND is like setting the legacy forward-when-no-consumers 
parameter to false.-->
<cluster-connections>
     <cluster-connection name="my-cluster">
     <address>jms</address>
        <connector-ref>netty-connector</connector-ref>
        <retry-interval>500</retry-interval>
        <use-duplicate-detection>true</use-duplicate-detection>
        <message-load-balancing>ON_DEMAND</message-load-balancing>
        <max-hops>1</max-hops>
        <discovery-group-ref discovery-group-name="my-discovery-group"/>
     </cluster-connection>

</cluster-connections>

消费者行为蒿-B1-B2-B3

Answer 1

在ConnectionFactoryClusteredConfig.pubsubFactory()方法中，尝试将factory.setpubsubdomain（true）移动到Configurer.configure（factory,connectionFactory)之后，如下所示:https://stackoverflow.com/a/44416121/832268。