代码之家 › 专栏 › 技术社区 › Mohamed Hosni

活动mq artemis springboot群集主题负载平衡(循环)问题

activemq-artemis spring-jms publish-subscribe

Mohamed Hosni · 技术社区 · 7 年前

在花费大量时间配置和尝试大量解决方案以使Artemis在簇模式,如 地方的 a中的模式 发布订阅 (主题)。所以我准备了3个 消费者 在不同的节点和a 制作人 仅在一个节点上发布消息。我预计这3位消费者会收到他们自己的消息副本,如中所述 here !

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

我的项目Github Repo

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>

消费者行为 artemis-b1-b2-b3

1 回复 | 直到 7 年前

Ashok Kallara 7 年前

在您的 ConnectionFactoryClusteredConfig.pubSubFactory() 方法,尝试移动 factory.setPubSubDomain(true) 之后 configurer.configure(factory, connectionFactory) 如下所述: https://stackoverflow.com/a/44416121/832268 .

推荐文章

user1008636 · “publish-subscribe”消息传递模式是否需要尽可能多的队列?

7 年前

pixel · C#根据订阅者的要求通知订阅者的事件

7 年前

vach · ZeroMQ可以订阅,但如何排除特定筛选器?

7 年前

Antoine · 在ROS-Python中使用来自多个主题的数据

7 年前

user1028741 · PubSub:是否可以获取迟到订阅者的最后一条消息?

7 年前

Mohamed Hosni · 活动mq artemis springboot群集主题负载平衡(循环)问题

7 年前

DSA · NATS请求-回复-它是如何工作的?

7 年前

Praveen Rathode · nanomsg中是否可能存在IP多播?

7 年前

vpgcloud · 将谷歌发布/订阅消息直接“流”到前端的最佳方式?服务器发送事件?

7 年前

Kenneth E. Bellock · 如何使用类方法的函子断开boost signal2的连接?

7 年前