ActiveMQ之集群介绍

小灰灰 2022-08-05 02:26 135阅读 0赞

ActiveMQ具有强大和灵活的集群功能，ActiveMQ的集群方式主要由两种：Master-Slave和Broker Cluster。

##### 一、Master-Slave部署方式 #####

Master-Slave方式中，只能是Master提供服务，Slave是实时地备份Master的数据，以保证消息的可靠性。当Master失效时，Slave会自动升级为Master，客户端会自动连接到Slave上工作。Master-Slave模式分为三类：Pure Master Slave、Shared File System Master Slave和JDBC Master Slave。

参考：

[http://activemq.apache.org/masterslave.html][http_activemq.apache.org_masterslave.html]

[http://activemq.apache.org/failover-transport-reference.html][http_activemq.apache.org_failover-transport-reference.html]  
**1）shared filesystem Master-Slave部署方式**

主要是通过共享存储目录来实现 master 和 slave 的热备，所有的 ActiveMQ 应用都在不断地获取共享目录的控制权，哪个应用抢到了控制权，它就成为 master 。

多个共享存储目录的应用，谁先启动，谁就可以最早取得共享目录的控制权成为master，其他的应用就只能作为slave。

![p2.png][]

**2）shared database Master-Slave方式**

与shared filesystem方式类似，只是共享的存储介质由文件系统改成了数据库而已。

**3）Replicated LevelDB Store方式**

这种主备方式是ActiveMQ5.9以后才新增的特性，使用ZooKeeper协调选择一个node作为master。被选择的master broker node开启并接受客户端连接。

其他node转入slave模式，连接master并同步他们的存储状态。slave不接受客户端连接。所有的存储操作都将被复制到连接至Master的slaves。

如果master死了，得到了最新更新的slave被允许成为master。fialed node能够重新加入到网络中并连接master进入slave mode。所有需要同步的disk的消息操作都将等待存储状态被复制到其他法定节点的操作完成才能完成。所以，如果你配置了replicas=3，那么法定大小是(3/2)+1=2. Master将会存储并更新然后等待 (2-1)=1个slave存储和更新完成，才汇报success。至于为什么是2-1，熟悉Zookeeper的应该知道，有一个node要作为观擦者存在。

单一个新的master被选中，你需要至少保障一个法定node在线以能够找到拥有最新状态的node。这个node将会成为新的master。因此，推荐运行至少3个replica nodes，以防止一个node失败了，服务中断。

![Center][]

##### 二、Broker-Cluster部署方式 #####

前面的Master-Slave的方式虽然能解决多服务热备的高可用问题，但无法解决负载均衡和分布式的问题。Broker-Cluster的部署方式就可以解决负载均衡的问题。

Broker-Cluster部署方式中，各个broker通过网络互相连接，并共享queue。当broker-A上面指定的queue-A中接收到一个message处于pending状态，而此时没有consumer连接broker-A时。如果cluster中的broker-B上面由一个consumer在消费queue-A的消息，那么broker-B会先通过内部网络获取到broker-A上面的message，并通知自己的consumer来消费。

**1）static Broker-Cluster部署**

在activemq.xml文件中静态指定Broker需要建立桥连接的其他Broker：

1、  首先在Broker-A节点中添加networkConnector节点：

<networkConnector   uri="static:(tcp:// 0.0.0.0:61617)"duplex="false"/>

</networkConnectors>

2、  修改Broker-A节点中的服务提供端口为61616：

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

3、  在Broker-B节点中添加networkConnector节点：

<networkConnector   uri="static:(tcp:// 0.0.0.0:61616)"duplex="false"/>

</networkConnectors>

4、  修改Broker-A节点中的服务提供端口为61617：

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61617?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

5、分别启动Broker-A和Broker-B。

** 2）Dynamic Broker-Cluster部署**

在activemq.xml文件中不直接指定Broker需要建立桥连接的其他Broker，由activemq在启动后动态查找：

1、  首先在Broker-A节点中添加networkConnector节点：

<networkConnectoruri="multicast://default"

dynamicOnly="true"

networkTTL="3"

prefetchSize="1"

decreaseNetworkConsumerPriority="true" />

</networkConnectors>

2、修改Broker-A节点中的服务提供端口为61616：

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61616? " discoveryUri="multicast://default"/>

</transportConnectors>

3、在Broker-B节点中添加networkConnector节点：

<networkConnectoruri="multicast://default"

dynamicOnly="true"

networkTTL="3"

prefetchSize="1"

decreaseNetworkConsumerPriority="true" />

</networkConnectors>

4、修改Broker-B节点中的服务提供端口为61617：

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61617" discoveryUri="multicast://default"/>

</transportConnectors>

5、启动Broker-A和Broker-B

**三、Master-Slave与Broker-Cluster相结合的部署方式**

可以看到Master-Slave的部署方式虽然解决了高可用的问题，但不支持负载均衡，Broker-Cluster解决了负载均衡，但当其中一个Broker突然宕掉的话，那么存在于该Broker上处于Pending状态的message将会丢失，无法达到高可用的目的。

由于目前ActiveMQ官网上并没有一个明确的将两种部署方式相结合的部署方案，所以我尝试者把两者结合起来部署：

![p4.png][]

**1、部署的配置修改**

这里以Broker-A + Broker-B建立cluster，Broker-C作为Broker-B的slave为例：

1）首先在Broker-A节点中添加networkConnector节点：

<networkConnector   uri="masterslave:(tcp://0.0.0.0:61617,tcp:// 0.0.0.0:61618)" duplex="false"/>

</networkConnectors>

2）修改Broker-A节点中的服务提供端口为61616：

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

3）在Broker-B节点中添加networkConnector节点：

<networkConnector   uri="static:(tcp:// 0.0.0.0:61616)"duplex="false"/>

</networkConnectors>

4）修改Broker-B节点中的服务提供端口为61617：

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61617?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

5）修改Broker-B节点中的持久化方式：

</persistenceAdapter>

6）在Broker-C节点中添加networkConnector节点：

<networkConnector   uri="static:(tcp:// 0.0.0.0:61616)"duplex="false"/>

</networkConnectors>

7）修改Broker-C节点中的服务提供端口为61618：

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61618?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>

</transportConnectors>

8）修改Broker-B节点中的持久化方式：

</persistenceAdapter>

9）分别启动broker-A、broker-B、broker-C，因为是broker-B先启动，所以“/localhost/kahadb”目录被lock住，broker-C将一直处于挂起状态，当人为停掉broker-B之后，broker-C将获取目录“/localhost/kahadb”的控制权，重新与broker-A组成cluster提供服务。

配置参考：[http://download.csdn.net/detail/tianwei7518/8759641][http_download.csdn.net_detail_tianwei7518_8759641]

参考文章：

1.[ActiveMQ集群：网络连接模式(network connector)详解][ActiveMQ_network connector]

2.[ActiveMQ负载均衡][ActiveMQ]

3.[ActiveMQ实现负载均衡+高可用部署方案][ActiveMQ 1]

4.[activemq master-slave集群安装文档][activemq master-slave]

5.[ActiveMQ的集群与高可用][ActiveMQ 2]  
6.[ActiveMQ集群应用][ActiveMQ 3]

[http_activemq.apache.org_masterslave.html]: http://activemq.apache.org/masterslave.html
[http_activemq.apache.org_failover-transport-reference.html]: http://activemq.apache.org/failover-transport-reference.html
[p2.png]: /images/20220805/900d624549b9442687067cd00374b1be.png
[Center]: /images/20220805/8c106f3cecf04384aa60344bd07a2b93.png
[p4.png]: /images/20220805/4c1b34db0cf04942abd42a68337975a8.png
[http_download.csdn.net_detail_tianwei7518_8759641]: http://download.csdn.net/detail/tianwei7518/8759641
[ActiveMQ_network connector]: http://blog.csdn.net/kimmking/article/details/8440150
[ActiveMQ]: http://www.huaishao8.com/config/activemq/178.html
[ActiveMQ 1]: http://www.open-open.com/lib/view/open1400126457817.html
[activemq master-slave]: http://wenku.baidu.com/view/219cf44b2e3f5727a5e962b7.html
[ActiveMQ 2]: http://blog.csdn.net/kimmking/article/details/13768367
[ActiveMQ 3]: http://bh-keven.iteye.com/blog/1617788