1. 程式人生 > 實用技巧 >六、ActiveMQ的Broker

六、ActiveMQ的Broker

一、broker是什麼

  相當於一個ActiveMQ伺服器例項。說白了,Broker其實就是實現了用程式碼的形式啟動ActiveMQ將MQ嵌入到Java程式碼中,以便隨時用隨時啟動,在用的時候再去啟動這樣能節省了資源,也保證了可用性。這種方式,我們實際開發中很少採用,因為他缺少太多了東西,如:日誌,資料儲存等等。

二、啟動Broker時指定配置檔案

  啟動broker時指定配置檔案,可以幫助我們在一臺伺服器上啟動多個broker。實際工作中一般一臺伺服器只啟動一個broker。

三、嵌入式的Broker啟動

  用ActiveMQ Broker作為獨立的訊息伺服器來構建Java應用。ActiveMQ也支援在vm中通訊基於嵌入的broker,能夠無縫的整合其他java應用。

  下面演示如何啟動嵌入式的broker

  • pom.xml新增一個依賴
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.10.1</version>
</dependency>
  • 嵌入式broke的啟動類
public class EmbedBroker {

    public static void
main(String[] args) throws Exception { //ActiveMQ也支援在vm中通訊基於嵌入的broker BrokerService brokerService = new BrokerService(); brokerService.setPopulateJMSXUserID(true); brokerService.addConnector("tcp://127.0.0.1:61616"); brokerService.start(); } }