六、ActiveMQ的Broker
阿新 • • 發佈:2021-01-11
一、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 voidmain(String[] args) throws Exception { //ActiveMQ也支援在vm中通訊基於嵌入的broker BrokerService brokerService = new BrokerService(); brokerService.setPopulateJMSXUserID(true); brokerService.addConnector("tcp://127.0.0.1:61616"); brokerService.start(); } }