三臺centos7伺服器。

1.開始前的準備ZK

必須安裝zookeeper群集才能實現三臺MQ連結。具體ZK群集搭建網上有很多 這裡就不詳談 簡單說下過程：

在zk1，zk2，zk3的目錄下，建立data目錄。

修改zk1,zk2,zk3的配置檔案。cp zoo_sample.cfg zoo.cfg

然後進入配置檔案zoo.cfg 將dataDir=/*/*/*/data改成data目錄

然後在最後加入

server.1=ip:2888:3888

server.2=ip:2888:3888

server.3=ip:2888:3888

還有一步，就是在zk1，zk2，zk3的data（這個data目錄也是自己建立的）下面建立一個檔案myid，內容就是zoo.cfg中的伺服器server.x中的數字1,2,3。

最後啟動即可。。

這個比較簡單，在三臺機器上安裝active MQ。
主要的修改配置檔案，就是activemq.xml。

下面以操作mq1為例

2.然後開始配置active MQ群集：

這個比較簡單，我在三臺機器上安裝AMQ。
主要的修改配置檔案，就是activemq.xml

進入mq1目錄，vim activemq.xml檔案。我們這裡amq的叢集是基於zk的，所以，不要預設的持久化方案。即將原始的

<persistenceAdapter>
      <kahaDB directory="${activemq.data}/kahadb"/>
</persistenceAdapter>

註釋掉，採用下面的新內容：

<persistenceAdapter>
    <replicatedLevelDB 
　　directory="${activemq.data}/leveldb"
　　replicas="3"
　　bind="tcp://0.0.0.0:0"
　　zkAddress="10.90.7.10:2181,10.90.7.10:2182,10.90.7.10:2183"
　　hostname="10.90.7.10"
　　sync="local_disk"
　　zkPath="/activemq/leveldb-stores"
　　/>
</persistenceAdapter>

這裡，hostname要修改為amq所在機器的IP地址，或者是能夠解析的域名。zkAddress是zk叢集的地址，即每個zk的IP：port對，之間用逗號分隔。zkPath這裡是指定的，所以，在上面的zkCli.sh中可以ls命令看到的內容。

。。。。。。
    <broker xmlns="http://activemq.apache.org/schema/core" brokerName="tkcss" dataDirectory="${activemq.data}">

        <destinationPolicy>
            <policyMap>
              <policyEntries>
                <policyEntry topic=">" >
                    <!-- The constantPendingMessageLimitStrategy is used to prevent
                         slow topic consumers to block producers and affect other consumers
                         by limiting the number of messages that are retained
                         For more information, see:

                         http://activemq.apache.org/slow-consumer-handling.html

                    -->
                  <pendingMessageLimitStrategy>
                    <constantPendingMessageLimitStrategy limit="1000"/>
                  </pendingMessageLimitStrategy>
                </policyEntry>
              </policyEntries>
            </policyMap>
        </destinationPolicy>


        <!--
            The managementContext is used to configure how ActiveMQ is exposed in
            JMX. By default, ActiveMQ uses the MBean server that is started by
            the JVM. For more information, see:

            http://activemq.apache.org/jmx.html
        -->
        <managementContext>
            <managementContext createConnector="false"/>
        </managementContext>

        <!--
            Configure message persistence for the broker. The default persistence
            mechanism is the KahaDB store (identified by the kahaDB tag).
            For more information, see:

            http://activemq.apache.org/persistence.html
        -->
        <!--
        <persistenceAdapter>
            <kahaDB directory="${activemq.data}/kahadb"/>
        </persistenceAdapter>
        -->

        <persistenceAdapter>
            <replicatedLevelDB 
                directory="${activemq.data}/leveldb"
                replicas="3"
                bind="tcp://0.0.0.0:0"
                zkAddress="10.90.7.10:2181,10.90.7.10:2182,10.90.7.10:2183"
                hostname="10.90.7.10"
                sync="local_disk"
               zkPath="/activemq/leveldb-stores"
           />
        </persistenceAdapter>
。。。。。。

配置完成後，即可啟動amq。

[[email protected] bin]# ./activemq start

啟動後，如果正常的話 會啟動一個MQ 而另外兩個沒顯示啟動  等啟動MQ死掉後 另外兩個會自動選舉