ActiveMQ 高可用集群安装、配置（ZooKeeper + LevelDB）
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了ActiveMQ 高可用集群安装、配置（ZooKeeper + LevelDB），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7289字，纯文字阅读大概需要11分钟。
内容图文
10.14.0.1 mq-01.ihomefnt.com ihome-mq-01
10.14.0.2 mq-02.ihomefnt.com ihome-mq-02
10.14.0.3 mq-03.ihomefnt.com ihome-mq-03
2、防火墙打开对应的端口
## mq cluster -A INPUT -m state --state NEW -m tcp -p tcp --dport 8361 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 8362 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 8363 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 53531 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 53532 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 53533 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 63631 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 63632 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 63633 -j ACCEPT -A INPUT -m state --state NEW -m tcp -p tcp --dport 63631 -j ACCEPT
3、分别在三台主机中创建/opt/product/activemq 目录
$ mkdir /opt/product/activemq
wget http://archive.apache.org/dist/activemq/5.11.1/apache-activemq-5.11.1-bin.tar.gz
4、解压并按节点命名
$ cd /opt/product/activemq $ tar -xvf apache-activemq-5.11.1-bin.tar.gz $ mv apache-activemq-5.11.1 node-0X #(X 代表节点号 1、2、3，下同)
5、修改管理控制台端口（默认为 8161）可在 conf/jetty.xml 中修改，如下：
Node-01 管控台端口：
<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start"> <!-- the default port number for the web console --> <property name="host" value="0.0.0.0"/> <property name="port" value="8361"/> </bean>
Node-02 管控台端口：
<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start"> <!-- the default port number for the web console --> <property name="host" value="0.0.0.0"/> <property name="port" value="8362"/> </bean>
Node-03 管控台端口：
<bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start"> <!-- the default port number for the web console --> <property name="host" value="0.0.0.0"/>
<property name="port" value="8363"/> </bean>
6、集群配置：
在 3 个 ActiveMQ 节点中配置 conf/activemq.xml 中的持久化适配器。修改其中 bind、zkAddress、
hostname 和 zkPath。注意：每个 ActiveMQ 的 BrokerName 必须相同，否则不能加入集群。
Node-01 中的持久化配置:
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="ihome-mq" dataDirectory="${activemq.data}"> <persistenceAdapter> <!-- kahaDB directory="${activemq.data}/kahadb"/ --> <replicatedLevelDB directory="${activemq.data}/leveldb" replicas="3" bind="tcp://0.0.0.0:63631" zkAddress="192.168.1.11:2181,192.168.1.12:2182,192.168.1.12:2183" hostname="ihome-mq-01" zkPath="/activemq2/leveldb-stores" /> </persistenceAdapter> </broker>
Node-02 中的持久化配置:
<broker xmlns="http://activemq.apache.org/schema/core" brokerName=" ihome-mq " dataDirectory="${activemq.data}"> <persistenceAdapter> <!-- kahaDB directory="${activemq.data}/kahadb"/ --> <replicatedLevelDB directory="${activemq.data}/leveldb" replicas="3" bind="tcp://0.0.0.0:63632" zkAddress="192.168.1.11:2181,192.168.1.12:2182,192.168.1.12:2183" hostname=" ihome-mq-02" zkPath="/activemq2/leveldb-stores" /> </persistenceAdapter> </broker>
Node-03 中的持久化配置:
<broker xmlns="http://activemq.apache.org/schema/core" brokerName=" ihome-mq " dataDirectory="${activemq.data}"> <persistenceAdapter> <!-- kahaDB directory="${activemq.data}/kahadb"/ --> <replicatedLevelDB directory="${activemq.data}/leveldb" replicas="3" bind="tcp://0.0.0.0:63633" zkAddress="192.168.1.11:2181,192.168.1.12:2182,192.168.1.12:2183" hostname=" ihome-mq-03" zkPath="/activemq2/leveldb-stores" /> </persistenceAdapter> </broker>
修改各节点的消息端口（注意，避免端口冲突）：
Node-01 中的消息端口配置:
<transportConnectors> <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --> <transportConnector name="openwire" uri="tcp://0.0.0.0:53531?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> </transportConnectors>
Node-02 中的消息端口配置:
<transportConnectors> <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --> <transportConnector name="openwire" uri="tcp://0.0.0.0:53532?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> </transportConnectors>
Node-03 中的消息端口配置:
<transportConnectors> <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --> <transportConnector name="openwire" uri="tcp://0.0.0.0:53533?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> </transportConnectors>
7、按顺序启动 3 个 ActiveMQ 节点：
$ /opt/product/activemq/node-01/bin/activemq start $ /opt/product/activemq/node-02/bin/activemq start $ /opt/product/activemq/node-03/bin/activemq start
8、集群的节点状态分析：
集群启动后对 ZooKeeper 数据的抓图，可以看到 ActiveMQ 的有 3 个节点，分别是 00000000000，
00000000001，00000000002。
9、集群可用性测试：
ActiveMQ 的客户端只能访问 Master 的 Broker，其他处于 Slave 的 Broker 不能访问。所以客户端连
接 Broker 应该使用 failover 协议。
failover:(tcp:// mq-01.ihomefnt.com:53531,tcp:// mq-02.ihomefnt.com:53532,tcp:// mq-03.ihomefnt.com:53533)?ran
domize=false
10、集群高可用测试：
当一个 ActiveMQ 节点挂掉，或者一个 ZooKeeper 节点挂掉，ActiveMQ 服务依然正常运转。如果仅剩
一个 ActiveMQ 节点，因为不能选举 Master，ActiveMQ 不能正常运转；同样的，如果 ZooKeeper 仅剩一个
节点活动，不管 ActiveMQ 各节点是否存活，ActiveMQ 也不能正常提供服务。
11、设置开机启动：
# vi /etc/rc.local
su - wusc -c ‘/opt/aijia/activemq/node-01/bin/activemq start‘
su - wusc -c ‘/opt/aijia/activemq/node-02/bin/activemq start‘
su - wusc -c ‘/opt/aijia/activemq/node-03/bin/activemq start‘
ActiveMQ 高可用集群安装、配置（ZooKeeper + LevelDB）
标签：集群配置 活动 tab 目录 jdk path adapter jetty section
本文系统来源：http://www.cnblogs.com/zihanxing/p/7359736.html
内容总结
以上是互联网集市为您收集整理的ActiveMQ 高可用集群安装、配置（ZooKeeper + LevelDB）全部内容，希望文章能够帮你解决ActiveMQ 高可用集群安装、配置（ZooKeeper + LevelDB）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。