| 编辑推荐: |
本文来自于jianshu，文章介绍了采用Zookeeper+LevelDB+ActiveMQ的方式进行ActiveMQ集群的相关知识。 |
|
这是ActiveMQ系列的最后一篇文章，主要是关于ActiveMQ集群，这里采用的方式是：Zookeeper+LevelDB+ActiveMQ。前面2篇博客地址如下：
《ActiveMQ从入门到精通（一）》、《ActiveMQ从入门到精通（二）》。
利用Zookeeper实现ActiveMQ的高可用
话不多说，先来看一张ActiveMQ官方提供的架构图：
Zookeeper + ActiveMQ
Master/Slave broker的信息要注册到ZK
注意到只有Master对外提供了服务，Slave是待机状态。当Master出现故障，ZK内部的选举机制，会让一个Slave升级成Master对外提供服务。
关于ZK，以后博主会有专题进行介绍，这里不做详细讲解，只需要了解通过ZK的协调、选举、容错机制等会实现ActiveMQ的高可用。
既然要做到高可用，那么ZK也得是高可用的，所以这里的搭建方案是这样的：
搭建方案
第一步：JDK环境
jdk环境
保证这3台机器都安装了JDK，并配置了JAVA环境变量。
第二步：配置Zookeeper
zk环境变量
为什么要配置ZK环境变量呢？很简单，我想在命令行下直接使用ZK相关的命令，而不是进入到安装ZK目录下的bin，更不想用绝对路径。
zoo.cfg
注意dataDir目录的指定；注意2181是外部访问ZK的端口；
2888:3888是ZK集群内部通信（比如ZK原子广播消息）的端口，注意server.X的定义，这是将ZK集群中的实例进行编号，实际上需要在dataDir目录中新建myid文件，并与之保持一致。
myid文件
第三步：启动ZK
zkServer start
可以通过netstat命令查看2722进程，发现ZK的端口是2181，这和zoo.cfg的配置是一致的。让3台机器的ZK都启动起来。
zk status
第四步：ActiveMQ主从配置
注意了，由于我将在3台物理机上搭建一台Master，2台Slave，因此我这边不需要对端口配置文件进行改动。比如WEB管控台的jetty.xml。
activemq.xml:brokerName
3台机器应该对外只有一个统一的名称，就是这个brokerName。3台机器都修改成一个名称即可。这里持久化，我将采用LevelDB，因此需要修改持久化配置：
leveldb
注意bind地址，其实是ActiveMQ集群内部通信的TCP端口，和ActiveMQ对外提供的消息端口（默认61616）不要搞混了。
hostname即本机的主机名称。
给出ZK集群的列表以及zkPath。zkPath下面其实存放着ActiveMQ的节点，在后续你会看到。
启动3台机器上的ActiveMQ，然后利用ZooInspector你可以看到：
121节点是Master
此时此刻，基于ZK的ActiveMQ的高可用方案就做好了。那么JAVA端访问ActiveMQ有什么变化么？其实就是在创建ConnectionFactory的时候给定的URL有变化：failover:(tcp://192.168.99.121:61616,tcp://192.168.99.122:61616,
tcp://192.168.99.123:61616)?Randomize=false就是一个失败转移协议！上面只是做了一个ActiveMQ的高可用方案，那么ActiveMQ集群呢？其实所谓的ActiveMQ集群就是多个ActiveMQ高可用之间产生关联：
ActiveMQ集群
高可用的ActiveMQ-1,ActiveMQ-2,...,ActiveMQ-N就可以组建ActiveMQ集群
在配置上很简单，其实就是ActiveMQ-1要知道ActiveMQ-2的信息而已，这里大家可以自行百度，不在演示了。
整个ActiveMQ从入门到精通系列就结束了，希望对大家有帮助！我们RocketMQ系列再见~ |
