玩轉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集羣，功能需求請不要按照這樣的方式寫；

▼長按如下二維碼便可關注▼