zookeeper与activemq最新存储replicatedLevelDB整合

zookeeper与activemq最新存储replicatedLevelDB整合

 

• 标签：
• jms /
• activemq /
• zookeeper

• 3244

测试环境：三台VM虚拟机centos6.4 64位 mini版，IP分别为192.168.1.191/192/193.

测试目的：测试activemq的failover以及与zookeeper的整合

测试缘由：activemq有多种持久化模式，可是均可能存在单点故障的状况。与zookeeper整合后基本能够保证(n-1)/2的稳定性。其中n表示服务器数量。

测试备注：该模式下仍是单节点负载，只是因为引入了zookeeper的监测机制。保证多个activemq服务在同一时间内只有一个服务对外开放。

性能分析：在环境搭载完成后测试了下性能负载，在单台无zookeeper模式下用kahadb负载能打到12000条/秒，可是在引入zookeeper后只能有1500条/秒左右，

可是因为本次测试不是性能调优，只是为了保证jms服务的可用性，所以没有进行性能优化调整。

 

 

 

 

一、下载zookeeper

cd /opt && wget http://mirror.bit.edu.cn/apache/zookeeper/stable/zookeeper-3.4.5.tar.gz

二、下载activemq

cd /opt && wget 

http://www.apache.org/dyn/closer.cgi?path=/activemq/apache-activemq/5.9.0/apache-activemq-5.9.0-bin.tar.gz

 

解压这两个文件，都放在opt目录下。

如下配置是分别在192.168.1.191 192.168.1.192 192.168.1.193三台服务器上进行配置。

这种配置方案可以实现(n-1)/2的容错率，也就是三台服务器容许挂一台，五个能当掉2个，依次类推。

 

三、更改zookeeper配置

cd /opt/zookeeper-3.4.5/conf

cp zoo_sample.cfg zoo.cfg

vi zoo.cfg

而后配置为三个节点

server.1=192.168.1.191:2888:3888

server.2=192.168.1.192:2888:3888

server.3=192.168.1.193:2888:3888

 

而后须要cd /tmp/zookeeper

新建一个名字叫作myid的文件，里面写上当前服务的优先级？基本上是数字 注意这里的数字要和zoo.cfg文件中的server.*吻合，好比个人配置是191这台机器是叫作1  192这台机器是叫作2   

vi myid

四、更改activemq的配置

vi /opt/apache-activemq-5.9.0/conf/activemq.xml

找到

<persistenceAdapter>

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

        </persistenceAdapter>

这种字样的配置项目，默认状况下activemq是走kahadb存储的，这里替换为：

<persistenceAdapter>

    <replicatedLevelDB

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

      replicas="3"

      bind="tcp://0.0.0.0:0"

      zkAddress="192.168.1.191:2181,192.168.1.192:2181,192.168.1.193:2181"

      zkPassword="password"

hostname="192.168.1.191"

      sync="local_disk"

      zkPath="/activemq/leveldb-stores"

      />

  </persistenceAdapter>

 

这里不一样机器上的hostname要设置为不一样。

 

五、剩下的就是开始服务了。

首先开始三台服务器上的zookeeper服务：

/opt/zookeeper-3.4.5/bin/zkServer.sh start

而后分别开启三台服务器上的activemq服务：

/opt/apache-activemq-5.9.0/bin/activemq start

 

好了，基本没什么问题了。

而后就开始http://192.168.1.191:8161 或者http://192.168.1.192:8161

或者http://192.168.1.193:8161

这三个连接看哪一个能访问，哪一个消息服务器则表示存活提供服务。

六、测试

关掉19一、19二、193其中任何一台，通过测试可以正常提供服务，客户端会自动切换链接，达到预期目的。

 

六、客户端链接使用failover方案：

failover:(tcp://192.168.1.191:61616,tcp://192.168.1.192:61616,tcp://192.168.1.193:61616)?initialReconnectDelay=1000