博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
玩转ActiveMQ与Zookeeper集群
阅读量:6271 次
发布时间:2019-06-22

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

hot3.png

MQ: Message Queue消息队列

ActiveMQ:Apache出品,最流行的,能力强劲的开源消息总线。

用途和优点

1.将数据从一个应用程序传送到另一个应用程序,或者从软件的一个模块传送到另外一个模块;

2.负责建立网络通信的通道,进行数据的可靠传送;

3.保证数据不重复,不丢失;

4.能够实现跨平台操作;

ActiveMQ应用场景

1,多个项目之间集成;

2,降低系统间模块的耦合度、解耦;

3,系统前后端隔离;

安装与配置

1.下载地址 http://activemq.apache.org/download.html

2.解压安装

tar -zxvf apache-activemq-5.15.3-bin.tar.gz -c /usr/local

3.重命名

mv apache-activemq-5.15.3 activemq

4.修改配置文件vim activemq/conf/activemq.xml

机器1.2.3修改集群名 三台机器必须一样

brokerName="activemq-cluster"

修改vim activemq/conf/activemq.xml持久化方式

   

修改vim activemq/conf/activemq.xml的消息端口 51516

 

修改vim activemq/conf/jetty.xml管控台端口 (192.168.16.128:8161)

       
       
   

根据以上步骤修改每台机器上的配置

 

机器IP 管控台端口 集群通讯端口 消息端口
192.168.16.128 8261 61621 51516
192.168.16.129 8262 61622 51517
192.168.16.130 8263 61623 51518

启动Zookeeper集群安装请查看文章

1.首先启动zookeeper集群 /zkServer.sh start

2.查看/zkServer.sh status 状态

3.启动activemq  ./activemq    start / stop /status/console(启动并查看日志)

4.查看zookeeper信息 ./zkCli.sh

查看是否有activemq信息 ls /

[activemq, zookeeper]

查看activemq集群是否持久化到zookeeper  ls /activemq/leveldb-stores

[00000000086, 00000000084, 00000000085]

界面访问

分别访问

http://192.168.16.130:8163/

http://192.168.16.129:8162/

http://192.168.16.128:8161/

有两个链接不能访问是属于正常,两个链接属于待机状态并没有真正实现MQ,当Master宕机,从两台Slave中选举一个为Master。

640?wx_fmt=png

640?wx_fmt=png

640?wx_fmt=png

 

到此安装就此结束了。

版本分别为JDK8、Zookeeper3.4.10、ActiveMQ5.15.3、Centos6.5;机器是虚拟机;

安装异常问题

Q:遇到未知的服务和名称

A:修改hosts文件 192.168.16.128  jin(hostname)

hostname

 

Q:集群搭建成功,当Master宕机,Slave没有选举为Master

A:三台集群端口一致为tcp://0.0.0.0.0,还有默认端口和消息端口使用默认。修改为不同端口,重启解决。

Q:MQ消息队列启动失败

A:JDK版本与MQ版本是否对应

Q:防火墙需关闭

启动Zookeeper与ActiveMQ之前是需要安装JDK

▼长按以下二维码即可关注▼

 

640?wx_fmt=jpeg

转载于:https://my.oschina.net/u/3758413/blog/1801830

你可能感兴趣的文章
百世汇通快递地区选择插件,单独剥离
查看>>
Linux系统调用---同步IO: sync、fsync与fdatasync【转】
查看>>
【MyBatis学习06】输入映射和输出映射
查看>>
[LeetCode] Decode String 解码字符串
查看>>
数字逻辑的一些基本运算和概念
查看>>
ant重新编译打包hadoop-core-1.2.1.jar时遇到的错
查看>>
【★★★★★】提高PHP代码质量的36个技巧
查看>>
3 weekend110的配置hadoop(格式化) + 一些问题解决 + 未免密码配置
查看>>
JavaScript Creating 对象
查看>>
Java compiler level does not match the version of the installed Java project facet.(转)
查看>>
WPF MediaElement.Position属性
查看>>
sqoop数据迁移(基于Hadoop和关系数据库服务器之间传送数据)
查看>>
spring mysql多数据源配置
查看>>
[React] Override webpack config for create-react-app without ejection
查看>>
检索 COM 类工厂中 CLSID 为{00024500-0000-0000-C000-000000000046} 的组件时失败,原因是出现以下错误: 80070005。...
查看>>
测试java的父子类化
查看>>
HDOJ 1008
查看>>
安装thrift出现的一些问题
查看>>
makefile编写---单个子目录编译模板
查看>>
Oracle DB_LINK如何使用
查看>>