ActiveMQ集群的安装配置

r囧r小猫 2022-06-11 03:46 495阅读 0赞

采用ZooKeeper 和 LevelDB 搭建 ActiveMQ 集群。集群仅提供主备方式的高可用集群功能，避免单点故障，没有负载均衡功能。

官方文档：http://activemq.apache.org/replicated-leveldb-store.html

1. ZooKeeper集群安装

准备3台服务器  192.168.43.129，192.168.43.130，192.168.43.131 ，参考 [http://blog.csdn.net/zsg88/article/details/76286225][http_blog.csdn.net_zsg88_article_details_76286225]

2. 在  192.168.43.129，192.168.43.130，192.168.43.131 分贝安装activemq，参考：

linux下ActiveMQ的安装配置一    [http://blog.csdn.net/zsg88/article/details/76153246][http_blog.csdn.net_zsg88_article_details_76153246]

linux下ActiveMQ的安装配置二   [  http://blog.csdn.net/zsg88/article/details/76158126][_http_blog.csdn.net_zsg88_article_details_76158126]

安装在   /home/zsg/program 目录下

cd  /home/zsg/program

tar -zxvf apache-activemq-5.15.0-bin.tar.gz

mv apache-activemq-5.15.0 activemq

2. activemq 集群配置

在 3 个 ActiveMQ 节点中配置 conf/activemq.xml 中的持久化适配器。修改其中 bind、zkAddress、hostname 和 zkPath。注意：每个 ActiveMQ 的 BrokerName 必须相同，否则不能加入集群。

bind：  集群的通讯端口

zkAddress ： zookeeper集群的ip和对客户端的监听端口

hostname ：  主机名或ip

zkPath： 代表zookeeper内的“路径”，即你运行在2181端口的zk内的“寻址节点”，类似于JNDI。如果你没有这个zkPath，默认它在zk内的寻址节点为“/default”。加入到某一组master slave中的mq的实例中的zkPath必须完全匹配。不用改。

replicas：这边的数字指的就是ActiveMQ实例的节点数，它需要满足2N+1，因此你也可以5台（1拖4）。

在<policyEntries>节点中添加

<destinationPolicy>
                <policyMap>
                  <policyEntries>
                    <policyEntry topic=">" >
                        
                      <pendingMessageLimitStrategy>
                        <constantPendingMessageLimitStrategy limit="1000"/>
                      </pendingMessageLimitStrategy>
                    </policyEntry>
                  </policyEntries>
                  
                  
                  <policyEntry queue=">" enableAudit="false">
                     <networkBridgeFilterFactory>
                        <conditionalNetworkBridgeFilterFactory replayWhenNoConsumers="true"/>
                     </networkBridgeFilterFactory>
                  </policyEntry>
                
               </policyMap>
            </destinationPolicy>

4.端口

activemq.xml 看到这么多通讯端口

activemq的jetty访问的默认端口是8161

如果你的3个activemq都在1台机器里，那么每个mq的的端口都不能一样。

如果是3太不同的机器，那么就可以都是同样的端口。

5. 先启动zookeeper集群

6. 启动3个activema

/home/zsg/program/activemq/bin/activemq start

一台一台启动的时候也要查active的log

cd data

tail -fn 100 activemq.log

如果到这里启动没什么问题的话，当你启动第一台mq的时候，zookeeper的日志就会打出英文的日志告诉你一台activemq不够，至少两台才能形成Master/Slave。

之后可以在浏览器上分别访问三台activeMq的web管理后台   http://192.168.43.129:8161/  ，http://192.168.43.130:8161/  ，http://192.168.43.131:8161/ ，这种主从的方式成功的话，只会有一台是master，三个端口也只能有一个可以访问，其他两个都是等待状态。

经测试，后台也只能有一个可以访问。

7. 通过分析activemq进程所占用端口的情况来确定集群的主从

(1)首先根据名称用ps命令查看进程的id：

$ ps -ef | grep activemq

![Center][]

找到activemq的进程编号 61573

(2)查到进程id之后，使用netstat命令查看其占用的端口：

$ netstat -nap | grep 61573

图一

![Center 1][]

图二

![Center 2][]

我们能看到2种端口占用的情况，很明显图二是主服务器，图一是从服务器

那么很明显，admin后台的访问地址是   http://192.168.43.130.8161

8. 客户端测试

生产和消费分成两个程序。  
生产发一条消息，注意看console会输出如“\[INFO\] Successfully reconnected to tcp://192.168.43.129:61616”  
手工停止61616这台实例，然后你会发觉另2个mq中有一个被promoted to master

然后运行consumer，consumer会连上被promoted的实例并继续消费刚才那几条消息

8.手动控制台方式启动，方便查看错误

/home/zsg/program/activemq/bin/activemq console

[http_blog.csdn.net_zsg88_article_details_76286225]: http://blog.csdn.net/zsg88/article/details/76286225
[http_blog.csdn.net_zsg88_article_details_76153246]: http://blog.csdn.net/zsg88/article/details/76153246
[_http_blog.csdn.net_zsg88_article_details_76158126]: http://blog.csdn.net/zsg88/article/details/76158126
[Center]: /images/20220611/533ac8baff8148d4b54d3813959ff08a.png
[Center 1]: /images/20220611/934f6440a8744a0e8a6bb029545423bf.png
[Center 2]: /images/20220611/b44f2d11c08e421d9d8e7d08d6ab9aad.png