腾讯云~基于zookeeper(集群)+LevelDB的ActiveMq高可用伪集群安装、配置、测试

文章目录

• ​​一、预先准备​​

• ​​1. 技术选型​​
• ​​2. zk集群搭建​​
• ​​3. MQ集群规划​​

• ​​二、预先准备​​

• ​​2.1. MQ下载​​
• ​​2.2. 解压​​
• ​​2.3. 复制3分​​
• ​​2.4. 修改jetty.xml​​
• ​​2.5. 统一所有主从节点 Broker 命名​​
• ​​2.6. 修改持久化配置​​
• ​​2.7. 修改服务端口​​
• ​​2.8. 配置防火墙​​
• ​​2.9. MQ启动​​
• ​​2.10. 查看 MQ状态​​

• ​​三、集群验证测试​​

• ​​3.1. 实现思路​​
• ​​3.2. 默认测试​​
• ​​3.3. 停止8163服务测试​​

• ​​四、查看主从状态​​

• ​​4.1. 连接 Zk​​
• ​​4.2. 查看状态信息​​
• ​​4.3. java中的代码​​

• ​​五、activeMq主从集群​​

• ​​5.1. 准备多份主从模型​​
• ​​5.2. 案例​​

• ​​六、常用操作​​

• ​​6.1. 常用命令​​
• ​​6.2. 清除数据​​

一、预先准备

1. 技术选型

2. zk集群搭建

根据自己的实际情况选择参考

腾讯云~伪集群环境
​腾讯云~ zookeeper集群安装、配置、验证​​

centos7~集群环境

​​Linux 环境 zookeeper集群安装、配置、验证​​

3. MQ集群规划

在同一个Linux中安装三个 ActiveMQ 实例， 使用不同端口实现同时启动。 端口分配如下：

二、预先准备

2.1. MQ下载

官网链接

​​https://activemq.apache.org/components/classic/download/​​

cd /app
wget https://dlcdn.apache.org//activemq/5.16.5/apache-activemq-5.16.5-bin.tar.g z

2.2. 解压

cd /app
tar -zxvf apache-activemq-5.16.5-bin.tar.gz

2.3. 复制3分

cp apache-activemq-5.16.5 mq_01 -r
cp apache-activemq-5.16.5 mq_02 -r
cp apache-activemq-5.16.5 mq_03 -r

2.4. 修改jetty.xml

打开3个窗口依次操作，修改conf/jetty.xml 中的host地址和端口配置。
host值都为0.0.0.0 ，jetty端口分别是8161、 8162、 8163

vim /app/mq_01/conf/jetty.xml
vim /app/mq_02/conf/jetty.xml
vim /app/mq_03/conf/jetty.xml

mq_01

mq_02

mq_03

host值设置为0.0.0.0是为了windows访问控制台

2.5. 统一所有主从节点 Broker 命名

vim /app/mq_01/conf/activemq.xml
vim /app/mq_02/conf/activemq.xml
vim /app/mq_03/conf/activemq.xml

搜索brokerName，统一为mq-cluster

mq_01

mq_02

mq_03

2.6. 修改持久化配置

修改 conf/activemq.xml 文件
修改 broker标签中子标签 persistenceAdapter相关内容：

replicas属性代表当前主从模型中的节点数量。 按需配置。
bind 属性中的端口为主从实例之间的通讯端口。 代表当前实例对外开放端口是什么， 三个实例分别使用 62626、 62627、 62628端口。
zkAddress 属性代表ZooKeeper安装位置， 安装具体情况设置。
zkPath 是 ActiveMQ 主从信息保存到 ZooKeeper中的什么目录内。
hostname为 ActiveMQ实例安装 Linux的主机名， 可以在/etc/hosts 配置文件中设置。 设置格式为： IP 主机名。 如：127.0.0.1 mq-server

vim /app/mq_01/conf/activemq.xml
vim /app/mq_02/conf/activemq.xml
vim /app/mq_03/conf/activemq.xml

搜索persistenceAdapter
mq_01

<persistenceAdapter>
        <!-- <kahaDB directory="${activemq.data}/kahadb"/> -->
             <replicatedLevelDB
                directory="${activemq.data}/levelDB"
                replicas="3"
                bind="tcp://0.0.0.0:62626"
                zkAddress="192.168.43.80:2181,192.168.43.80:2182,192.168.43.80:2183"
                zkPath="/activemq/leveldb-stores"
                hostname="mq-server"/>
        </persistenceAdapter>

mq_02

<!-- <kahaDB directory="${activemq.data}/kahadb"/> -->
             <replicatedLevelDB
                directory="${activemq.data}/levelDB"
                replicas="3"
                bind="tcp://0.0.0.0:62627"
                zkAddress="192.168.43.80:2181,192.168.43.80:2182,192.168.43.80:2183"
                zkPath="/activemq/leveldb-stores"
                hostname="mq-server"/>
        </persistenceAdapter>

mq_03

<persistenceAdapter>
        <!-- <kahaDB directory="${activemq.data}/kahadb"/> -->
             <replicatedLevelDB
                directory="${activemq.data}/levelDB"
                replicas="3"
                bind="tcp://0.0.0.0:62628"
                zkAddress="192.168.43.80:2181,192.168.43.80:2182,192.168.43.80:2183"
                zkPath="/activemq/leveldb-stores"
                hostname="mq-server"/>
        </persistenceAdapter>

• 配置host

vim /etc/hosts

添加映射关系

127.0.0.1 mq-server

2.7. 修改服务端口

修改 ActiveMQ对外提供的服务端口。 原默认端口为 61616。
当前环境使用的端口为：61616、 61617、 61618。
修改conf/activemq.xml配置文件。 修改broker 标签中子标签transportConnectors的相关配置

