广播消息：
一个点发送，所有有监听订阅的程序都能收到消息。
应用场景：一个配置更新了，其他点都需要知道配置更新需加载。
mq创建
主要是创建组时与队列有点区别
mqadmin updateSubGroup -c rocketmq-cluster -d true -g broad-string-consumer -n "192.168.3.252:9876;192.168.3.253:9876" mqadmin updateSubGroup -c rocketmq-cluster -d true -g broad-string-consumer -n "192.168.3.252:9876;192.168.3.253:9876"
mqadmin updateTopic -c rocketmq-cluster -t TOPIC-SYS-ACC-BIZ-BROADCAST
mqadmin updateSubGroup -c rocketmq-cluster -d true -g GID-ACC-BIZBROADCAST
生产者
产生消息与产生普通消息一样
@Component public class RocketTest extends BaseTest{ @Autowired private AccBizSender accBizSender; @Test public void accBizSenderTest() throws Exception { for (int i=0;i<10;i++) { BaseMqRequest baseMqRequest = new BaseMqRequest(); baseMqRequest.setBizType("sendTest"); baseMqRequest.setData("{i="+i+"}"); accBizSender.sendMessageBroadcast(baseMqRequest); } MyDateUtil.sleep(1000000); } }
消费者
消息模式必须指定
messageModel = MessageModel.BROADCASTING
import org.apache.rocketmq.spring.annotation.MessageModel; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.springframework.stereotype.Component; import com.ccjr.commons.constants.RocketMqConstants; import lombok.extern.slf4j.Slf4j; @Slf4j @Component @RocketMQMessageListener(topic = RocketMqConstants.TOPIC_SYS_ACC_BIZ_BROADCAST, consumerGroup = RocketMqConstants.G_TAG_ACC_BIZBROADCAST, selectorExpression = RocketMqConstants.TAG_ACC_BIZBROADCAST, messageModel = MessageModel.BROADCASTING) public class AccBizListener extends BaseListener { @Override public void onMessageExec(String boContext) { super.initMqMsg(RocketMqConstants.TOPIC_SYS_ACC_BIZ_BROADCAST, RocketMqConstants.G_TAG_ACC_BIZBROADCAST, RocketMqConstants.TAG_ACC_BIZBROADCAST); log.info("接收广播消息ACC：："+boContext); } }
测试结果：
系统A： 2022-11-14 11:21:10.343 INFO 2740 [ti:4af8db59ad8a] -- [MessageThread_4] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=3}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:14daff420a85] -- [MessageThread_1] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=0}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:59c55d117568] -- [essageThread_10] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=9}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:cd8331a33522] -- [MessageThread_7] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=6}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:c06c620aed6f] -- [MessageThread_2] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=1}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:8649c25fb46b] -- [MessageThread_5] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=4}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:77cfbf7db01a] -- [MessageThread_3] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=2}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:28c5eee7b43c] -- [MessageThread_8] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=7}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:9e346a603f5c] -- [MessageThread_9] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=8}"} 2022-11-14 11:21:10.343 INFO 2740 [ti:67c235b561e4] -- [MessageThread_6] c.ccjr.cus.mq.listerner.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=5}"} 系统B： 2022-11-14 11:21:10.346 INFO 4936 [ti:43e2a62170b5] -- [MessageThread_1] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=1}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:8e5713c22a14] -- [MessageThread_7] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=6}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:9354a92f3f36] -- [MessageThread_9] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=8}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:f1b44a0ba79c] -- [MessageThread_5] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=4}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:09acbaf4b249] -- [MessageThread_6] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=5}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:00d1ed751683] -- [MessageThread_4] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=3}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:4f378ca6e336] -- [essageThread_10] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=9}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:ae09aaa74d79] -- [MessageThread_3] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=2}"} 2022-11-14 11:21:10.346 INFO 4936 [ti:8102a4dc4d15] -- [MessageThread_2] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=0}"} 2022-11-14 11:21:10.348 INFO 4936 [ti:2fe1bf33a5b6] -- [MessageThread_8] c.c.acc.biz.mq.listener.AccBizListener : 接收广播消息ACC：：{"bizType":"sendTest","data":"{i=7}"}
原文地址：http://www.cnblogs.com/a393060727/p/16889024.html
1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！
2. 分享目的仅供大家学习和交流，请务用于商业用途!
3. 如果你也有好源码或者教程，可以到用户中心发布，分享有积分奖励和额外收入！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！
5. 如有链接无法下载、失效或广告，请联系管理员处理！
6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！
7. 如遇到加密压缩包，默认解压密码为"gltf",如遇到无法解压的请联系管理员！
8. 因为资源和程序源码均为可复制品，所以不支持任何理由的退款兑现，请斟酌后支付下载
声明：如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性
