热门IT资讯网

ActiveMQ之brokers network集群

发表于:2024-11-24 作者:热门IT资讯网编辑
编辑最后更新 2024年11月24日,一、集群配置方式类型master-slave uri列表中对应的顺序就是MASTER,SLAVE1,SLAVE2...SLAVE;master-slave的作用就是brokers之间的主从,同一时刻

一、集群配置方式类型

master-slave
  
  • uri列表中对应的顺序就是MASTER,SLAVE1,SLAVE2...SLAVE;
  • master-slave的作用就是brokers之间的主从,同一时刻只能连接一个broker。通常先连接master,如果master连接不上,则连接slave;
  • brokers之间的消息同步机制是通过共享的存储方式来共享数据的,如:jdbc/kahaDB/replicaLevelDB(zookeeper)。同时,brokers之间也是通过获取数据存储的访问权来获取broker的主导权(即哪个broker激活)。
  • zookeeper做masterslave时,brokers的名字必须一致,否则zookeeper会认为不符合2n+1的规则。
  • masterslave这种配置既可以在activeMQ.xml中配置,也可以在client端使用。通常建议在client使用。虽然master-slave可以提高可用性,但是负载均衡的功能减弱,并且很多时候会浪费slave broker服务器。
broker static discover
  

表示当前local broker与remote broker(61616/61617)建立的单向网络连接。即local broker可以将消息传递给remote broker,但反过来就不行。duplex="true" 属性配置可以开启双向通信。

broker multicast discover
   

组播发现会自动发现同网络中的broker并进行连接通信。注意:必须是同网络中。
在实际的配置很少这样配置,因为无法保证哪些brokers建立了连接。对于master-slave配置也不是很好。

dynamicallyIncludedDestinations
          

当networkConnector中连接的broker有customers时,那么对应的destinations才会传递到对应的broker。否则,不传递。这中方式对于point-to-point的方式就比较合适。

staticallyIncludedDestinations
          

不管networkConnector中连接的broker有无customers,都会讲消息发送到每个broker去。这种方式比较适合topic的消息方式。

excludedDestinations
          

networkConnector中指定某些detination不会发送到remote brokers.

networkConnector中uri的参数
uri="static:(tcp://host1:61616,tcp://host2:61616)?maxReconnectDelay=5000&useExponentialBackOff=false"

initialReconnectDelay:重连的时间间隔。
maxReconnectDelay:最大重连时间。即initialReconnectDelay次数
useExponentialBackOff:一次连接失败,后面的重连时间是否依次递增。
backOffMultiplier:当useExponentialBackOff=true,重连时间的间隔的倍数,即initialReconnectDelay
backOffMultiplier

networkConnector属性配置

name:连接名称,多个时必须唯一。
dynamicOnly:
decreaseNetworkConsumerPriority:
networkTTL:
messageTTL:
consumerTTL:
conduitSubscriptions:管道订阅。即一个broker有多个customers,也只会认为是一个customer.
excludedDestinations:
dynamicallyIncludedDestinations:
useVirtualDestSubs:
staticallyIncludedDestinations:
duplex:是否开启双工通信
prefetchSize:
suppressDuplicateQueueSubscriptions:
bridgeTempDestinations:
alwaysSyncSend:
staticBridge:静态连接桥。与staticallyIncludedDestinations联合使用
userName:networkConnector连接用户名
password:networkConnector连接密码

二、集群实例

broker-master

                                                   

broker-slave01

                                                                  

broker-slave02

                                                                                         

broker-cluster01

                                                                  

broker-cluster02

                                                              

brokers的安全配置

              file:${activemq.conf}/credentials.properties                                                                                                                                                                                        

参考文档:
http://activemq.apache.org/networks-of-brokers.html
http://shift-alt-ctrl.iteye.com/blog/2070531
https://www.cnblogs.com/shihaiming/p/6018916.html

0