activemq集群之master-slave+zookeeper

川长思鸟来 2022-05-14 01:28 212阅读 0赞

参考[ActiveMQ的集群方案对比及部署][ActiveMQ]

**本文使用的是activemq的master slave集群，俗称高可用，并没有考虑负载均衡。使用Zookeeper来管理各个broker.**

由于zookeeper选举原则是2N+1，所以至少要有3个broker。否则会提示“Not enough cluster members when using LevelDB replication”。这样就没法选择Master。

本文的例子是在Windows64位环境。

## zookeeper安装 ##

下载就不说了，我下载的是zookeeper-3.3.6版本。下载下来后解压缩，然后在conf目录新建zoo.cfg文件，内容如下：

# The number of milliseconds of each tick
    tickTime=2000
    # The number of ticks that the initial 
    # synchronization phase can take
    initLimit=10
    # The number of ticks that can pass between 
    # sending a request and getting an acknowledgement
    syncLimit=5
    # the directory where the snapshot is stored.
    dataDir=D:/luckystar88/soft/zookeeper-3.3.6/zookeeper-3.3.6/data/1
    # the port at which the clients will connect
    clientPort=2181

**启动zookeeper**  
执行zookeeperhome  z o o k e e p e r h o m e /bin下的zkServer.cmd即可。

## activemq安装 ##

下载不多说，我这里使用的是apache-activemq-5.14.2版本。  
解压缩，新建目录activemqtest，复制到该目录，并重命名为brokerA。  
![ed6ec565ec161726.png][]

同样的，复制brokerA的副本，并重命名，得到brokerB,brokerC。这样就有3个broker。

## activemq各个broker配置 ##

**brokerA的配置**  
打开brokerA/conf下的activemq.xml文件。  
1.找到`<broker...`，将brokerName设置为一个值，比如broker1.

2.找到下面的代码，并注释掉。

3.增加下面的代码

zkAddress的IP即为安装和打开zookeeper的电脑的IP，port即为zoo.cfg中配置的clientPort。

4.修改transportConnector的端口为61616.

5.修改jetty.xml中的端口为8161.

**brokerB的配置**  
修改同brokerA，但transportConnector的端口改为61617，jetty的端口改为8162.

**brokerC的配置**  
修改同brokerA，但transportConnector的端口改为61618，jetty的端口改为8163.

### 启动activemq集群 ###

为了启动方便，我写了一个bat脚本，即activemqtest目录下的startCluster.bat。内容如下：

d:
    cd luckystar88/soft/activemqtest
    cd brokerA/bin/win64
    start activemq.bat
    
    cd ../../../brokerB/bin/win64/
    start activemq.bat
    
    cd ../../../brokerC/bin/win64/
    start activemq.bat

双击startCluster.bat，即可启动。（前提是zookeeper要先启动）  
![ea66b5df9dad8d6a.png][]  
如上图所示，其中一个broker成为了master，其他2个成为了slave。

## java client连接activemq集群 ##

配置如下：

消息生产者可以每隔几秒钟发送一条数据到mq，消费者一直监听消息。  
在发送几条数据后，关闭master的broker，可以发现还是可以继续发送信息，并不会出错。而且[http://localhost:8161,http://localhost:8162,http://localhost:8163][http_localhost_8161_http_localhost_8162_http_localhost_8163]同一时间只有一个能打开。

**注意事项**

3个broker的brokerName,zkPath等必须一致。

[ActiveMQ]: http://www.cnblogs.com/guozhen/p/6209973.html
[ed6ec565ec161726.png]: http://p1.bqimg.com/567571/ed6ec565ec161726.png
[ea66b5df9dad8d6a.png]: http://p1.bpimg.com/567571/ea66b5df9dad8d6a.png
[http_localhost_8161_http_localhost_8162_http_localhost_8163]: http://localhost:8161,http://localhost:8162,http://localhost:8163