玩转ActiveMQ集群

时间 2019-11-15 标签 activemq 集群

如何搭建ActiveMQ集群https://mp.weixin.qq.com/s/_zqBwzDcPJdGTzhxbCMQMQjava

1.首先新建一个maven项目，而后引入activemq-client依赖和测试包 dom

2.新建Test类机器对应的消息端口；否则链接不上；默认端口是61616；因为搭建集群我已经修改消息端口；这里就不使用默认值；maven

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)具体代码以下tcp

MQ消费者（Sub）具体代码以下测试

这里消费者首先须要订阅生产者；否则生产者生产的消息，消费者是得不到的；因此以上代码先运行消费者代码；控制台消息 code

ActiveMQ 管理后台;这里能够查看到主题；说明测试成功；图片

以上代码只是测试链接ActiveMQ集群，功能需求请不要按照这样的方式写；get

▼长按如下二维码便可关注▼it