ActiveMQ从入门到精通(三)

本人花费半年的时间总结的《Java面试指南》已拿腾讯等大厂offer,已开源在github ,欢迎star!

本文GitHub https://github.com/OUYANGSIHAI/JavaInterview 已收录,这是我花了6个月总结的一线大厂Java面试总结,本人已拿大厂offer,欢迎star

原文链接:blog.ouyangsihai.cn >> ActiveMQ从入门到精通(三)

点击上方“Java知音”,选择“置顶公众号”

技术文章第一时间送达!

作者:张丰哲 www.jianshu.com/p/79f8a0457069

www.jianshu.com/p/79f8a0457069

阅****读

1. 

****2. ****

3. 

****4. ****

这是ActiveMQ系列的最后一篇文章,主要是关于ActiveMQ集群,这里采用的方式是:Zookeeper+LevelDB+ActiveMQ。

前面2篇博客地址如下:

  • 利用Zookeeper实现ActiveMQ的高可用话不多说,先来看一张ActiveMQ官方提供的架构图:

    ActiveMQ从入门到精通(三)

    Zookeeper + ActiveMQ

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

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

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

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

    ActiveMQ从入门到精通(三)

    搭建方案

    第一步:JDK环境

    ActiveMQ从入门到精通(三)

    jdk环境

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

    第二步:配置Zookeeper

    ActiveMQ从入门到精通(三)

    zk环境变量

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

    ActiveMQ从入门到精通(三)

    zoo.cfg

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

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

    ActiveMQ从入门到精通(三)

    myid文件

    第三步:启动ZK

    ActiveMQ从入门到精通(三)

    zkServer start

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

    ActiveMQ从入门到精通(三)

    zk status

    第四步:ActiveMQ主从配置

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

    ActiveMQ从入门到精通(三)

    activemq.xml:brokerName

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

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

    ActiveMQ从入门到精通(三)

    leveldb

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

    hostname即本机的主机名称。

    给出ZK集群的列表以及zkPath。zkPath下面其实存放着ActiveMQ的节点,在后续你会看到。
    启动3台机器上的ActiveMQ,然后利用ZooInspector你可以看到:

    ActiveMQ从入门到精通(三)

    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集群

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

    看完本文有收获?请转发分享给更多人

    ActiveMQ从入门到精通(三)

    原文始发于微信公众号(Java知音):

    本人花费半年的时间总结的《Java面试指南》已拿腾讯等大厂offer,已开源在github ,欢迎star!

    本文GitHub https://github.com/OUYANGSIHAI/JavaInterview 已收录,这是我花了6个月总结的一线大厂Java面试总结,本人已拿大厂offer,欢迎star

    原文链接:blog.ouyangsihai.cn >> ActiveMQ从入门到精通(三)


     上一篇
    一文读懂 Redis 基础、高级特性与性能调优 一文读懂 Redis 基础、高级特性与性能调优
    原文:****https://www.jianshu.com/p/2f14bc570563 本文将从Redis的基本特性入手,通过讲述Redis的数据结构和主要命令对Redis的基本能力进行直观介绍。之后概览Redis提供的高级能力,并
    2021-04-05
    下一篇 
    RocketMQ实战(一) RocketMQ实战(一)
    点击上方“Java知音”,选择“置顶公众号” 技术文章第一时间送达! 作者:张丰哲 www.jianshu.com/p/3afd610a8f7d www.jianshu.com/p/3afd610a8f7d 推荐阅****读
    2021-04-05