玩轉ActiveMQ叢集

如何搭建ActiveMQ叢集https://mp.weixin.qq.com/s/_zqBwzDcPJdGTzhxbCMQMQ

1.首先建立一個maven項目，然後引入activemq-client依賴和測試包

2.建立Test類 機器對應的消息端口；不然連接配接不上；預設端口是61616；由于搭建叢集我已經修改消息端口；這裡就不使用預設值；

String brokerUrl = "failover:(tcp://192.168.16.128:51516," +
                             "tcp://192.168.16.129:51517," +
                             "tcp://192.168.16.130:51518)?Randomize=false";
           

MQ生産者(Pub)具體代碼如下

MQ消費者（Sub）具體代碼如下

這裡消費者首先需要訂閱生産者；不然生産者生産的消息，消費者是得不到的；是以以上代碼先運作消費者代碼； 控制台消息

ActiveMQ 管理背景;這裡可以檢視到主題；說明測試成功；

以上代碼隻是測試連接配接ActiveMQ叢集，功能需求請不要按照這樣的方式寫；

▼長按以下二維碼即可關注▼

版權聲明：本文為CSDN部落客「weixin_33796205」的原創文章，遵循CC 4.0 BY-SA版權協定，轉載請附上原文出處連結及本聲明。

原文連結：https://blog.csdn.net/weixin_33796205/article/details/92406889