ActiveMQ从入门到精通(三)

简介:

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


利用Zookeeper实现ActiveMQ的高可用

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

wKioL1jXr5Li62TyAAE_KWap_pg504.png

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

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

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


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

wKioL1jXr9GyjWd1AABcYGDubWE287.png


第一步:JDK环境

wKiom1jXr_TiqOqrAAAaOf8DsBs655.png


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

第二步:配置Zookeeper

wKioL1jXsDDjKt1oAAAWOUY_BZw130.png


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

wKiom1jXsFnTX9scAAB1pNZQYLQ310.png


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

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


wKioL1jXsIXQ5LRnAAAHLU0W4og456.png


第三步:启动ZK

wKiom1jXsLDxCFbpAABUCOMc1Yk291.png


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

wKioL1jXsNXTU0p4AAAusjZWeKI223.png


第四步:ActiveMQ主从配置

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

wKiom1jXsQGAljYxAAAYPx3pa68680.png

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

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

wKioL1jXsXSRDpjyAAAvao12GQ4122.png

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

hostname即本机的主机名称。

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


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

wKioL1jXsYuBzIvbAACFvTTa2o0409.png

此时此刻,基于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高可用之间产生关联:

wKiom1jXsciDGUC-AABHFyt66Nw706.png

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

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


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


本文转自zfz_linux_boy 51CTO博客,原文链接:http://blog.51cto.com/zhangfengzhe/1910511,如需转载请自行联系原作者

相关文章
|
存储 机器学习/深度学习 消息中间件
数据处理能力相差 2.4 倍?Flink 使用 RocksDB 和 Gemini 的性能对比实验
在本篇文章中我们将对 RocksDB、Heap 和 Gemini 在相同场景下进行压测,并对其资源消耗进行对比。测试的 Flink 内核版本为 1.10.0。
数据处理能力相差 2.4 倍?Flink 使用 RocksDB 和 Gemini 的性能对比实验
|
机器学习/深度学习 虚拟化
|
JavaScript
VUE学习二:事件监听(v-on)、条件判断(v-if/v-else-if/v-else)、循环遍历(v-for)
这篇文章是关于Vue.js的学习指南,涵盖了事件监听、条件判断、循环遍历、数组方法响应性、案例分析以及高阶函数的使用。
191 2
VUE学习二:事件监听(v-on)、条件判断(v-if/v-else-if/v-else)、循环遍历(v-for)
|
开发框架 .NET API
在 ASP.NET Core Web API 中使用异常筛选器捕获和统一处理异常
在 ASP.NET Core Web API 中使用异常筛选器捕获和统一处理异常
187 0
|
11月前
|
Go 数据处理 API
Go语言在微服务架构中的应用与优势
本文摘要采用问答形式,以期提供更直接的信息获取方式。 Q1: 为什么选择Go语言进行微服务开发? A1: Go语言的并发模型、简洁的语法和高效的编译速度使其成为微服务架构的理想选择。 Q2: Go语言在微服务架构中有哪些优势? A2: 主要优势包括高性能、高并发处理能力、简洁的代码和强大的标准库。 Q3: 文章将如何展示Go语言在微服务中的应用? A3: 通过对比其他语言和展示Go语言在实际项目中的应用案例,来说明其在微服务架构中的优势。
|
消息中间件 Java Kafka
SpringBoot实用开发篇第六章(整合第三方技术,ActiveMQ,RabbitMQ,RocketMQ,Kafka)
SpringBoot实用开发篇第六章(整合第三方技术,ActiveMQ,RabbitMQ,RocketMQ,Kafka)
|
算法
【图像】图像增强-降噪锐化
【图像】图像增强-降噪锐化
148 1
2023年电赛---运动目标控制与自动追踪系统(E题)OpenART mini的代码移植到OpenMV
2023年电赛---运动目标控制与自动追踪系统(E题)OpenART mini的代码移植到OpenMV
402 0
|
存储 Java 关系型数据库
分布式定时任务框架Quartz总结和实践(2)—持久化到Mysql数据库
本文主要介绍分布式定时任务框架Quartz集成SpringBoot持久化数据到Mysql数据库的操作,上一篇文章使用Quartz创建定时任务都是保存在内存中,如果服务重启定时任务就会失效,所以Quartz官方也提供将定时任务等信息持久化到Mysql数据库的功能,本文主要实现这种Quartz的这种使用方式。
1859 0
分布式定时任务框架Quartz总结和实践(2)—持久化到Mysql数据库
|
弹性计算
阿里云服务器采用AMD CPU处理器ECS实例规格大全
阿里云有AMD服务器吗?有的,阿里云百科分享阿里云服务器ECS实例采用AMD处理器的规格大全
719 0
阿里云服务器采用AMD CPU处理器ECS实例规格大全