黑马程序员技术交流社区

标题: 【西安校区】ActiveMQ高可用集群的搭建 [打印本页]

作者: 西安Java组 时间: 2018-3-29 17:19
标题: 【西安校区】ActiveMQ高可用集群的搭建
本帖最后由逆风TO 于 2018-4-6 10:42 编辑

1 ActiveMQ集群的由来

单点的ActiveMQ作为企业应用无法满足业务的需求,因为单点的ActiveMQ存在单点故障问题,当该节点宕机以后,就会直接影响我们业务的正常运转,所以我们需要搭建高可用的ActiveMQ集群来支撑我们的业务系统

2 ActiveMQ集群的主要部署方式2.1 默认的单机部署（kahadb）

activeMQ的默认存储的单机方式，以本地kahadb文件的方式存储，所以性能指标完全依赖本地磁盘IO，不能提供高可用。

</persistenceAdapter>

2.2 基于共享数据库的主从（Shared JDBC Master/Slave）

可以基于postgres、mysql、oracle等常用数据库。每个节点启动都会争抢数据库锁，从而保证master的唯一性，其他节点作为备份，一直等待数据库锁的释放。因为所有消息读写，其实都是数据库操作，activeMQ节点本身压力很小，性能完全取决于数据库性能。优点：实现高可用和数据安全,简单灵活，2台节点就可以实现高可用. 缺点：稳定性依赖数据库,性能依赖数据库.

<beanid="mysql-ds"class="org.apache.commons.dbcp.BasicDataSource"destroy-method="close">
<property name="driverClassName"value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/amq?relaxAutoCommit=true"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
<property name="maxActive" value="20"/>
<property name="poolPreparedStatements"value="true"/>

</bean>

</persistenceAdapter>

2.3 基于zookeeper以及可复制的 LevelDB实现

5.9.0新推出的主从实现，基于zookeeper来选举出一个master，其他节点自动作为slave实时同步消息。因为有实时同步数据的slave的存在，master不用担心数据丢失，所以leveldb会优先采用内存存储消息，异步同步到磁盘。所以该方式的activeMQ读写性能都最好，特别是写性能能够媲美非持久化消息。优点：实现高可用和数据安全性能较好.缺点：因为选举机制要超过半数，所以最少需要3台节点，才能实现高可用。
LevelDB 是 Google 开发的一套用于持久化数据的高性能类库。 LevelDB 并不是一种服务,用户需要自行实现 Server。是单进程的服务，能够处理十亿级别规模 Key-Value 型数据，占用内存小。

</persistenceAdapter>

了解完毕ActiveMQ集群的三种部署方式以后,我们本教程将采用第三种方式来建ActiveMQ集群,因为第三种的读写性能都最好的.

3 ActiveMQ高可用原理

使用ZooKeeper（集群）注册所有的ActiveMQ Broker。只有其中的一个Broker可以提供服务，被视为 Master，其他的 Broker 处于待机状态，被视为Slave。如果Master因故障而不能提供服务，Zookeeper会从Slave中选举出一个Broker充当Master。Slave连接Master并同步他们的存储状态，Slave不接受客户端连接。所有的存储操作都将被复制到连接至 Master的Slaves。如果Master宕了，得到了最新更新的Slave会成为 Master。故障节点在恢复后会重新加入到集群中并连接Master进入Slave模式。

1 基于zookeeper以及leveldb实现高可用ActiveMQ集群

了解完毕ActiveMQ集群的三种部署方式以后,我们本教程将采用第三种方式来建ActiveMQ集群,因为第三种的读写性能都最好的.

1.1 ActiveMQ集群部署规划

环境： CentOS 6.6 x64 、 JDK7
版本： ActiveMQ 5.11.1

zookeeper集群说明: 192.168.221.141:2181 , 192.168.221.141:2182, 192.168.221.141:2183

集群节点规划说明:

主机	集群间通信端口	消息端口	管控台端口	其他端口	安装目录
192.168.221.136	62621	11616	8161	以1开始即可	/usr/local/src/activemq-cluster
192.168.221.136	62622	21616	8162	以2开始即可
192.168.221.136	62623	31616	8163	以3开始即可

1.2 搭建ActiveMQ步骤1.2.1 准备环境

Ø 在/usr/local/src/在创建activemq-cluster目录: mkdir –p /usr/local/src/activemq-cluster

Ø 上传activemq安装包到linux服务器下

Ø 解压activemq的安装包: tar –zxvf –C /usr/local/src/activemq-cluster

Ø 重命名: mv apache-activemq-5.12.0/ activemq-cluster-node01

Ø 以1节点为基础复制两个节点出来

² cp –r activemq-cluster-node01 activemq-cluster-node02

² cp –r activemq-cluster-node01 activemq-cluster-node03

1.2.2 修改管理控制台端口可在 conf/jetty.xml 中修改

node01管控台端口

</bean>

node02管控台端口

</bean>

node03管控台端口

</bean>

1.2.3 配置持久化适配器

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

node01-持久化适配器:

<replicatedLevelDB

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

replicas="3"

bind="tcp://192.168.221.136:62621"

zkAddress="192.168.80.129:2182,192.168.80.129:2183,192.168.80.129:2184"

hostname="192.168.80.129"

zkPath="/activemq/leveldb-stores"

</persistenceAdapter>

</broker>

node02-持久化适配器:

<replicatedLevelDB

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

replicas="3"

bind="tcp://192.168.221.136:62622"

zkAddress="192.168.221.145:2181,192.168.221.145:2182,192.168.221.145:2183"

hostname="192.168.221.136"

zkPath="/activemq/leveldb-stores"

</persistenceAdapter>

</broker>

node03-持久化适配器:

<replicatedLevelDB

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

replicas="3"

bind="tcp://192.168.221.136:62623"

zkAddress="192.168.221.145:2181,192.168.221.145:2182,192.168.221.145:2183"

hostname="192.168.221.136"

zkPath="/activemq/leveldb-stores"

</persistenceAdapter>

</broker>

1.2.4 修改消息服务端口

node-01消息服务端口:

</transportConnectors>

node-02消息服务端口:

</transportConnectors>

node-03消息服务端口:

</transportConnectors>

1.2.5 启动3个ActiveMQ集群节点

/usr/local/src/activemq-cluster/apache-activemq-01/bin/activemq start

/usr/local/src/activemq-cluster/apache-activemq-02/bin/activemq start

/usr/local/src/activemq-cluster/apache-activemq-03/bin/activemq start

监听日志

tail -f /usr/local/src/activemq-cluster/apache-activemq-01/data/activemq.log

tail -f /usr/local/src/activemq-cluster/apache-activemq-02/data/activemq.log

tail -f /usr/local/src/activemq-cluster/apache-activemq-03/data/activemq.log

1.2.6 集群的节点状态分析

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

1.1.1 集群测试

ActiveMQ的客户端只能访问MasterBroker,其他处于Slave的Broker不能访问.所以客户端连接Broker应该使用failover(故障转移)协议

failover:(tcp://192.168.221.136:11616,tcp://192.168.221.136:21616,tcp:// 192.168.221.136:31616)?randomize=false

1.1.2 客户端连接url配置优化

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

tcp://192.168.221.136:11616,tcp://192.168.221.136:21616,tcp:// 192.168.221.136:31616

1.1.3 集群测试结果说明

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

作者: Yin灬Yan 时间: 2018-3-30 13:09
我来占层楼啊

欢迎光临黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2