第一步:創建集群目錄

[root@node001 ~]# mkdir -p /usr/local/activemqCluster

復制單點至集群目錄

[root@node001 ~]# cp /usr/local/activemq/apache-activemq-5.14.5 /usr/local/activemqCluster/mq1 -rf

第二步：配置activemq.xml

進入conf所在目錄

[root@node001 ~]# cd /usr/local/activemqCluster/mq1/conf

[root@node001 conf]# vi activemq.xml

替換為下面的內容：

配置詳細信息解讀：

<persistenceAdapter>
    <replicatedLevelDB
        #數據目錄
        directory="${activemq.data}/leveldb"   
        #集群數為3
        replicas="3"
        #綁定服務地址
        bind="tcp://0.0.0.0:62621"
        #zookeeper地址
        zkAddress="localhost:2181,localhost:2182,localhost:2183"
        #服務的地址
        hostname
 
="localhost"
        #在zookeeper中的路徑
        zkPath="/activemq/leveldb-stores"/>
</persistenceAdapter>


<networkConnectors>
    #配置自動切換地址
    <networkConnector uri="static:(tcp://127.0.0.1:61616,tcp://127.0.0.1:61716,tcp://127.0.0.1:61816)" duplex="false"/>
</networkConnectors>

第三步：再復制兩份，共計三份，修改端口號

[root@node001 ~]# cd /usr/local/activemqCluster/

[root@node001 activemqCluster]# cp mq1 mq2 -rf
[root@node001 activemqCluster]# cp mq1 mq3 -rf

mq2修改端口號

[root@node001 activemqCluster]# cd mq2/conf

[root@node001 conf]# vi activemq.xml

mq3修改端口號同理,改為61816即可，此處不在演示

第四步：啟動

[root@node001 ~]# cd /usr/local/activemqCluster/

[root@node001 activemqCluster]# mq1/bin/activemq start
INFO: Loading ‘/usr/local/activemqCluster/mq1//bin/env‘
INFO: Using java ‘/usr/local/java/jdk1.8.0_161/bin/java‘
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: pidfile created : ‘/usr/local/activemqCluster/mq1//data/activemq.pid‘ (pid ‘2786‘)
[root@node001 activemqCluster]# mq2/bin/activemq start
INFO: Loading ‘/usr/local/activemqCluster/mq2//bin/env‘
INFO: Using java ‘/usr/local/java/jdk1.8.0_161/bin/java‘
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: pidfile created : ‘/usr/local/activemqCluster/mq2//data/activemq.pid‘ (pid ‘2840‘)
[root@node001 activemqCluster]# mq3/bin/activemq start
INFO: Loading ‘/usr/local/activemqCluster/mq3//bin/env‘
INFO: Using java ‘/usr/local/java/jdk1.8.0_161/bin/java‘
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: pidfile created : ‘/usr/local/activemqCluster/mq3//data/activemq.pid‘ (pid ‘2892‘)

java客戶端操作集群

更改連接地址即可，如圖：

activemq集群搭建Demo