博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Zookeeper+ActiveMQ 集群实现
阅读量:7232 次
发布时间:2019-06-29

本文共 2070 字,大约阅读时间需要 6 分钟。

hot3.png

基础环境:

系统环境:centos6.7

软件包:zookeeper-3.4.10.tar.gz

主机ip 消息端口 通信端口
192.168.33.17 2181 2888:3888
192.168.33.18 2181 2888:3888
192.168.33.19 2181 2888:3888
主机ip 集群间的通信端口 消息端口 控制台端口
192.168.33.17

62621

61616

8161
192.168.33.18

62621

61616

8161
192.168.33.19

62621

61616

8161

zookeeper集群安装配置(需要在所有集群节点配置):

0.ZooKeeper依赖于Java,请先安装好java,并配置好环境变量。

1.配置ZooKeeper环境变量

# vim /etc/profileexport ZOOKEEPER=/usr/local/zookeeper-3.4.10export PATH=$ZOOKEEPER/bin:$PATH

2.修改配置文件名

mv zoo_sample.cfg zoo.cfg

3. 修改配置文件

vim zoo.cfg

主要修改两个地方,如下:

(1)data文件目录默认不存在需要手动创建

dataDir=/usr/local/zookeeper-3.4.10/data

 

(2)配置文件最后增加集群服务器ip及端口信息

server.1=192.168.33.17:2888:3888server.2=192.168.33.18:2888:3888server.3=192.168.33.19:2888:3888

4.在Zookeeper主目录下创建data目录

mkdir datacd data/

在data文件夹下建立myid(三个节点,0,1,2)

#vim myid0

5.启动zookeeper

cd /usr/local/zookeeper-3.4.10/bin./zkServer.sh start

6.查看ZooKeeper进程

[root@localhost bin]# jps2406 QuorumPeerMain2487 Jps

7.查看节点状态(可以看到该节点角色为master)

# ./zkServer.sh statusZooKeeper JMX enabled by defaultUsing config: /usr/local/zookeeper-3.4.10/bin/../conf/zoo.cfgMode: leader

 

ActiveMQ集群配置:

1.vim usr/local/activemq5.15/conf/activemq.xml

(1)修改brokerName,三台机器的brokerName相同,都为"activemq-cluster"

(2)修改数据库为replicatedLevelDB

注:hostname 填写本机的ip

2.三台mq机器分别启动mq服务

/usr/local/activemq5.15/bin/activemq start

3.集群测试

访问http://192.168.33.17:8161/

http://192.168.33.18:8161/

http://192.168.33.19:8161/

可以发现只有一台机器能够访问到,则集群配置成功

4.zookeeper client端,查看zookeeper集群信息

 zkCli.sh

[zk: localhost:2181(CONNECTED) 4]  ls /activemq/leveldb-stores[00000000002, 00000000003, 00000000001]

可以看到有三个节点信息

5.通过idea,安装zookeeper插件,也可以查询到ActiveMq集群信息

120413_lmA5_1393804.png

01

{"id":"activemq-cluster","container":null,"address":"tcp://192.168.33.18:62621","position":-1,"weight":1,"elected":"0000000001"}

02

{"id":"activemq-cluster","container":null,"address":null,"position":-1,"weight":1,"elected":null}

03

{"id":"activemq-cluster","container":null,"address":null,"position":-1,"weight":1,"elected":null}

可以看到,192.68.33.18为目前active的机器。

 

转载于:https://my.oschina.net/CentralD/blog/1556386

你可能感兴趣的文章
利用Ajax无刷新更新rss阅读
查看>>
Arch Linux 安装 ibus 五笔输入法备忘录
查看>>
第38周星期二
查看>>
hdu1166(单点更新,区间求和)
查看>>
Synergy 一个bug的解决办法
查看>>
HTML5socket通信——postMessage出现的不能提交的问题
查看>>
常用的CSS[持续更新]
查看>>
ssh框架下junit测试
查看>>
设置输入域(input/textarea)中文本光标的位置
查看>>
nginx自定义模块编写-根据post参数路由到不同服务器
查看>>
使用信号量来 限制无边界池子与队列
查看>>
<modules runAllManagedModulesForAllRequests="true" />(转1)
查看>>
【NLP】蓦然回首:谈谈学习模型的评估系列文章(二)
查看>>
iOS开发之功能模块--长方形UIImage截取中间最大正方形区域
查看>>
04.SQLServer性能优化之---读写分离&数据同步
查看>>
Form 表单中的Input元素回车时不保存表单
查看>>
大神php摘录
查看>>
MySQL常用查询
查看>>
drop user 报错ora-00604
查看>>
微信JSSDK支付接口-安卓机无法正常调起接口
查看>>