JMS之——ActiveMQ 高可用与负载均衡集群安装、配置(ZooKeeper + LevelDB + Static discovery)

2021-07-30 21:33:25

一、说明

从 ActiveMQ 5.9 开始， ActiveMQ 的集群实现方式取消了传统的 Master-Slave 方式，增加了基于ZooKeeper + LevelDB 的 Master-Slave 实现方式，其他两种方式目录共享和数据库共享依然存在。
三种集群方式的对比：

1、基于共享文件系统（KahaDB， 默认）

  1. <persistenceAdapter>
  2. <kahaDB directory="${activemq.data}/kahadb"/>
  3. </persistenceAdapter>

2、基于 JDBC

  1. <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  2. <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  3. <property name="url" value="jdbc:mysql://localhost:3306/amq?relaxAutoCommit=true"/>
  4. <property name="username" value="root"/>
  5. <property name="password" value="root"/>
  6. <property name="maxActive" value="20"/>
  7. <property name="poolPreparedStatements" value="true"/>
  8. </bean>
  9. <persistenceAdapter>
  10. <jdbcPersistenceAdapter dataDirectory="${activemq.data}" dataSource="#mysql-ds" createTablesOnStartup="false"/>
  11. </persistenceAdapter>

3、基于可复制的 LevelDB（本博文采用这种集群方式）

LevelDB 是 Google 开发的一套用于持久化数据的高性能类库。 LevelDB 并不是一种服务,用户需要自行实现 Server。 是单进程的服务，能够处理十亿级别规模 Key-Value 型数据，占用内存小。

  1. <persistenceAdapter>
  2. <replicatedLevelDB
  3. directory="${activemq.data}/leveldb"
  4. replicas="3"
  5. bind="tcp://0.0.0.0:62621"
  6. zkAddress="localhost:2181,localhost:2182,localhost:2183"
  7. hostname="localhost"
  8. zkPath="/activemq/leveldb-stores"
  9. />
  10. </persistenceAdapter>

二、原理

官方文档：http://activemq.apache.org/replicated-leveldb-store.html
集群原理图：

JMS之——ActiveMQ 高可用与负载均衡集群安装、配置(ZooKeeper + LevelDB + Static discovery)

高可用的原理：使用 ZooKeeper（集群）注册所有的 ActiveMQ Broker。只有其中的一个 Broker 可以提供服务，被视为 Master，其他的 Broker 处于待机状态，被视为 Slave。如果 Master 因故障而不能提供服务，ZooKeeper 会从 Slave 中选举出一个 Broker 充当 Master。Slave 连接 Master 并同步他们的存储状态， Slave 不接受客户端连接。所有的存储操作都将被复制到连接至 Master 的 Slaves。 如果 Master 宕了，得到了最新更新的 Slave 会成为 Master。 故障节点在恢复后会重新加入到集群中并连接 Master 进入 Slave 模式。所有需要同步的 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失败了，服务中断。（原理与 ZooKeeper 集群的高可用实现方式类似）

三、部署规划

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的安装、 配置 》）

主机 集群端口 消息端口 控制台端口 节点安装目录
192.168.50.132 62621 51511 8161 /usr/local/activemq/node-01
192.168.50.133 62622 51512 8162 /usr/local/activemq/node-02
192.168.50.134 62623 51513 8163 /usr/local/activemq/node-03

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

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

3、 创建/usr/local/activemq 目录

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

  1. $ mkdir /usr/local/activemq

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

4、 解压并按节点命名

  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、修改conf/jetty.xml

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

  1. <bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
  2. <!-- the default port number for the web console -->
  3. <property name="host" value="0.0.0.0"/>
  4. <property name="port" value="8161"/>
  5. </bean>

Node-02 管控台端口：

  1. <bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
  2. <!-- the default port number for the web console -->
  3. <property name="host" value="0.0.0.0"/>
  4. <property name="port" value="8162"/>
  5. </bean>

Node-03 管控台端口：

  1. <bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start">
  2. <!-- the default port number for the web console -->
  3. <property name="host" value="0.0.0.0"/>
  4. <property name="port" value="8163"/>
  5. </bean>

6、 集群配置

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

  1. <broker xmlns="http://activemq.apache.org/schema/core" brokerName="liuyazhuang" dataDirectory="${activemq.data}">
  2. <persistenceAdapter>
  3. <!-- kahaDB directory="${activemq.data}/kahadb"/ -->
  4. <replicatedLevelDB
  5. directory="${activemq.data}/leveldb"
  6. replicas="3"
  7. bind="tcp://0.0.0.0:62621"
  8. zkAddress="192.168.50.132:2181,192.168.50.133:2182,192.168.50.134:2183"
  9. hostname="liuyazhuang132"
  10. zkPath="/activemq/leveldb-stores"
  11. />
  12. </persistenceAdapter>
  13. </broker>

Node-02 中的持久化配置:

  1. <broker xmlns="http://activemq.apache.org/schema/core" brokerName="liuyazhuang" dataDirectory="${activemq.data}">
  2. <persistenceAdapter>
  3. <!-- kahaDB directory="${activemq.data}/kahadb"/ -->
  4. <replicatedLevelDB
  5. directory="${activemq.data}/leveldb"
  6. replicas="3"
  7. bind="tcp://0.0.0.0:62622"
  8. zkAddress="192.168.50.132:2181,192.168.50.133:2182,192.168.50.134:2183"
  9. hostname="liuyazhuang133"
  10. zkPath="/activemq/leveldb-stores"
  11. />
  12. </persistenceAdapter>
  13. </broker>