vim /app/mq_01/conf/activemq.xml
vim /app/mq_02/conf/activemq.xml
vim /app/mq_03/conf/activemq.xml

搜索61616

mq_01 保持不变

mq_02

mq_03

2.8. 配置防火墙

控制台端口+通讯端口+集群端口+tcp端口62621

firewall-cmd --zone=public --add-port=8161/tcp --permanent
firewall-cmd --zone=public --add-port=8162/tcp --permanent
firewall-cmd --zone=public --add-port=8163/tcp --permanent
firewall-cmd --zone=public --add-port=5672/tcp --permanent
firewall-cmd --zone=public --add-port=62626/tcp --permanent
firewall-cmd --zone=public --add-port=62627/tcp --permanent
firewall-cmd --zone=public --add-port=62628/tcp --permanent
firewall-cmd --zone=public --add-port=61616/tcp --permanent
firewall-cmd --zone=public --add-port=61617/tcp --permanent
firewall-cmd --zone=public --add-port=61618/tcp --permanent
firewall-cmd --reload

2.9. MQ启动

mq_01

/app/mq_01/bin/activemq start & tail -f /app/mq_01/data/activemq.log

mq_02

/app/mq_02/bin/activemq start & tail -f /app/mq_02/data/activemq.log

mq_03

/app/mq_03/bin/activemq start & tail -f /app/mq_03/data/activemq.log

2.10. 查看 MQ状态

/app/mq_01/bin/activemq status
/app/mq_02/bin/activemq status
/app/mq_03/bin/activemq status

三、集群验证测试

3.1. 实现思路

1. 只有一个MQ对外提供服务
2. 当MQ停止运行后，从机会对外提供服务
3. zk会帮助我们完成负载

3.2. 默认测试

测试地址：

http://192.168.43.80:8161/admin
http://192.168.43.80:8162/admin
http://192.168.43.80:8163/admin

账号密码都是admin

从上面测试来看，启动的MQ3个节点，默认只有8163端口对外提供服务

3.3. 停止8163服务测试

ps -ef|grep mq

四、查看主从状态

4.1. 连接 Zk

${zkHome}/bin/zkCli.sh

cd /app/zookeeper-3.4.12/bin
./zkCli.sh

4.2. 查看状态信息

连接成功后， 可以使用命令ls查看ZooKeeper中的目录结构如：

ls /
ls /activemq/leveldb-stores

找到对应的内容后， 可以使用命令get 查看 ZooKeeper 中的数据内容

get /activemq/leveldb-stores/00000000028

get /activemq/leveldb-stores/00000000029

get /activemq/leveldb-stores/00000000027

4.3. java中的代码

//普通模式连接工厂
ConnectionFactory factory = new ActiveMQConnectionFactory("guest","guest","tcp://192.168.43.80:61616");
//集群模式连接工厂
// failover -失败转移，当任意节点宕机，自动转移
ConnectionFactory factory = new ActiveMQConnectionFactory("guest","guest",
"failover:(tcp://192.168.43.80:61616,tcp://192.168.43.80:61617,tcp://192.168.43.80:61618)?Randomize=false");

五、activeMq主从集群

5.1. 准备多份主从模型

在所有的 ActiveMQ节点中的 conf/activemq.xml中增加下述配置：
（每个主从模型中的 networkConnector都指向另外一个主从模型）
常用操作

<networkConnectors>
<networkConnector uri="static://(tcp://ip:port,tcp://ip:port)" duplex="false">
</networkConnector>
</networkConnectors>

duplex="false"的意思是不做复制，假入有两个模型，设置为fasle的话，其中得到消息的模型就不会复制到没有得到消息的模型里，如果设置为true，那么得到消息的模型会把消息复制到没有得到消息的模型中去
注意配置顺序，Networks相关配置必须在持久化相关配置之前。 如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://activemq.apache.org/schema/core">
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="mq-cluster"
dataDirectory="${activemq.data}" >
<networkConnectors>
<networkConnector uri=" static://(tcp://ip:port,tcp://ip:port)"/>
</networkConnectors>

<persistenceAdapter>
<replicatedLevelDB directory = "xxx"/>
</persistenceAdapter>
</broker>
</beans>

5.2. 案例

如： 主从模型1 -192.168.159.129主从模型 2 - 192.168.159.130，
在主从模型 1 的所有节点activemq.xml 配置文件中增加标签：

<networkConnectors>
<networkConnector uri="static://(tcp://192.168.159.130:61616,tcp://192.168.159.130:61617)"/>
</networkConnectors>

在模型 2 中所有节点增加配置：

<networkConnectors>
<networkConnector uri="static://(tcp://192.168.159.129:61616,tcp://192.168.159.129:61617)"/>
</networkConnectors>

六、常用操作

6.1. 常用命令

启动MQ

/app/mq_02/bin/activemq start & tail -f /app/mq_02/data/activemq.log

停止MQ

/app/mq_02/bin/activemq stop

查看MQ 状态

/app/mq_02/bin/activemq status

重新启动MQ

/app/mq_02/bin/activemq restart & tail -f /app/mq_02/data/activemq.log

6.2. 清除数据

用于搭建集群环境有问题，重新搭建，建议把zk数据一起清除

rm -rf /app/mq_01/data/levelDB/
rm -rf /app/mq_02/data/levelDB/
rm -rf /app/mq_03/data/levelDB/
cat /dev/null > /app/mq_01/data/activemq.log
cat /dev/null > /app/mq_02/data/activemq.log
cat /dev/null > /app/mq_03/data/activemq.log