消息隊列--ActiveMQ集群部署


 

 

 

   

一、activeMQ主要的部署方式?

  1,默認的單機部署(kahadb)

    activeMQ默認的存儲單機模式,如果配置文件不做修改,則默認使用此模式。以本地的kahadb文件的方式進行存儲,性能完全依賴本地磁盤,不能提供高可用。

  2,基於zookeeper主從模式(levelDB Master/Slave)

    基於zookeeper來選舉一個master,其他節點作為slave實時同步消息,levelDB會優先采用內存存儲消息,異步同步到磁盤。該方式讀寫性能都較好,寫性能能媲美非持久化消息。

    優點:實現高可用和數據安全,性能較好。

    缺點:由於zookeeper的選舉機制,必須要使用2n+1(n>=1)的節點,才能實現高可用。

  3,基於共享數據庫的主從模式(Shared JDBC Master/Slave)

    可以基於常用的mysql,mariadb,oracle等數據庫。

    每個節點啟動都會爭搶數據庫鎖,從而保證master的唯一性,其他節點作為備份,一直等待數據庫鎖的釋放。

              因為所有消息讀寫,其實都是數據庫操作,activeMQ節點本身壓力很小,性能完全取決於數據庫性能。

    優點:實現高可用和數據安全,一般兩個節點就可以實現高可用。

    缺點:性能和穩定性都依賴於數據庫。

 

