玩转ActiveMQ集群
Posted 木子道
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了玩转ActiveMQ集群相关的知识，希望对你有一定的参考价值。
---2018年已经过去116天---
如何搭建ActiveMQ集群
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集群，功能需求请不要按照这样的方式写；
▼长按以下二维码即可关注▼
以上是关于玩转ActiveMQ集群的主要内容，如果未能解决你的问题，请参考以下文章