一、本文目的         介紹如何在同一臺虛擬機器上搭建高可用的Activemq服務，叢集數量包含3個Activemq，當Activemq可用數>=2時，整個叢集可用。         本文Activemq的叢集數量為3個，分別命名為mq1，mq2，mq3 二、概念介紹 1、偽叢集       叢集搭建在同一臺虛擬機器上，3個Activemq分別使用不同的埠提供服務，啟用1個為Master，其它2個為Slaver，同一時間僅Master佇列提供服務 2、高可用       3個Activemq服務,同一時間僅Master佇列提供服務，當Master佇列掛掉後，其它2個Slaver自動選舉出1個成為Master，整個佇列服務依然可用。當掛掉的佇列重新恢復後，自動加入叢集。當叢集僅剩下1個佇列時，整個佇列不可用。 3、Activemq叢集資料儲存方式       a) kahaDB：檔案共享，預設方式       b) JDBC：資料庫共享，支援MySql、Sql Server、Oracle等       c) LevelDB：資料共享，本文使用方式，比kahaDB更快，基於索引 三、Activemq偽叢集的搭建 1、Activemq的埠介紹       Activemq預設主要使用2個埠，8161(Web管理控制檯埠）、61616（提供訊息佇列服務的埠），如果需要搭建叢集，還需要開放叢集間通訊的埠（主要用於選舉Master） 2、Activemq叢集埠的分配

Web管理控制檯	訊息服務介面	叢集通訊介面
mq1	8161	51511	61601
mq2	8162	51512	61602
mq3	8163	51513	61603

服務介面沒有使用預設的61611是因為activemq預設還會使用61613,61614等埠，如何開放埠及配置控制檯埠請自行百度 3、修改activemq配置 a) 安裝activemq，本文使用Activemq版本為5.11.1，安裝過程略 b) 修改配置檔案activemq.xml，路徑為conf/activemq.xml      1、broker（所有activemq的brokerName必須一致，才能加入同一個叢集）

1	<broker xmlns= brokerName="V1MQ" dataDirectory="${activemq.data}">

    2、配置levelDB，載入<broker>節點內

           bind：叢集間通訊的ip和埠

           zkAddress：ZooKeeper地址，多個可用，逗號分隔

           hostname：主機名，可在/etc/hosts中進行配置

           zkPath：zkPath目錄，可在ZooInspetor中進行檢視

1 2 3 4 5 6 7 8 9 10 11

<persistenceAdapter> <!-- kahaDB directory="${activemq.data}/kahadb"/ --> <replicatedLevelDB directory="${activemq.data}/leveldb" replicas="3" zkAddress="192.168.146.130:2181" hostname="V1" zkPath="/activemq/leveldb-stores" /> </persistenceAdapter>

4、啟動activemq

      /usr/local/src/activemq1/bin/activemq start

      可通過/usr/local/src/activemq1/data/activemq.log檢視啟動日誌

5、關於管控臺

       雖然3個activemq都啟動了，但是同一時間只有Master對應的管控臺可用，Slaver對應的管控臺不可用

四、結合ZooInspector測試（推薦使用dubbokeeper中檢視zookeeper的一個UI外掛，https://github.com/dubboclub/dubbokeeper）

1、開啟ZooInspector（可自行搜尋下載或從群中下載），輸入ZooKeeper地址進行監控，如果3個activemq都啟動成功，則顯示如下：

2、Java測試程式碼

       a) 配置叢集IP（這裡3個activemq的埠分別是51511,51512,51513）

1 2 3 4 5 6 7 8

<!-- 配置JMS連線工廠 --> <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <!--解決接收訊息丟擲異常：javax.jms.JMSException: Failed to build body from content. Serializable class not available to broke--> <property name="trustAllPackages" value="true"/> <!-- 是否非同步傳送 --> <property name="useAsyncSend" value="true" /> </bean>

        b)  測試程式碼

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20

@Test public void produceMsg_DefaultQueue() { for (int i = 0; i < 10000; i++) { final String msg ="序號："+String.valueOf(i) + " " +"這裡是向預設佇列傳送的訊息" + new Date().toString(); System.out.println(msg); String destination = jmsTemplate.getDefaultDestination().toString(); jmsTemplate.send(new MessageCreator() { public Message createMessage(Session session) throws JMSException { return session.createTextMessage(msg); } }); try { Thread.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } } }

3、啟動Java程式併發送訊息

4、關閉Master佇列（注意此時的Master佇列為mq2）

a)   此時的ZooInspetor

5、重啟mq2佇列（重啟後mq2加入佇列成為Slaver，但是mq1還是Master，佇列不受影響）

6、關閉mq1、mq2，僅剩mq3（由於只有一個佇列，無法進行選舉，所以整個佇列都無法提供服務）

7、重啟mq1（重啟mq1後，mq1和mq3選舉了Master佇列，從而重新對外提供服務）

a) ZooInspecto顯示mq1被選舉為Master

b) 程式重新向佇列訊息，資料並沒有中斷 

五、總結

        本文演示了activemq偽叢集的搭建過程及高可用的測試過程，通過舉一反三可以將activemq部署到不同的機器上，從而實現相同的功能。

        遺留問題：ZooInspetor的activemq編號是自動生成的，很難發現其對應的佇列，請問有沒有可以自定義編號的方法，謝謝。

六、參考資料