JMS之——ActiveMQ高可用集群安装、配置(基于ZooKeeper + LevelDB的伪集群)

Bertha 。 2022-06-10 02:08 235阅读 0赞

来源

[http://blog.csdn.net/l1028386804/article/details/72599615?locationNum=12&fps=1][http_blog.csdn.net_l1028386804_article_details_72599615_locationNum_12_fps_1]

**ActiveMQ技术学习 [https://www.itkc8.com][https_www.itkc8.com]**

ActiveMQ的单节点安装请参见博文《[JMS之——ActiveMQ的安装与配置(单机版)][JMS_ActiveMQ] 》

### 1、 ActiveMQ 集群部署规划 ###

环境： CentOS 6.5 x64 、 JDK7  
版本： ActiveMQ 5.14.4  
ZooKeeper 集群环境： 192.168.50.132:2181,192.168.50.133:2182,192.168.50.134:2183  
（ZooKeeper 集群部署请参考《[Dubbo之——Dubbo 注册中心集群Zookeeper-3.4.9的安装、 配置][Dubbo_Dubbo _Zookeeper-3.4.9_]》）

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td>主机</td> 
   <td>集群端口</td> 
   <td>消息端口</td> 
   <td>控制台端口</td> 
   <td>节点安装目录</td> 
  </tr> 
  <tr> 
   <td>192.168.1.101</td> 
   <td>63631</td> 
   <td>53531</td> 
   <td>8361</td> 
   <td>/usr/local/activemq/node-01</td> 
  </tr> 
  <tr> 
   <td>192.168.1.101</td> 
   <td>63632</td> 
   <td>53532</td> 
   <td>8362</td> 
   <td>/usr/local/activemq/node-02</td> 
  </tr> 
  <tr> 
   <td>192.168.1.101</td> 
   <td>63633</td> 
   <td>53533</td> 
   <td>8363</td> 
   <td>/usr/local/activemq/node-03</td> 
  </tr> 
 </tbody> 
</table>

### 2、 防火墙打开对应的端口 ###

**\[plain\]** [view plain][] [copy][view plain]

1.  \#\# mq cluster  
2.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 8361 -j ACCEPT  
3.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 8362 -j ACCEPT  
4.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 8363 -j ACCEPT  
5.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 53531 -j ACCEPT  
6.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 53532 -j ACCEPT  
7.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 53533 -j ACCEPT  
8.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 63631 -j ACCEPT  
9.  \-A INPUT -m state --state NEW -m tcp -p tcp --dport 63632 -j ACCEPT  
10. \-A INPUT -m state --state NEW -m tcp -p tcp --dport 63633 -j ACCEPT  
11. \-A INPUT -m state --state NEW -m tcp -p tcp --dport 63631 -j ACCEPT

### 3、 分别在三台主机中创建/usr/local/activemq 目录 ###

**\[plain\]** [view plain][] [copy][view plain]

1.  $ mkdir /usr/local/activemq

上传 apache-activemq-5.14.4-bin.tar.gz 到/usr/local/activemq 目录

### 4、 解压并按节点命名 ###

###  ###

**\[plain\]** [view plain][] [copy][view plain]

1.  $ cd /usr/local/activemq  
2.  $ tar -xvf apache-activemq-5.14.4-bin.tar.gz  
3.  $ mv apache-activemq-5.14.4 node-0X \#(X 代表节点号 1、 2、 3， 下同)

### 5、 修改jetty.xml ###

修改管理控制台端口（默认为 8161） 可在 conf/jetty.xml 中修改， 如下：  
Node-01 管控台端口：

**\[html\]** [view plain][] [copy][view plain]

1.  **<****bean** id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start"**>**  
2.        
3.      **<****property** name="host" value="0.0.0.0"**/>**  
4.      **<****property** name="port" value="8361"**/>**  
5.  **</****bean****>**

Node-02 管控台端口：

**\[html\]** [view plain][] [copy][view plain]

Node-03 管控台端口：

**\[html\]** [view plain][] [copy][view plain]

### 6、 集群配置 ###

在 3 个 ActiveMQ 节点中配置 conf/activemq.xml 中的持久化适配器。修改其中 bind、 zkAddress、hostname 和 zkPath。 注意： 每个 ActiveMQ 的 BrokerName 必须相同，否则不能加入集群。  
Node-01 中的持久化配置:

**\[html\]** [view plain][] [copy][view plain]

1.  **<****broker** xmlns="http://activemq.apache.org/schema/core" brokerName="DubboEdu2" dataDirectory="$\{activemq.data\}"**>**  
2.      **<****persistenceAdapter****>**  
3.        
4.          **<****replicatedLevelDB**  
5.          directory="$\{activemq.data\}/leveldb"  
6.          replicas="3"  
7.          bind="tcp://0.0.0.0:63631"  
8.          zkAddress="192.168.1.81:2181,192.168.1.82:2182,192.168.1.83:2183"  
9.          hostname="edu-mq-01"  
10.         zkPath="/activemq2/leveldb-stores"  
11.         **/>**  
12.     **</****persistenceAdapter****>**  
13. **</****broker****>**

Node-02 中的持久化配置:

**\[html\]** [view plain][] [copy][view plain]

1.  **<****broker** xmlns="http://activemq.apache.org/schema/core" brokerName="DubboEdu2" dataDirectory="$\{activemq.data\}"**>**  
2.      **<****persistenceAdapter****>**  
3.            
4.          **<****replicatedLevelDB**  
5.          directory="$\{activemq.data\}/leveldb"  
6.          replicas="3"  
7.          bind="tcp://0.0.0.0:63632"  
8.          zkAddress="192.168.1.81:2181,192.168.1.82:2182,192.168.1.83:2183"  
9.          hostname="edu-mq-01"  
10.         zkPath="/activemq2/leveldb-stores"  
11.         **/>**  
12.     **</****persistenceAdapter****>**  
13. **</****broker****>**

Node-03 中的持久化配置:

**\[html\]** [view plain][] [copy][view plain]

1.  **<****broker** xmlns="http://activemq.apache.org/schema/core" brokerName="DubboEdu2" dataDirectory="$\{activemq.data\}"**>**  
2.      **<****persistenceAdapter****>**  
3.            
4.          **<****replicatedLevelDB**  
5.          directory="$\{activemq.data\}/leveldb"  
6.          replicas="3"  
7.          bind="tcp://0.0.0.0:63633"  
8.          zkAddress="192.168.1.81:2181,192.168.1.82:2182,192.168.1.83:2183"  
9.          hostname="edu-mq-01"  
10.         zkPath="/activemq2/leveldb-stores"  
11.         **/>**  
12.     **</****persistenceAdapter****>**  
13. **</****broker****>**

修改各节点的消息端口（注意，避免端口冲突）：  
Node-01 中的消息端口配置:

**\[html\]** [view plain][] [copy][view plain]

1.  **<****transportConnectors****>**  
2.        
3.      **<****transportConnector** name="openwire" uri="tcp://0.0.0.0:53531?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
4.      **<****transportConnector** name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
5.      **<****transportConnector** name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
6.      **<****transportConnector** name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
7.      **<****transportConnector** name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
8.  **</****transportConnectors****>**

Node-02 中的消息端口配置:

**\[html\]** [view plain][] [copy][view plain]

1.  **<****transportConnectors****>**  
2.        
3.      **<****transportConnector** name="openwire" uri="tcp://0.0.0.0:53532?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
4.      **<****transportConnector** name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
5.      **<****transportConnector** name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
6.      **<****transportConnector** name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
7.      **<****transportConnector** name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
8.  **</****transportConnectors****>**

Node-03 中的消息端口配置:

**\[html\]** [view plain][] [copy][view plain]

1.  **<****transportConnectors****>**  
2.        
3.      **<****transportConnector** name="openwire" uri="tcp://0.0.0.0:53533?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
4.      **<****transportConnector** name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
5.      **<****transportConnector** name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
6.      **<****transportConnector** name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
7.      **<****transportConnector** name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"**/>**  
8.  **</****transportConnectors****>**

### 7、 按顺序启动 3 个 ActiveMQ 节点 ###

**\[plain\]** [view plain][] [copy][view plain]

1.  $ /usr/local/activemq/node-01/bin/activemq start  
2.  $ /usr/local/activemq/node-02/bin/activemq start  
3.  $ /usr/local/activemq/node-03/bin/activemq start

### 8、集群的节点状态分析 ###

集群启动后对 ZooKeeper 数据的抓图，可以看到 ActiveMQ 的有 3 个节点，分别是 00000000000，00000000001， 00000000002。  
以下第一张图展现了 00000000000 的值，可以看到 elected 的值是不为空，说明这个节点是 Master，其他两个节点是 Slave。  
![outside_default.png][]

### 9、 集群可用性测试 ###

ActiveMQ 的客户端只能访问 Master 的 Broker，其他处于 Slave 的 Broker 不能访问。所以客户端连接 Broker 应该使用 failover 协议。

**\[html\]** [view plain][] [copy][view plain]

1.  failover:(tcp://192.168.1.101:53531,tcp://192.168.1.101:53532,tcp://192.168.1.101:53533)?randomize=false

### 10、 集群高可用测试 ###

当一个 ActiveMQ 节点挂掉，或者一个 ZooKeeper 节点挂掉， ActiveMQ 服务依然正常运转。如果仅剩一个 ActiveMQ 节点，因为不能选举 Master， ActiveMQ 不能正常运转； 同样的，如果 ZooKeeper 仅剩一个节点活动，不管 ActiveMQ 各节点是否存活， ActiveMQ 也不能正常提供服务。

### 11、 设置开机启动 ###

**ActiveMQ技术学习 [https://www.itkc8.com][https_www.itkc8.com]**

**\[plain\]** [view plain][] [copy][view plain]

1.  \# vi /etc/rc.local  
2.  /usr/local/activemq/node-01/bin/activemq start  
3.  /usr/local/activemq/node-02/bin/activemq start  
4.  /usr/local/activemq/node-03/bin/activemq start  
5.

[http_blog.csdn.net_l1028386804_article_details_72599615_locationNum_12_fps_1]: http://blog.csdn.net/l1028386804/article/details/72599615?locationNum=12&fps=1
[https_www.itkc8.com]: https://www.itkc8.com
[JMS_ActiveMQ]: http://blog.csdn.net/l1028386804/article/details/71598339
[Dubbo_Dubbo _Zookeeper-3.4.9_]: http://blog.csdn.net/l1028386804/article/details/72595552
[view plain]: http://blog.csdn.net/l1028386804/article/details/72599615?locationNum=12&fps=1#
[outside_default.png]: /images/20220610/e6881e06ae4e45259b0a89b76833d241.png