ActiveMQ 安裝

linux 安裝

• 安裝很簡單，ActiveMQ就是用Java寫的。是以，隻要linux環境下有java 1.8的環境，将activemq的包下下來，就能直接打開用了。
• 官網下載下傳
• 或者在linux環境下，用wget操作

  wget https://mirrors.bfsu.edu.cn/apache//activemq/5.15.15/apache-activemq-5.15.15-bin.tar.gz
             

• 解壓

  tar -xvzf apache-activemq-5.15.15-bin.tar.gz
             

• 進入bin檔案夾，開啟服務

  ./activemq start
             

• 也可以讓它的輸出儲存在一個檔案裡面，當成一個日志檔案

  ./activemq start > /myactivemq/run_activemq.log
             

• 也可以針對某個配置檔案，開啟服務

  ./activemq start xbean:file/myactivemq/apache-activemq-5.15.9/conf/activemq.xml
             

• 檢視是否開啟，也有三個指令。（預設占用端口是61616）

  ps -ef | grep activemq
  netstat -anp | grep 61616
  lsof -i:61616
             

• 至此，在linux上開啟了服務
• ActiveMQ官方開發了一個網頁版的運維管理頁面，我們可以直接通過HTTP通路伺服器，了解目前MQ的情況
• 首先，擷取目前伺服器的ip位址

  ifconfig
             

• 擷取ip位址之後，我們可以通過浏覽器打開管理頁面。預設端口是

  8161

  ，帳号密碼都是

  admin

  

2. 嵌入式的broker

• broker，可以簡單了解為一個Active MQ伺服器執行個體。一個broker對外就是一個Active MQ伺服器執行個體，當然為了保險起見，它可以由多個主從伺服器組成。
• 而為了友善起見，其實我們也可以直接在自己的Java工程中，嵌入一個broker，對外就是一個簡單的Active MQ執行個體。

2.1 實作

• 引入依賴

  <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-databind</artifactId>
      <version>2.10.1</version>
  </dependency>
             

• 寫一個broker的啟動類

  public class EmbedBroker {
    public static void main(String[] args) throws Exception {
      BrokerService brokerService = new BrokerService();  // 建立一個broker服務
      brokerService.setPopulateJMSXUserID(true);
      brokerService.addConnector("tcp://127.0.0.1:61616"); // 設定ip和端口号
      brokerService.start();
    }
  }
             

• 就此，完成了一個簡單的broker，隻要修改一下平時代碼的位址部分，就可以直接使用了。