這是ActiveMQ系列的最后一篇文章，主要是關(guān)于ActiveMQ集群，這里采用的方式是：Zookeeper+LevelDB+ActiveMQ。前面2篇博客地址如下：《ActiveMQ從入門到精通（一）》、《ActiveMQ從入門到精通（二）》。
利用Zookeeper實(shí)現(xiàn)ActiveMQ的高可用
話不多說(shuō)，先來(lái)看一張ActiveMQ官方提供的架構(gòu)圖：
Master/Slave broker的信息要注冊(cè)到ZK
注意到只有Master對(duì)外提供了服務(wù)，Slave是待機(jī)狀態(tài)。當(dāng)Master出現(xiàn)故障，ZK內(nèi)部的選舉機(jī)制，會(huì)讓一個(gè)Slave升級(jí)成Master對(duì)外提供服務(wù)。
關(guān)于ZK，以后博主會(huì)有專題進(jìn)行介紹，這里不做詳細(xì)講解，只需要了解通過(guò)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)境變量呢？很簡(jiǎn)單，我想在命令行下直接使用ZK相關(guān)的命令，而不是進(jìn)入到安裝ZK目錄下的bin，更不想用絕對(duì)路徑。
注意dataDir目錄的指定；注意2181是外部訪問(wèn)ZK的端口；
2888:3888是ZK集群內(nèi)部通信（比如ZK原子廣播消息）的端口，注意server.X的定義，這是將ZK集群中的實(shí)例進(jìn)行編號(hào)，實(shí)際上需要在dataDir目錄中新建myid文件，并與之保持一致。
第三步：?jiǎn)?dòng)ZK
可以通過(guò)netstat命令查看2722進(jìn)程，發(fā)現(xiàn)ZK的端口是2181，這和zoo.cfg的配置是一致的。讓3臺(tái)機(jī)器的ZK都啟動(dòng)起來(lái)。
第四步：ActiveMQ主從配置
注意了，由于我將在3臺(tái)物理機(jī)上搭建一臺(tái)Master，2臺(tái)Slave，因此我這邊不需要對(duì)端口配置文件進(jìn)行改動(dòng)。比如WEB管控臺(tái)的jetty.xml。
3臺(tái)機(jī)器應(yīng)該對(duì)外只有一個(gè)統(tǒng)一的名稱，就是這個(gè)brokerName。3臺(tái)機(jī)器都修改成一個(gè)名稱即可。
這里持久化，我將采用LevelDB，因此需要修改持久化配置：
注意bind地址，其實(shí)是ActiveMQ集群內(nèi)部通信的TCP端口，和ActiveMQ對(duì)外提供的消息端口（默認(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端訪問(wèn)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集群
在配置上很簡(jiǎn)單，其實(shí)就是ActiveMQ-1要知道ActiveMQ-2的信息而已，這里大家可以自行百度，不在演示了。
整個(gè)ActiveMQ從入門到精通系列就結(jié)束了，希望對(duì)大家有幫助！我們RocketMQ系列再見~
