ActiveMQ集群模式

叁歲伎倆 2023-10-11 20:18 37阅读 0赞

**目录**

一、面试题

二、多节点集群是什么

三、zookeeper+replicated-leveldb-store的主从集群

四、官网集群原理图

五、部署规划和步骤

六、集群可用性测试

--------------------

## 一、面试题 ##

引入消息队列之后该如何保证其高可用性

## 二、多节点集群是什么 ##

基于ZooKeeper和LevelDB搭建ActiveMQ 集群集群仅提供主备方式的高可用集群功能，避免单点故障

## 三、zookeeper+replicated-leveldb-store的主从集群 ##

官网：[ActiveMQ (apache.org)][ActiveMQ _apache.org]

![935265c008b44e46b98a1d4003e555aa.png][]

两种集群方式

1.  基于sharedFileSystem共享文件系统(KahaDB默认)
2.  基于JDBC

## 四、官网集群原理图 ##

![7672882706494283920e0a285584a381.png][]

![0dd0306f68f7468fb5932e95f1ed09a0.png][]

## 五、部署规划和步骤 ##

**（一）环境和版本**

CentOS 7 x86\_64

JDK1.8

zookeeper-3.5.7

activemq-5.16.5

**（二）关闭防火墙并保证win可以ping通过ActimveMq服务器**

**（三）要求具备ZK集群并可以成功启动**

**（四）集群部署规划列表**

![956df33ffa8d4a1abd5d1a73ec52d249.png][]

**（五）创建3台集群目录**

![637a05e8f68644c7aa4f284df3c1c650.png][]

**（六）修改管理控制台端口**

1.mq\_node01全部不动

2.mq\_node02进入conf目录下得jetty.xml文件进行修改。port改为8162

![f2a9a9fa3a1447dd8d9dd9f6a51f1708.png][]

![63bd5d84e2f240318a28247428a520a7.png][]

3.mq\_node03进入conf目录下得jetty.xml文件进行修改。port改为8163

![a0a9a6ec7be840339af8d9dc56594748.png][]

![1949f0bf5ed747129826f6bc0734e5a9.png][]

**这里修改port的同时可以将上面的host那一行注释掉，不然只允许本机访问，Windows打不开前台**

**将下面这一行注释掉或者将value改为主机ip**

> <property name="host" value="127.0.0.1"/>

**（七）AcitveMQ集群配置**

**1.三个节点的brokername要全部一致**

进入activemq.xml文件进行修改

![fbec0fce9615481a8a8e85a658e64a48.png][]

brokername改为mqcluster

![8c27b6bef06a4c52b49414add4a60bd7.png][]

**2.3个节点的持久化配置**

**node1，2，3分别对应**

bind：63631，63632，63633

zkAddress对应三台zookeeper集群所在的服务ip和zookeeper端口号（我这里zookeeper集群分布在三台虚拟机上）

![8cae2bab74d246eda2af885574ca65d4.png][]

**（八）修改各节点的消息端口**

**node1，2，3分别对应**

openwire的url对应61616，61617，61618

![292b0b4826684d599ac5b8f844316bd2.png][]  
**（九）按顺序启动3个ActiveMQ节点到这步前提是zk集群已经成功启动运行**

首先通过之前编写的zookeeper脚本启动位于3台虚拟机的zookeeper集群

![39e05a2aa1a6410fb33fdb6a14c38ba4.png][]

编写一个启动和关闭脚本

![8f90333d92d344bfb50d79800f97a369.png][]

amq\_batch.sh

#!/bin/sh
    
    cd /mq_cluster/mq_node01/bin
    ./activemq start
    
    cd /mq_cluster/mq_node02/bin
    ./activemq start
    
    cd /mq_cluster/mq_node03/bin
    ./activemq start

amq\_batch\_stop.sh

#!/bin/sh
    
    cd /mq_cluster/mq_node01/bin
    ./activemq stop
    
    cd /mq_cluster/mq_node02/bin
    ./activemq stop
    
    cd /mq_cluster/mq_node03/bin
    ./activemq stop

记得用chmod 777 文件名修改文件权限，使文件可执行

![363f206fc8614017aea983c7cda1d5c9.png][]

**（十）zk集群的节点状态说明**

登录另一台虚拟机的zookeeper客户端，查看/节点下是否有activemq节点

./zkCli.sh -server 127.0.0.1:2181
    
    ls /

![a5e3bcf6ba7240939f0a3186bc2f8987.png][]

可以看到三个结点都配置成功了![099a363f329142fbb5ec40217dcf06a7.png][]

**再查看节点的具体信息**

可以看到63633也就是我们的node03activemq有elected，即被选中作为master，其他两台为slave

![3f4b30cdd119496bbc86fd09dc6fc1e8.png][]

windows下访问8363，成功

![d1895f81ad2b44fb8a92adb42c41c42f.png][]

## 六、集群可用性测试 ##

**测试队列发送与接收**

**生产者**

public class JMSProduce {
    
        public static final String ACTIVEMQ_URL = "failover:(tcp://ip:61616,tcp://ip:61617,tcp://ip:61618)?randomize=false";
        public static final String QUEUE_NAME = "queue-cluster";
    
