這是ActiveMQ系列的最后一篇文章,主要是關(guān)于ActiveMQ集群,這里采用的方式是:Zookeeper+LevelDB+ActiveMQ。前面2篇博客地址如下:《ActiveMQ從入門到精通(一)》、《ActiveMQ從入門到精通(二)》。
利用Zookeeper實現(xiàn)ActiveMQ的高可用
話不多說,先來看一張ActiveMQ官方提供的架構(gòu)圖:

Master/Slave broker的信息要注冊到ZK
注意到只有Master對外提供了服務(wù),Slave是待機狀態(tài)。當Master出現(xiàn)故障,ZK內(nèi)部的選舉機制,會讓一個Slave升級成Master對外提供服務(wù)。
關(guān)于ZK,以后博主會有專題進行介紹,這里不做詳細講解,只需要了解通過ZK的協(xié)調(diào)、選舉、容錯機制等會實現(xiàn)ActiveMQ的高可用。
既然要做到高可用,那么ZK也得是高可用的,所以這里的搭建方案是這樣的:

第一步:JDK環(huán)境

保證這3臺機器都安裝了JDK,并配置了JAVA環(huán)境變量。
第二步:配置Zookeeper

為什么要配置ZK環(huán)境變量呢?很簡單,我想在命令行下直接使用ZK相關(guān)的命令,而不是進入到安裝ZK目錄下的bin,更不想用絕對路徑。

注意dataDir目錄的指定;注意2181是外部訪問ZK的端口;
2888:3888是ZK集群內(nèi)部通信(比如ZK原子廣播消息)的端口,注意server.X的定義,這是將ZK集群中的實例進行編號,實際上需要在dataDir目錄中新建myid文件,并與之保持一致。

第三步:啟動ZK

可以通過netstat命令查看2722進程,發(fā)現(xiàn)ZK的端口是2181,這和zoo.cfg的配置是一致的。讓3臺機器的ZK都啟動起來。

第四步:ActiveMQ主從配置
注意了,由于我將在3臺物理機上搭建一臺Master,2臺Slave,因此我這邊不需要對端口配置文件進行改動。比如WEB管控臺的jetty.xml。

3臺機器應(yīng)該對外只有一個統(tǒng)一的名稱,就是這個brokerName。3臺機器都修改成一個名稱即可。
這里持久化,我將采用LevelDB,因此需要修改持久化配置:

注意bind地址,其實是ActiveMQ集群內(nèi)部通信的TCP端口,和ActiveMQ對外提供的消息端口(默認61616)不要搞混了。
hostname即本機的主機名稱。
給出ZK集群的列表以及zkPath。zkPath下面其實存放著ActiveMQ的節(jié)點,在后續(xù)你會看到。
啟動3臺機器上的ActiveMQ,然后利用ZooInspector你可以看到:

此時此刻,基于ZK的ActiveMQ的高可用方案就做好了。那么JAVA端訪問ActiveMQ有什么變化么?其實就是在創(chuàng)建ConnectionFactory的時候給定的URL有變化:
failover:(tcp://192.168.99.121:61616,tcp://192.168.99.122:61616,tcp://192.168.99.123:61616)?Randomize=false
就是一個失敗轉(zhuǎn)移協(xié)議!
上面只是做了一個ActiveMQ的高可用方案,那么ActiveMQ集群呢?其實所謂的ActiveMQ集群就是多個ActiveMQ高可用之間產(chǎn)生關(guān)聯(lián):

高可用的ActiveMQ-1,ActiveMQ-2,...,ActiveMQ-N就可以組建ActiveMQ集群
在配置上很簡單,其實就是ActiveMQ-1要知道ActiveMQ-2的信息而已,這里大家可以自行百度,不在演示了。
整個ActiveMQ從入門到精通系列就結(jié)束了,希望對大家有幫助!我們RocketMQ系列再見~