ActiveMQ从入门到精通(三)

这是ActiveMQ系列的最后一篇文章,主要是关于ActiveMQ集群,这里采用的方式是:Zookeeper+LevelDB+ActiveMQ。前面2篇博客地址如下:《ActiveMQ从入门到精通(一)》《ActiveMQ从入门到精通(二)》

利用Zookeeper实现ActiveMQ的高可用

话不多说,先来看一张ActiveMQ官方提供的架构图:

Zookeeper + ActiveMQ

Master/Slave broker的信息要注册到ZK

注意到只有Master对外提供了服务,Slave是待机状态。当Master出现故障,ZK内部的选举机制,会让一个Slave升级成Master对外提供服务。

关于ZK,以后博主会有专题进行介绍,这里不做详细讲解,只需要了解通过ZK的协调、选举、容错机制等会实现ActiveMQ的高可用。

既然要做到高可用,那么ZK也得是高可用的,所以这里的搭建方案是这样的:

搭建方案

第一步:JDK环境

jdk环境

保证这3台机器都安装了JDK,并配置了JAVA环境变量。

第二步:配置Zookeeper

zk环境变量

为什么要配置ZK环境变量呢?很简单,我想在命令行下直接使用ZK相关的命令,而不是进入到安装ZK目录下的bin,更不想用绝对路径。


zoo.cfg

注意dataDir目录的指定;注意2181是外部访问ZK的端口;

2888:3888是ZK集群内部通信(比如ZK原子广播消息)的端口,注意server.X的定义,这是将ZK集群中的实例进行编号,实际上需要在dataDir目录中新建myid文件,并与之保持一致。

myid文件

第三步:启动ZK

zkServer start

可以通过netstat命令查看2722进程,发现ZK的端口是2181,这和zoo.cfg的配置是一致的。让3台机器的ZK都启动起来。


zk status


第四步:ActiveMQ主从配置

注意了,由于我将在3台物理机上搭建一台Master,2台Slave,因此我这边不需要对端口配置文件进行改动。比如WEB管控台的jetty.xml。


activemq.xml:brokerName

3台机器应该对外只有一个统一的名称,就是这个brokerName。3台机器都修改成一个名称即可。

这里持久化,我将采用LevelDB,因此需要修改持久化配置:

leveldb

注意bind地址,其实是ActiveMQ集群内部通信的TCP端口,和ActiveMQ对外提供的消息端口(默认61616)不要搞混了。

hostname即本机的主机名称。

给出ZK集群的列表以及zkPath。zkPath下面其实存放着ActiveMQ的节点,在后续你会看到。

启动3台机器上的ActiveMQ,然后利用ZooInspector你可以看到:

121节点是Master

此时此刻,基于ZK的ActiveMQ的高可用方案就做好了。那么JAVA端访问ActiveMQ有什么变化么?其实就是在创建ConnectionFactory的时候给定的URL有变化:

failover:(tcp://192.168.99.121:61616,tcp://192.168.99.122:61616,tcp://192.168.99.123:61616)?Randomize=false

就是一个失败转移协议!

上面只是做了一个ActiveMQ的高可用方案,那么ActiveMQ集群呢?其实所谓的ActiveMQ集群就是多个ActiveMQ高可用之间产生关联:

ActiveMQ集群

高可用的ActiveMQ-1,ActiveMQ-2,...,ActiveMQ-N就可以组建ActiveMQ集群

在配置上很简单,其实就是ActiveMQ-1要知道ActiveMQ-2的信息而已,这里大家可以自行百度,不在演示了。

整个ActiveMQ从入门到精通系列就结束了,希望对大家有帮助!我们RocketMQ系列再见~

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 一、ActiveMQ集群的简单介绍 从 ActiveMQ 5.9 开始,ActiveMQ 的集群实现方式取消了传统...
    会跳舞的机器人阅读 9,014评论 0 18
  • 1 Zookeeper概述# ZooKeeper是一个为分布式应用所设计的分布的、开源的协调服务,它主要是用来解决...
    七寸知架构阅读 12,086评论 0 101
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,833评论 19 139
  • ZooKeeper介绍 Zookeeper 分布式服务框架是 Apache Hadoop 的一个子项目,它主要是用...
    Coselding阅读 13,920评论 1 37
  • 人生是海洋,希望是舵手的罗盘,使人们在暴风雨中不致迷失方向。 —— 狄德罗 1. 前言   ActiveMQ M...
    guqj阅读 9,190评论 0 0

友情链接更多精彩内容