基于zookeeper（集群）+levelDB的activeMQ高可用集群搭建

布满荆棘的人生 2022-05-24 09:18 220阅读 0赞

**上一篇我们进行了zookeeper集群的搭建。本篇我们进行activeMQ集群的搭建。**

**1、activeMQ集群部署规划。**

**环境：CentOS、jdk8.**

**版本：5.14.3**

**zookeeper集群环境**：192.9.200.130:2181、192.9.200.159.2181,192.9.200.160:2181

<table> 
 <tbody> 
  <tr> 
   <td>主机</td> 
   <td>集群端口</td> 
   <td>消息端口</td> 
   <td>管控台端口</td> 
   <td>activeMQ安装目录</td> 
  </tr> 
  <tr> 
   <td>192.9.200.130</td> 
   <td>62621</td> 
   <td>51511</td> 
   <td>8161</td> 
   <td>/home/rds</td> 
  </tr> 
  <tr> 
   <td>192.9.200.159</td> 
   <td>62622</td> 
   <td>51512</td> 
   <td>8162</td> 
   <td>/home/rds</td> 
  </tr> 
  <tr> 
   <td>192.9.200.160</td> 
   <td>62623</td> 
   <td>51513</td> 
   <td>8163</td> 
   <td>/home/rds</td> 
  </tr> 
 </tbody> 
</table>

**2、防火墙开放对应上表格管控台端口。**

**3、上传apache-activemq-5.14.3-bin.tar.gz到三台服务器的/home/rds目录下。**

![70][]

**4、分别解压三台服务器/home/rds目录下的activemq并修改名称。**

tar -zxf apache-activemq-5.14.3-bin.tar.gz

mv apache-activemq-5.14.3 activemq

**5、修改三台服务器管控台端口（/home/rds/activemq/conf/jetty.xml）。默认为8161。**

vi /home/rds/activemq/conf/jetty.xml

192.9.200.130主机：

![70 1][]

192.9.200.159主机：

![70 2][]

192.9.200.160主机：

![70 3][]

**6、集群配置（重要）**

在3台服务器的3个activemq节点中配置conf/activemq.xml的持久化适配器。

修改其中的bind、zkAddress、hostname和zkPath。

注意：3个activemq的brokerName必须相同，否则不能加入集群。

192.9.200.130主机的持久化适配器：

![70 4][]

![70 5][]

192.9.200.159主机持久化适配器：

![70 6][]

![70 7][]

192.9.200.160主机持久化适配器：

![70 8][]

![70 9][]

**解释：**

将上述的kahaDB注释掉。该持久化方案是基于文件的持久化适配器。

directory：数据和日志文件目录

replicas：节点数（一般是(replicas/2 + 1)个，避免集群宕机）

zkAddress：zookeeper集群地址。

hostname：activemq所在的主机地址。（本机地址）

zkPath：主从切换时候选举信息。

**7、修改各节点的消息端口。（注意：避免端口冲突），默认消息端口为61616**

192.9.200.130主机消息端口：

![70 10][]

192.9.200.159主机消息端口：

![70 11][]

192.9.200.160主机消息端口：

![70 12][]

**8、设置开机启动（可省略）**

\#vi /etc/rc.local    (分别在3台主机上执行)

su - rds -c '/home/rds/activemq/bin/activemq start'

**9、按顺序启动该3个节点**

/home/rds/activemq/bin/activemq start

监听日志：

tail -f /home/rds/activemq/data/activemq.log

**10、集群节点状态分析。**

下载ZooInspector。具体使用可以问度娘，这里不再赘述。

集群启动后对Zookeeper数据的抓图，可以看到activemq有3个节点。分别是：0000000026，0000000027，0000000028

下图第一张展现了0000000026节点的值。可以看到elected不为空，说明这个节点是Master，其他两个是Slave。

![70 13][]![70 14][]![70 15][]

**11、集群的可用性测试。**

activeMQ的客户端只能访问Master的Broker，其他处于Slave的Broker不能访问。

![70 16][]

所以：客户端一般配置为：

<table> 
 <tbody> 
  <tr> 
   <td><pre style="margin-bottom:0px;white-space:pre-wrap;"><span style="font-family:'Microsoft YaHei';font-size:14px;line-height:1.5;">failover:(tcp:192.9.200.130:51511,192.9.200.159:51512,192.9.200.160:51513)?randomize=false</span></pre></td> 
  </tr> 
 </tbody> 
</table>

[70]: /images/20220524/2b02f9a88e9e4d0fa1272aab0c918312.png
[70 1]: /images/20220524/41a18056b5d749a3b6b446e246ff6609.png
[70 2]: /images/20220524/55a41c0787954f3eb18f7f8c1dd47820.png
[70 3]: /images/20220524/bb327b2195cc4abead9687bb83a3f80f.png
[70 4]: /images/20220524/73b25c51b8d14a26969b3fb0214fccd5.png
[70 5]: /images/20220524/eb95227dd5f44ea9a41cd74e3f2734c4.png
[70 6]: /images/20220524/d4752ddab62e4fd8aa883000cb4911a6.png
[70 7]: /images/20220524/3a5307518d704ed78adfc872bf2062f9.png
[70 8]: /images/20220524/1e64e6f57f8d4824898b30a3b2ecc34c.png
[70 9]: /images/20220524/cd43166e07784a85a085efffe98af195.png
[70 10]: /images/20220524/e003dc05f32944dca501081ba56ba67c.png
[70 11]: /images/20220524/efa3966b0ddb4c529173ad28a31224e6.png
[70 12]: /images/20220524/706b7604d46d4ad4b69d8e44cc5d6f55.png
[70 13]: https://img-blog.csdn.net/2018052417343575?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5MjQ0MjY0/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 14]: https://img-blog.csdn.net/20180524173507543?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5MjQ0MjY0/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 15]: /images/20220524/3ce1db57a2184945bf18ef8a74f70c30.png
[70 16]: /images/20220524/667b3ce994244df0a5fd24c562a955e0.png