這是ActiveMQ系列的最后一篇文章哺窄,主要是關(guān)于ActiveMQ集群般婆,這里采用的方式是:Zookeeper+LevelDB+ActiveMQ到腥。前面2篇博客地址如下:《ActiveMQ從入門到精通(一)》、《ActiveMQ從入門到精通(二)》腺兴。
利用Zookeeper實(shí)現(xiàn)ActiveMQ的高可用
話不多說左电,先來看一張ActiveMQ官方提供的架構(gòu)圖:
Master/Slave broker的信息要注冊到ZK
注意到只有Master對外提供了服務(wù),Slave是待機(jī)狀態(tài)页响。當(dāng)Master出現(xiàn)故障篓足,ZK內(nèi)部的選舉機(jī)制,會(huì)讓一個(gè)Slave升級(jí)成Master對外提供服務(wù)闰蚕。
關(guān)于ZK栈拖,以后博主會(huì)有專題進(jìn)行介紹,這里不做詳細(xì)講解没陡,只需要了解通過ZK的協(xié)調(diào)涩哟、選舉、容錯(cuò)機(jī)制等會(huì)實(shí)現(xiàn)ActiveMQ的高可用盼玄。
既然要做到高可用贴彼,那么ZK也得是高可用的,所以這里的搭建方案是這樣的:
第一步:JDK環(huán)境
保證這3臺(tái)機(jī)器都安裝了JDK埃儿,并配置了JAVA環(huán)境變量器仗。
第二步:配置Zookeeper
為什么要配置ZK環(huán)境變量呢?很簡單童番,我想在命令行下直接使用ZK相關(guān)的命令精钮,而不是進(jìn)入到安裝ZK目錄下的bin,更不想用絕對路徑剃斧。
注意dataDir目錄的指定轨香;注意2181是外部訪問ZK的端口;
2888:3888是ZK集群內(nèi)部通信(比如ZK原子廣播消息)的端口幼东,注意server.X的定義臂容,這是將ZK集群中的實(shí)例進(jìn)行編號(hào)科雳,實(shí)際上需要在dataDir目錄中新建myid文件,并與之保持一致策橘。
第三步:啟動(dòng)ZK
可以通過netstat命令查看2722進(jìn)程炸渡,發(fā)現(xiàn)ZK的端口是2181娜亿,這和zoo.cfg的配置是一致的丽已。讓3臺(tái)機(jī)器的ZK都啟動(dòng)起來。
第四步:ActiveMQ主從配置
注意了买决,由于我將在3臺(tái)物理機(jī)上搭建一臺(tái)Master沛婴,2臺(tái)Slave,因此我這邊不需要對端口配置文件進(jìn)行改動(dòng)督赤。比如WEB管控臺(tái)的jetty.xml嘁灯。
3臺(tái)機(jī)器應(yīng)該對外只有一個(gè)統(tǒng)一的名稱,就是這個(gè)brokerName躲舌。3臺(tái)機(jī)器都修改成一個(gè)名稱即可丑婿。
這里持久化,我將采用LevelDB没卸,因此需要修改持久化配置:
注意bind地址羹奉,其實(shí)是ActiveMQ集群內(nèi)部通信的TCP端口,和ActiveMQ對外提供的消息端口(默認(rèn)61616)不要搞混了约计。
hostname即本機(jī)的主機(jī)名稱诀拭。
給出ZK集群的列表以及zkPath。zkPath下面其實(shí)存放著ActiveMQ的節(jié)點(diǎn)煤蚌,在后續(xù)你會(huì)看到耕挨。
啟動(dòng)3臺(tái)機(jī)器上的ActiveMQ,然后利用ZooInspector你可以看到:
此時(shí)此刻尉桩,基于ZK的ActiveMQ的高可用方案就做好了筒占。那么JAVA端訪問ActiveMQ有什么變化么?其實(shí)就是在創(chuàng)建ConnectionFactory的時(shí)候給定的URL有變化:
failover:(tcp://192.168.99.121:61616,tcp://192.168.99.122:61616,tcp://192.168.99.123:61616)?Randomize=false
就是一個(gè)失敗轉(zhuǎn)移協(xié)議蜘犁!
上面只是做了一個(gè)ActiveMQ的高可用方案翰苫,那么ActiveMQ集群呢?其實(shí)所謂的ActiveMQ集群就是多個(gè)ActiveMQ高可用之間產(chǎn)生關(guān)聯(lián):
高可用的ActiveMQ-1,ActiveMQ-2,...,ActiveMQ-N就可以組建ActiveMQ集群
在配置上很簡單沽瘦,其實(shí)就是ActiveMQ-1要知道ActiveMQ-2的信息而已革骨,這里大家可以自行百度,不在演示了析恋。
整個(gè)ActiveMQ從入門到精通系列就結(jié)束了良哲,希望對大家有幫助!我們RocketMQ系列再見~