前提
配置好jdk環境
一、下載:apache-activemq-5.15.2-bin.tar.gz
https://archive.apache.org/dist/activemq/5.15.2/apache-activemq-5.15.2-bin.tar.gz
二、安裝activemq
#su – admin
1、gz文件拷貝到/home/admin目錄
2、解壓啟動
tar -zxvf apache-activemq-5.15.2-bin.tar.gz
cd apache-activemq-5.15.2/bin
./activemq start
#su – root
ln -s /home/admin/activemq/bin/activemq /etc/init.d/
服務啟動
#su – admin
/etc/init.d/activemq start
設置開機自啟動
#cat /etc/rc.local
export JAVA_HOME=/usr/local/jdk1.8
su - admin -c '/home/admin/activemq/bin/activemq start'
日志目錄
/home/admin/activemq/data
查看管控台
直接在本地開啟瀏覽器訪問:Linux的地址加上8161端口。
默認登錄用戶:admin 密碼:admin
修改用戶信息編輯 conf/jetty-realm.properties 即可
集群配置
192.168.13.19、192.168.13.24、192.168.13.25
修改ActiveMQ配置文件conf/activemq.xml
1、第一處修改:brokerName="msgService" 三台MQ的需要修改成一樣的
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="msgService" dataDirectory="${activemq.data}">
2、第二處修改:
<persistenceAdapter>
<!-- <kahaDB directory="${activemq.data}/kahadb"/> -->
<replicatedLevelDB
directory="${activemq.data}/leveldb"
replicas="3"
bind="tcp://0.0.0.0:0"
zkAddress="192.168.13.19:2181,192.168.13.24:2181,192.168.13.25:2181"
zkPassword=""
zkPath="/activemq/leveldb-stores"
hostname="192.168.13.19"
//分別修改成對應自己服務器的ip地址
sync="local_disk"
/>
三、Client使用
該zookeeper+activemq的集群Master Slave部署方案,能夠提供(3-1)/2的容錯率,即3台服務器允許宕機一台,而不影響整個集群的對外提供服務。
編寫代碼連接時使用failover策略:
String url = failover:(tcp://192.168.1319:61616,tcp://192.168.13.24:61616,tcp://192.168.13.25:61616)?initialReconnectDelay=1000