        public static void main(String[] args) throws JMSException {
            //1.创建链接工厂,按照给定的url地址，采用默认的用户和密码
            ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);
            //2.通过链接工厂，获得Connection并启动
            Connection connection = activeMQConnectionFactory.createConnection();
            connection.start();
            //3.创建会话session
            //3.1 两个参数 ①事务 ②签收
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //4.创建目的地（queue or topic）
            Queue queue = session.createQueue(QUEUE_NAME);
            //5.创建生产者
            MessageProducer producer = session.createProducer(queue);
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);
            //6.通过MessageProducer生成3条消息到MQ队列中
            for(int i = 1 ; i <= 3; i ++ ) {
                TextMessage textMessage = session.createTextMessage("clusterMessage--" + i);
                producer.send(textMessage);
            }
            producer.close();
            session.close();
            connection.close();
    
            System.out.println("消息发布到完成……");
        }
    }

**消费者**

public class JmsConsumer {
        public static final String ACTIVEMQ_URL = "failover:(tcp://ip:61616,tcp://ip:61617,tcp://ip:61618)?randomize=false";
        public static final String QUEUE_NAME = "queue-cluster";
    
        public static void main(String[] args) throws JMSException, IOException {
            //1.创建链接工厂,按照给定的url地址，采用默认的用户和密码
            ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);
            //2.通过链接工厂，获得Connection并启动
            Connection connection = activeMQConnectionFactory.createConnection();
            connection.start();
            //3.创建会话session
            //3.1 两个参数 ①事务 ②签收
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //4.创建目的地（queue or topic）
            Queue queue = session.createQueue(QUEUE_NAME);
            //5.创建消费者
            MessageConsumer consumer = session.createConsumer(queue);
            
            consumer.setMessageListener(new MessageListener() {
                @Override
                public void onMessage(Message message) {
                    if(null != message && message instanceof TextMessage) {
                        TextMessage textMessage = (TextMessage) message;
                        try {
                            System.out.println("监听到cluster消息："+textMessage.getText());
                        } catch (JMSException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });
            //连接AvtiveMQ需要等待时间
            System.in.read();
            consumer.close();
            session.close();
            connection.close();
        }
    }

![81e5c5973e904c2ead67568ddcdb04ad.png][]

![9c444958c5c74dca93b8de435ff41337.png][]

[ActiveMQ _apache.org]: https://activemq.apache.org/masterslave.html
[935265c008b44e46b98a1d4003e555aa.png]: https://img-blog.csdnimg.cn/935265c008b44e46b98a1d4003e555aa.png
[7672882706494283920e0a285584a381.png]: https://img-blog.csdnimg.cn/7672882706494283920e0a285584a381.png
[0dd0306f68f7468fb5932e95f1ed09a0.png]: https://img-blog.csdnimg.cn/0dd0306f68f7468fb5932e95f1ed09a0.png
[956df33ffa8d4a1abd5d1a73ec52d249.png]: https://img-blog.csdnimg.cn/956df33ffa8d4a1abd5d1a73ec52d249.png
[637a05e8f68644c7aa4f284df3c1c650.png]: https://img-blog.csdnimg.cn/637a05e8f68644c7aa4f284df3c1c650.png
[f2a9a9fa3a1447dd8d9dd9f6a51f1708.png]: https://img-blog.csdnimg.cn/f2a9a9fa3a1447dd8d9dd9f6a51f1708.png
[63bd5d84e2f240318a28247428a520a7.png]: https://img-blog.csdnimg.cn/63bd5d84e2f240318a28247428a520a7.png
[a0a9a6ec7be840339af8d9dc56594748.png]: https://img-blog.csdnimg.cn/a0a9a6ec7be840339af8d9dc56594748.png
[1949f0bf5ed747129826f6bc0734e5a9.png]: https://img-blog.csdnimg.cn/1949f0bf5ed747129826f6bc0734e5a9.png
[fbec0fce9615481a8a8e85a658e64a48.png]: https://img-blog.csdnimg.cn/fbec0fce9615481a8a8e85a658e64a48.png
[8c27b6bef06a4c52b49414add4a60bd7.png]: https://img-blog.csdnimg.cn/8c27b6bef06a4c52b49414add4a60bd7.png
[8cae2bab74d246eda2af885574ca65d4.png]: https://img-blog.csdnimg.cn/8cae2bab74d246eda2af885574ca65d4.png
[292b0b4826684d599ac5b8f844316bd2.png]: https://img-blog.csdnimg.cn/292b0b4826684d599ac5b8f844316bd2.png
[39e05a2aa1a6410fb33fdb6a14c38ba4.png]: https://img-blog.csdnimg.cn/39e05a2aa1a6410fb33fdb6a14c38ba4.png
[8f90333d92d344bfb50d79800f97a369.png]: https://img-blog.csdnimg.cn/8f90333d92d344bfb50d79800f97a369.png
[363f206fc8614017aea983c7cda1d5c9.png]: https://img-blog.csdnimg.cn/363f206fc8614017aea983c7cda1d5c9.png
[a5e3bcf6ba7240939f0a3186bc2f8987.png]: https://img-blog.csdnimg.cn/a5e3bcf6ba7240939f0a3186bc2f8987.png
[099a363f329142fbb5ec40217dcf06a7.png]: https://img-blog.csdnimg.cn/099a363f329142fbb5ec40217dcf06a7.png
[3f4b30cdd119496bbc86fd09dc6fc1e8.png]: https://img-blog.csdnimg.cn/3f4b30cdd119496bbc86fd09dc6fc1e8.png
[d1895f81ad2b44fb8a92adb42c41c42f.png]: https://img-blog.csdnimg.cn/d1895f81ad2b44fb8a92adb42c41c42f.png
[81e5c5973e904c2ead67568ddcdb04ad.png]: https://img-blog.csdnimg.cn/81e5c5973e904c2ead67568ddcdb04ad.png
[9c444958c5c74dca93b8de435ff41337.png]: https://img-blog.csdnimg.cn/9c444958c5c74dca93b8de435ff41337.png