Node-03 中的持久化配置:




    

  1. <broker xmlns="http://activemq.apache.org/schema/core" brokerName="liuyazhuang" dataDirectory="${activemq.data}">
    2. 

  2. <persistenceAdapter>
    3. 

  3. <!-- kahaDB directory="${activemq.data}/kahadb"/ -->
    4. 

  4. <replicatedLevelDB
    5. 

  5. directory="${activemq.data}/leveldb"
    6. 

  6. replicas="3"
    7. 

  7. bind="tcp://0.0.0.0:62623"
    8. 

  8. zkAddress="192.168.50.132:2181,192.168.50.133:2182,192.168.50.134:2183"
    9. 

  9. hostname="liuyazhuang134"
    10. 

  10. zkPath="/activemq/leveldb-stores"
    11. 

  11. />
    12. 

  12. </persistenceAdapter>
    13. 

  13. </broker>
    14. 





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




    

  1. <transportConnectors>
    2. 

  2. <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    3. 

  3. <transportConnector name="openwire" uri="tcp://0.0.0.0:51511?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    4. 

  4. <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    5. 

  5. <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    6. 

  6. <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    7. 

  7. <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    8. 

  8. </transportConnectors>
    9. 





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




    

  1. <transportConnectors>
    2. 

  2. <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    3. 

  3. <transportConnector name="openwire" uri="tcp://0.0.0.0:51512?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    4. 

  4. <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    5. 

  5. <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    6. 

  6. <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    7. 

  7. <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    8. 

  8. /transportConnectors>
    9. 





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




    

  1. <transportConnectors>
    2. 

  2. <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
    3. 

  3. <transportConnector name="openwire" uri="tcp://0.0.0.0:51513?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    4. 

  4. <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    5. 

  5. <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    6. 

  6. <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    7. 

  7. <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
    8. 

  8. </transportConnectors>
    9. 





7、 启动ActiveMQ并监听日志


按顺序启动 3 个 ActiveMQ 节点




    

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

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

  3. $ /usr/local/activemq/node-03/bin/activemq start
    4. 





监听日志：




    

  1. $ tail -f /usr/local/activemq/node-01/data/activemq.log
    2. 

  2. $ tail -f /usr/local/activemq/node-02/data/activemq.log
    3. 

  3. $ tail -f /usr/local/activemq/node-03/data/activemq.log
    4. 





8、集群的节点状态分析


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


JMS之——ActiveMQ 高可用与负载均衡集群安装、配置(ZooKeeper + LevelDB + Static discovery)


9、 集群可用性测试


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




  1. failover:(tcp://192.168.50.132:51511,tcp://192.168.50.133:51512,tcp://192.168.50.134:51513)?randomize=false




10、 集群高可用测试


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


11、 设置开机启动




    

  1. # vi /etc/rc.local
    2. 

  2. /usr/local/activemq/node-01/bin/activemq start
    3. 

  3. /usr/local/activemq/node-02/bin/activemq start
    4. 

  4. /usr/local/activemq/node-03/bin/activemq start
    5. 





12、 配置优化


updateURIsURL，通过 URL（或者本地路径）获取重连的 url，这样做具有良好的扩展性，因为客户端每次连接都是从 URL（或文件）中加载一次，所以可以随时从文件中更新 url 列表，做到动态添加 MQ 的备点。failover:()?randomize=false&updateURIsURL=file:/home/wusc/activemq/urllist.txt
urllist.txt 中的地址通过英文逗号分隔，示例：




  1. tcp://192.168.50.132:51511,tcp://192.168.50.133:51512,tcp://192.168.50.134:51513




13、官方文档的一则警告


附上官方文档的一则警告，请使用者注意。 replicatedLevelDB 不支持延迟或者计划任务消息。这些消息存储在另外的 LevelDB 文件中，如果使用延迟或者计划任务消息，将不会复制到 slave Broker 上，不能实现消息的高可用。


四、高可用+负载均衡实现


Broker-Cluster 可以解实现载均衡，但当其中一个 Broker 突然宕掉的话，那么存在于该 Broker 上处于 Pending 状态的 message 将会丢失，无法达到高可用的目的。Master-Slave 与 Broker-Cluster 相结合的部署


1、集群 1 链接集群 2




    

  1. <networkConnectors>
    2. 

  2. <networkConnector uri="static:(tcp://192.168.1.101:53531,tcp://192.168.1.101:53532,tcp://192.168.1.101:53533)" duplex="false"/>
    3. 

  3. </networkConnectors>
    4. 





2、集群 2 链接集群 1




    

  1. <networkConnectors>
    2. 

  2. <networkConnector uri="static:(tcp://192.168.50.132:51511,tcp://192.168.50.133:51512,tcp://192.168.50.134:51513)" duplex="false"/>
    3. 

  3. </networkConnectors>
    4. 





注：以上配置需配置到activemq.xml文件中 <persistenceAdapter>... </persistenceAdapter>节点上面，与其为同级节点，具体如下图：


JMS之——ActiveMQ 高可用与负载均衡集群安装、配置(ZooKeeper + LevelDB + Static discovery)
上一篇：搜索服务Solr集群搭建 使用ZooKeeper作为代理层

下一篇：使用ef查询有缓存的问题