ActiveMQ高可用集群方案

一. ActiveMQ的高可用原理
使用ZooKeeper（集群）注册全部的ActiveMQ Broker。只有其中的一个Broker能够提供服务，被视为 Master，其余的 Broker 处于待机状态，被视为Slave。若是Master因故障而不能提供服务，Zookeeper会从Slave中选举出一个Broker充当Master。
Slave链接Master并同步他们的存储状态，Slave不接受客户端链接。全部的存储操做都将被复制到 链接至 Master的Slaves。若是Master宕了，获得了最新更新的Slave会成为 Master。故障节点在恢复后会从新加入到集群中并链接Master进入Slave模式。
是否是以为和Redis Sentinel主从高可用的方式很像，这里的zookeeper起到的做用和reids里的sentinel做用差很少。

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

二. ActiveMQ的持久化方式
ActiveMQ有三种持久化方式（在activemq.xml可配）：
(1) 基于共享文件系统（KahaDB，默认）

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

(2) 基于JDBC

<persistenceAdapter>
    <jdbcPersistenceAdapter dataSource="#MySQL-DS"/>
</persistenceAdapter>
<!--注意：须要添加mysql-connector-java相关的jar包到avtivemq的lib包下-->
<bean id="MySQL-DS" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="url" value="jdbc:mysql://127.0.0.1:3306/beautyssm_mq?useUnicode=true&amp;characterEncoding=UTF-8"/>
    <property name="username" value="root"/>
    <property name="password" value="xxxx"/>
</bean>

(3) 基于可复制的LevelDB（经常使用于集群）

<persistenceAdapter>
  <replicatedLevelDB
    directory="${activemq.data}/leveldb" #数据存储路径
    replicas="3" #节点个数
    bind="tcp://0.0.0.0:62621" #用于各个节点之间的通信
    zkAddress="localhost:2181,localhost:2182,localhost:2183"
    hostname="localhost"
    zkPath="/activemq/leveldb-stores"/>#在zookeeper中集群相关数据存放路径
</persistenceAdapter>

LevelDB是Google开发的一套用于持久化数据的高性能类库。LevelDB并非一种服务,用户须要自行实现Server。是单进程的服务，可以处理十亿级别规模Key-Value型数据，占用内存小。
这里咱们采用第三种方式，也是官网推荐的方式。

三. 高可用的部署
一、ActiveMQ的高可用集群基于Zookeeper的高可用集群，因此要先部署Zookeeper集群
见：ZooKeeper高可用集群的安装及配置

二、在3个ActiveMQ节点中配置conf/activemq.xml中的监控端口
节点1：

<property name="port" value="8161"/>

节点2：

<property name="port" value="8162"/>

节点3：

<property name="port" value="8163"/>

三、在3个ActiveMQ节点中配置conf/activemq.xml中的持久化适配器

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
    <persistenceAdapter>
      <replicatedLevelDB
        directory="${activemq.data}/leveldb"
        replicas="3"
        bind="tcp://0.0.0.0:6262?"
        zkAddress="localhost:2181,localhost:2182,localhost:2183"
        hostname="localhost"
        zkPath="/activemq/leveldb-stores"/>
    </persistenceAdapter>
</broker>

注：每一个 ActiveMQ 的 BrokerName 必须相同，不然不能加入集群。

四、修改各节点的消息端口：

节点1：

<transportConnector name="openwire" uri="tcp://0.0.0.0:61611maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

节点2：

<transportConnector name="openwire" uri="tcp://0.0.0.0:61612maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

节点3：

<transportConnector name="openwire" uri="tcp://0.0.0.0:61613maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>

五、按顺序启动 3 个 ActiveMQ 节点：

$ /usr/local/activemq/activemq-01/bin/activemq start
$ /usr/local/activemq/activemq-02/bin/activemq start
$ /usr/local/activemq/activemq-03/bin/activemq start

监听日志：

$ tail -f /usr/local/activemq/activemq-01/data/activemq.log
$ tail -f /usr/local/activemq/activemq-02/data/activemq.log
$ tail -f /usr/local/activemq/activemq-03/data/activemq.log

四. 集群部署
以前已经实现了ActiveMQ的高可用部署，单仅仅是高可用集群，没法达到负载均衡的做用，接下来只需简单配置就能完成能够实现负载均衡的集群功能：

在集群1的activemq.xml中连接集群2（在persistenceAdapter标签前配置）：

<networkConnectors>
    <networkConnector uri="static:(tcp://192.168.2.100:61611,tcp://192.168.2.101:61612,tcp://192.168.2.102:61613)" duplex="false"/>
</networkConnectors>

在集群2的activemq.xml中连接集群1（在persistenceAdapter标签前配置）：

<networkConnectors>
    <networkConnector uri="static:(tcp://192.168.1.100:61611,tcp://192.168.1.101:61612,tcp://192.168.1.102:61613)" duplex="false"/>
</networkConnectors>

这样就实现了ActiveMQ的集群高可用负载均衡功能。

三. 客户端链接：
ActiveMQ 的客户端只能访问Master的Broker，其余处于Slave的Broker不能访问。因此客户端链接Broker应该使用 failover 协议。
配置文件地址应为：

failover:(tcp://192.168.1.100:61611,tcp://192.168.1.100:61612,tcp://192.168.1.100:61613)?randomize=false
或：
failover:(tcp://192.168.2.100:61611,tcp://192.168.2.100:61612,tcp://192.168.2.100:61613)?randomize=false