activemq的多个broker之间的消息共享

短命女 2022-06-12 06:06 228阅读 0赞

假设activemq有两个broker服务，A和B。

在A的activemq.xml的broker标签下添加如下配置：

<networkConnectors>

<networkConnector uri="static:(tcp://172.16.15.111:61616,tcp://172.16.15.111:61626)" duplex="true"/>

</networkConnectors>

该配置可以让消息从A到B，或者从B到A。但只能流动一次。也就是不能从A到B再回到A。

如果duplex="false"则只能从A到B。

那么如何能让消息来回流转，使A和B自由共享消息呢？

在activemq.xml的policyEntries标签下（注意这里需要在A和B上都配置）做如下配置：

<policyEntry queue=">" enableAudit="false">  
                     <networkBridgeFilterFactory>  
                         <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true"/>  
                     </networkBridgeFilterFactory>  
                 </policyEntry>

该配置可以实现消息回流。

客户端连接broker的时候使用容错机制"failover:(tcp://172.16.15.111:61616,tcp://172.16.15.111:61626)"，这样当某个broker挂了，客户端会自动连接别的broker。

以上配置也间接实现了activemq的均衡负载。

不过这种均衡负载是针对broker的，也就是说如果A上连了一个客户端，B上连了两个，那么A上的一个客户端消费的和B上的两个客户端加起来相等。

如果要三个客户端均分的话，需要给networkConnector标签添加一个属性，也就是在duplex="true"后面添加conduitSubscriptions="false"。它的意思是多个网络消费者是否被当做一个消费者来对待。

发表评论取消回复

表情：

评论列表（有 0 条评论，228人围观）

还没有评论，来说两句吧...

相关阅读

相关 Activemq的Broker

目录一、broker是什么二、启动broker时指定配置文件三、嵌入式Broker （一）Pom.xml （二）Broker实例（三）验证 -------

墨蓝/ 2023年10月11日 20:16/ 0 赞/ 9 阅读

相关消息中间件-ACTIVEMQ-4：ActiveMQ的Broker

目录 1：Broker是什么 2：根据不同的conf启动不同的activemq 3：java嵌入式mq 3.1：pom.xml 3.2：启动自己java代码写的内嵌式

系统管理员/ 2023年10月05日 09:33/ 0 赞/ 53 阅读

相关 Broker 保存消息

存储方式物理上把 topic 分成一个或多个 patition，每个 patition 物理上对应一个文件夹（该文件夹存储该 patition

清疚/ 2023年08月17日 15:19/ 0 赞/ 106 阅读

相关 ActiveMQ之Broker

什么是Broker？相当于一个ActiveMQ服务器实例，说白了，Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java代码中，以便随时用随时启

男娘i/ 2023年07月18日 03:13/ 0 赞/ 18 阅读

相关 ActiveMQ专题6 ——ActiveMQ的Broker

是什么？相当于一个内嵌式ActiveMQ服务器实例。其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java代码中，以便随时用随时启动，在用的时候再去启动这样

小鱼儿/ 2022年11月05日 12:56/ 0 赞/ 174 阅读

相关同一网站的多个域名之间访问共享信息

1. ContextSingleListener package test; import javax.servlet.\; import javax.servl

谁借莪１个温暖的怀抱￠/ 2022年08月14日 01:50/ 0 赞/ 215 阅读

相关 activemq的多个broker之间的消息共享

假设activemq有两个broker服务，A和B。在A的activemq.xml的broker标签下添加如下配置： <networkConnectors>

短命女/ 2022年06月12日 06:06/ 0 赞/ 229 阅读

相关多个Tomcat之间实现Session共享

文章转自 [https://www.cnblogs.com/beyang/p/9122406.html][https_www.cnblogs.com_beyang_p_9122

绝地灬酷狼/ 2022年05月06日 06:54/ 0 赞/ 211 阅读

相关 ActiveMQ入门教程(五)------ActiveMQ的Broker

ActiveMQ的Broker 定义：相当于一个ActiveMQ服务器实例，说白了，Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到

「爱情、让人受尽委屈。」/ 2021年09月01日 10:37/ 0 赞/ 353 阅读

相关 ActiveMQ--Broker

Broker 相当于一个ActiveMQ服务器实例。 Broker其实就是实现了用代码的形式启动ActiveMQ将MQ嵌入到Java中，以便随时用随时启动，在用的时候再

妖狐艹你老母/ 2021年08月13日 18:46/ 0 赞/ 346 阅读