二、基於zookeeper的activeMQ單台服務器集群部署

  1,環境需求

    Centos7系統,java環境(jdk),zookeeper安裝包,activeMQ安裝包

  2,部署jdk環境

    jdk安裝包下載地址:https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

    

    上面這個是最新版的,我使用的是jdk-8u121-linux-x64.tar.gz。

    2.1  上傳壓縮包到服務器,在當前有壓縮包的目錄下進行操作。

    2.2  創建文件夾

      mkdir /application

    2.3  解壓壓縮包(根據你自己的包名進行修改)

      tar xf jdk-8u121-linux-x64.tar.gz  -C /application/

    2.4  創建軟鏈接(根據你自己的包名進行修改)

      ln -s /application/jdk1.8.0_121/ /application/jdk

    2.5  配置環境變量

      vim /etc/profile

      在最后面添加這么幾行:

      export JAVA_HOME=/application/jdk

      export PATH=$JAVA_HOME/bin:$JAVA_HOME/jre/bin:$PATH

      export CLASSPATH=.:$JAVA_HOME/lib:$JAVA_HOME/jre/lib:$JAVA_HOME/lib/tools.jar

    2.6  使環境變量生效

      source /etc/profile

    2.7  查看jdk配置情況

      命令行輸入 java -version  顯示:

      

      則配置成功。

 

  3,安裝zookeeper單機集群

    3.1  獲取zookeeper安裝包

      wget https://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz

    3.2  安裝配置(配置3個)

      3.2.1  生成3個文件

        tar xf zookeeper-3.4.14.tar.gz -C /usr/local/zookeeper1

        tar xf zookeeper-3.4.14.tar.gz -C /usr/local/zookeeper2

        tar xf zookeeper-3.4.14.tar.gz -C /usr/local/zookeeper3

           3.2.2  修改 zookeeper1 的配置文件(我的內網地址是172.16.1.8)

        cd /usr/local/zookeeper1/conf

        cp zoo_sample.cfg zoo.cfg

        vim zoo.cfg

        將文件里面的內容清空,后加入以下內容

                             tickTime=2000

        initLimit=10

        syncLimit=5

        dataDir=/usr/local/zookeeper1/data        文件存放位置

        clientPort=2181                                       端口

        server.1=172.16.1.8:2881:3881              第一個節點IP和端口(使用內網)

        server.2=172.16.1.8:2882:3882              第二個節點IP和端口

        server.3=172.16.1.8:2883:3883              第三個節點IP和端口

      3.2.3  創建 zookeeper1 的 myid 文件

        cd /usr/local/zookeeper1

        mkdir data

        echo "1" >  /usr/local/zookeeper1/data/myid

      3.2.4  修改 zookeeper2 的配置文件

        cd /usr/local/zookeeper2/conf

        cp zoo_sample.cfg zoo.cfg

        vim zoo.cfg

        將文件里面的內容清空,后加入以下內容

                             tickTime=2000

        initLimit=10

        syncLimit=5

        dataDir=/usr/local/zookeeper2/data        文件存放位置

        clientPort=2182                                       端口

        server.1=172.16.1.8:2881:3881              第一個節點IP和端口(使用內網)

        server.2=172.16.1.8:2882:3882              第二個節點IP和端口

        server.3=172.16.1.8:2883:3883              第三個節點IP和端口

      3.2.5  創建 zookeeper1 的 myid 文件

        cd /usr/local/zookeeper2

        mkdir data

        echo "2" >  /usr/local/zookeeper2/data/myid

      3.2.6  修改 zookeeper3 的配置文件

        cd /usr/local/zookeeper3/conf

        cp zoo_sample.cfg zoo.cfg

        vim zoo.cfg

        將文件里面的內容清空,后加入以下內容

                             tickTime=2000

        initLimit=10

        syncLimit=5

        dataDir=/usr/local/zookeeper3/data        文件存放位置

        clientPort=2183                                       端口

        server.1=172.16.1.8:2881:3881              第一個節點IP和端口(使用內網)

        server.2=172.16.1.8:2882:3882              第二個節點IP和端口

        server.3=172.16.1.8:2883:3883              第三個節點IP和端口

      3.2.7  創建 zookeeper1 的 myid 文件

        cd /usr/local/zookeeper3

        mkdir data

        echo "3" >  /usr/local/zookeeper3/data/myid

      3.2.8  啟動zookeeper集群

        /usr/local/zookeeper1/bin/zkServer.sh start

        /usr/local/zookeeper2/bin/zkServer.sh start

        /usr/local/zookeeper3/bin/zkServer.sh start

      3.2.9  查看zookeeper集群狀態

        /usr/local/zookeeper1/bin/zkServer.sh status

       

       

       其中,follower是跟隨者,leader為領導者。

 

  4,部署單台服務器activeMQ集群

    4.1  下載activeMQ安裝包

      下載地址為:http://mirror.bit.edu.cn/apache//activemq/5.15.9/apache-activemq-5.15.9-bin.tar.gz

    4.2  創建3個文件目錄(3個)

      tar xf apache-activemq-5.15.9-bin.tar.gz

      cp -r apache-activemq-5.15.9 /application/activemq1

      cp -r apache-activemq-5.15.9 /application/activemq2

      cp -r apache-activemq-5.15.9 /application/activemq3

    4.3  分別修改 activemq1、activemq2、activemq3的配置文件

      4.3.1  修改 activemq1、activemq2、activemq3的  jetty.xml 文件

         vim /application/activemq1/conf/jetty.xml

         

         vim /application/activemq2/conf/jetty.xml

         

         vim /application/activemq3/conf/jetty.xml

         

      4.3.2  修改 activemq1、activemq2、activemq3的  activemq.xml  文件

         vim /application/activemq1/conf/activemq.xml   

         將 <persistenceAdapter> 文件的內容修改成以下內容:

         

         將 <transportConnectors> 文件中的url修改,如果一樣則無需修改

            

         3個配置文件中的brokeName一定要一致(3個文件都要修改)

         

         vim /application/activemq2/conf/activemq.xml 

            將 <persistenceAdapter> 文件的內容修改成以下內容:

          

         將 <transportConnectors> 文件中的url修改,如果一樣則無需修改

         

         vim /application/activemq3/conf/activemq.xml 

          將 <persistenceAdapter> 文件的內容修改成以下內容:

         

         將 <transportConnectors> 文件中的url修改,如果一樣則無需修改

         

      4.3.3  啟動集群(那個先啟動,就是Master)

         /application/activemq1/bin/activemq start

         /application/activemq2/bin/activemq start

         /application/activemq3/bin/activemq start

      4.3.4  查看啟動日志

         tail -fn 100 /application/activemq1/data/activemq.log

         master啟動:

            

         slave啟動:

         

         登錄服務器驗證:

         輸入公網ip,加master端口訪問:

         

 

 

 

      

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM