zookeeper与activemq整合

（1）zookeeper与activemq原理

使用ZooKeeper实现的Master-Slave实现方式，是对ActiveMQ进行高可用的一种有效的解决方案，高可用的原理：使用ZooKeeper（集群）注册所有的ActiveMQ Broker。只有其中的一个Broker可以对外提供服务（也就是Master节点），其他的Broker处于待机状态，被视为Slave。如果Master因故障而不能提供服务，则利用ZooKeeper的内部选举机制会从Slave中选举出一个Broker充当Master节点，继续对外提供服务。

（2）环境

centos版本

#cat /etc/redhat-release 
CentOS release 6.5 (Final)

关闭selinux和iptables防火墙配置

sed -ri '/^SELINUX=/cSELINUX=disable' /etc/selinux/config
setenforce 0
iptables -I INPUT 1 -s 192.168.92.0/24 -j ACCEPT
service iptables save

zookeeper环境

主机IP                 消息端口        通信端口        节点目录/usr/local/下
192.168.92.134        2181            2888:3888          zookeeper
192.168.92.135        2181            2888:3888          zookeeper
192.168.92.136        2181            2888:3888          zookeeper

activemq环境

主机IP                         消息端口      控制台端口          节点目录/usr/local/下
192.168.92.134                  61616          8161                 activemq
192.168.92.135                  61616          8161                 activemq
192.168.92.136                  61616          8161                 activemq

（3）安装zookeeper

1）基本配置

#node1配置：192.168.92.134 
[ -d /tools ] || mkdir /tools 
cd /tools
wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.3.6/zookeeper-3.3.6.tar.gz
tar xf zookeeper-3.3.6.tar.gz -C /usr/local/
ln -sv /usr/local/zookeeper-3.3.6/ /usr/local/zookeeper
mkdir  /usr/local/zookeeper/{data,log}
echo 1 >/usr/local/zookeeper/data/myid
echo "export PATH=/usr/local/zookeeper/bin:$PATH" >>/etc/profile ; source /etc/profile
###############################################################################
#node2配置：192.168.92.135 
[ -d /tools ] || mkdir /tools 
cd /tools
wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.3.6/zookeeper-3.3.6.tar.gz
tar xf zookeeper-3.3.6.tar.gz -C /usr/local/
ln -sv /usr/local/zookeeper-3.3.6/ /usr/local/zookeeper
mkdir  /usr/local/zookeeper/{data,log}
echo 2 >/usr/local/zookeeper/data/myid
echo "export PATH=/usr/local/zookeeper/bin:$PATH" >>/etc/profile ; source /etc/profile
###############################################################################
#node3配置：192.168.92.136
[ -d /tools ] || mkdir /tools 
cd /tools
wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.3.6/zookeeper-3.3.6.tar.gz
tar xf zookeeper-3.3.6.tar.gz -C /usr/local/
ln -sv /usr/local/zookeeper-3.3.6/ /usr/local/zookeeper
mkdir  /usr/local/zookeeper/{data,log}
echo 3 >/usr/local/zookeeper/data/myid
echo "export PATH=/usr/local/zookeeper/bin:$PATH" >>/etc/profile ; source /etc/profile

2）修改配置文件：三台节点的配置相同

cd /usr/local/zookeeper/conf
cp zoo_sample.cfg zoo.cfg

#vim zoo.cfg
clientPort=2181
server.1=192.168.92.134:2888:3888 
server.2=192.168.92.135:2888:3888 
server.3=192.168.92.136:2888:3888 
dataDir=/usr/local/zookeeper/data
dataLogDir=/usr/local/zookeeper/log

3）三台节点启动zookeeper

zkServer.sh start
ss -anltup | grep 2181

# zkServer.sh status
JMX enabled by default
Using config: /usr/local/zookeeper-3.3.6/bin/../conf/zoo.cfg
Mode: follower
zkServer.sh status
JMX enabled by default
Using config: /usr/local/zookeeper-3.3.6/bin/../conf/zoo.cfg
Mode: leader

（4）安装和配置activemq

1）安装activemq

cd /tools
wget https://mirrors.tuna.tsinghua.edu.cn/apache//activemq/5.15.3/apache-activemq-5.15.3-bin.tar.gz
tar xf apache-activemq-5.15.3-bin.tar.gz -C  /usr/local/
ln -sv /usr/local/apache-activemq-5.15.3/ /usr/local/activemq
echo  "export PATH=$PATH:/usr/local/activemq/bin"  >>/etc/profile;source /etc/profile

2）修改配置文件

cp /usr/local/activemq/conf/activemq.xml{,.bak}

修改配置文件内容如下

#vim /usr/local/activemq/conf/activemq.xml
注释一下内容：
		<!--
        <persistenceAdapter>
            <kahaDB directory="${activemq.data}/kahadb"/>
        </persistenceAdapter>
		-->
修改内容如下：三台主机的hostname各种修改成自己的ip地址即可
<persistenceAdapter>
<replicatedLevelDB 
directory="${activemq.data}/leveldb"
replicas="3"
bind="tcp://0.0.0.0:0"
zkAddress="192.168.92.134:2181,192.168.92.135:2181,192.168.92.136:2181"
zkPassword="redhat"
hostname="192.168.92.134"
sync="local_disk"
zkPath="/activemq/leveldb-stores" />
</persistenceAdapter>
修改brokerName：三台服务器必须要一样
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="mq" dataDirectory="${activemq.data}">

启动activemq

activemq start