基于zookeeper+leveldb搭建activemq集群
2015-06-01 11:50
986 查看
自从activemq5.9.0开始,activemq的集群实现方式取消了传统的Master-Slave方式,增加了基于zookeeper+leveldb的实现方式,其他两种方式:目录共享和数据库共享依然存在。本文主要阐述基于zookeeper和leveldb搭建activemq集群,这里需要特别提醒,本文实现的集群仅提供主备功能,避免单点故障,没有负载均衡功能。
下面开始我们的征途。
一、搭建zookeeper集群
关于搭建zookeeper集群的文章请参考:zookeeper的集群模式下的安装和配置。
本文使用zookeeper3.4.6,3台虚拟机:192.168.2.161, 192.168.2.145, 192.168.2.146,zookeeper使用其默认端口:2181。
zookeeper集群搭建完成之后,我顺便搭建了两套监控系统:taokeeper-monitor和node-zookeeper-browser。前者是淘宝开源的一套监控zookeeper的系统,用了之后感觉得到的有效信息不多,而且集群趋势图总是不显示;后者是用nodejs实现的zookeeper节点数据查看系统,虽然页面不太美观,但是实用。
图 1. taokeeper-monitor界面
图 2. node-zookeeper-browser界面
二、搭建activemq集群
1、安装
activemq本身的安装过程很简单,本文不详述,可参照官方的Getting-started。
2、配置
在三台机器上完成activemq安装之后,开始集群配置,通过配置使三个activemq实例组成集群。下面的配置在三个实例上保持一致,除了标红部分,主要修改配置文件conf/activemq.xml。
(1)broker-name的统一
将broker标签的brokerName属性设置为统一的值,我将这个值设置为“test”,只有三个实例的brokerName一致,zookeeper才能识别它们属于同一个集群。
(2)persistenceAdapter的配置
persistenceAdapter设置持久化方式,主要有三种方式:kahaDB(默认方式)、数据库持久化、levelDB(v5.9.0提供支持)。
本文采用levelDB来进行持久化,并使用zookeeper实现集群的高可用,配置如下:
首先注释掉原来kahaDB的持久化方式,然后配置levelDB+zookeeper的持久化方式。
?
注意上述配置中的hostname属性值,不同的activemq实例对应不同的hostname值,其他两个实例配置的hostname值分别为:192.168.2.145,
192.168.2.146。
3、问题与解决方案
配置完成之后启动zookeeper集群,然后依次启动三个activemq实例,启动之后报错:"activemq
LevelDB IOException handler"。
原因:版本5.10.0存在的依赖冲突。
解决方案:
(1)移除lib目录中的pax-url-aether-1.5.2.jar包;
(2)注释掉配置文件中的日志配置;
?
参考:http://www.350351.com/jiagoucunchu/leveldb/334233.html
4、测试
任意停掉三个实例中的任意一个,activemq服务依然正常运转。
转至:http://my.oschina.net/xiaohui249/blog/313028
下面开始我们的征途。
一、搭建zookeeper集群
关于搭建zookeeper集群的文章请参考:zookeeper的集群模式下的安装和配置。
本文使用zookeeper3.4.6,3台虚拟机:192.168.2.161, 192.168.2.145, 192.168.2.146,zookeeper使用其默认端口:2181。
zookeeper集群搭建完成之后,我顺便搭建了两套监控系统:taokeeper-monitor和node-zookeeper-browser。前者是淘宝开源的一套监控zookeeper的系统,用了之后感觉得到的有效信息不多,而且集群趋势图总是不显示;后者是用nodejs实现的zookeeper节点数据查看系统,虽然页面不太美观,但是实用。
图 1. taokeeper-monitor界面
图 2. node-zookeeper-browser界面
二、搭建activemq集群
1、安装
activemq本身的安装过程很简单,本文不详述,可参照官方的Getting-started。
2、配置
在三台机器上完成activemq安装之后,开始集群配置,通过配置使三个activemq实例组成集群。下面的配置在三个实例上保持一致,除了标红部分,主要修改配置文件conf/activemq.xml。
(1)broker-name的统一
将broker标签的brokerName属性设置为统一的值,我将这个值设置为“test”,只有三个实例的brokerName一致,zookeeper才能识别它们属于同一个集群。
(2)persistenceAdapter的配置
persistenceAdapter设置持久化方式,主要有三种方式:kahaDB(默认方式)、数据库持久化、levelDB(v5.9.0提供支持)。
本文采用levelDB来进行持久化,并使用zookeeper实现集群的高可用,配置如下:
首先注释掉原来kahaDB的持久化方式,然后配置levelDB+zookeeper的持久化方式。
?
192.168.2.146。
3、问题与解决方案
配置完成之后启动zookeeper集群,然后依次启动三个activemq实例,启动之后报错:"activemq
LevelDB IOException handler"。
原因:版本5.10.0存在的依赖冲突。
解决方案:
(1)移除lib目录中的pax-url-aether-1.5.2.jar包;
(2)注释掉配置文件中的日志配置;
?
4、测试
任意停掉三个实例中的任意一个,activemq服务依然正常运转。
转至:http://my.oschina.net/xiaohui249/blog/313028
相关文章推荐
- 解析ActiveMQ的使用说明总结
- ActiveMQ发消息、收消息、持久化,查询队列剩余消息数、出队数的实现
- activemq报EOFExceptionjvm错误
- 基于zookeeper+leveldb搭建activemq集群
- ActiveMQ 实例
- Ubuntu 14.04.1 安装 activemq 5.11.1
- 在Spring中使用ActiveMQ发送邮件
- 多个地市连接MQ,如果较长时间没有消息发送,ActiveMQ的消费端会自动断开连接(topic端)
- JMS和消息驱动Bean(MDB)
- JMS_使用ActiveMQ实现消息的发送和接收
- ActiveMQ 消息游标
- ActiveMQ 生产者流量控制
- ActiveMQ 全排序(Total Ordering)
- ActiveMQ 使用笔记
- ActiveMq 不能正确获取有过期时间的消息的原因
- Spring JMS笔记
- Spring和Apache CXF,ActiveMQ整合记录
- 解决apache activemq 前端推送延迟问题
- ActiveMQ
- ActiveMQ 启动Broker