脚本宝典收集整理的这篇文章主要介绍了rocketmq广播消息的（五），脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。
广播消费指的是：一条消息被多个consumer消费，即使这些consumer属于同一个ConsumerGroup,消息也会被ConsumerGroup中的每个Consumer都消费一次，广播消费中ConsumerGroup概念可以认为在消息划分方面无意义。
/** * 发布订阅消息生产者 */ public class BroadcastProducer { public static void main(String[] args) throws MQClientException, InterruptedException, RemotingException, MQBrokerException, UnsupportedEncodingException { // 1. 创建生产者对象 DefaultMQProducer producer = new DefaultMQProducer("GROUP_TEST"); // 2. 设置NameServer的地址，如果设置了环境变量NAMESRV_ADDR，可以省略此步 producer.setNamesrvAddr("192.168.32.128:9876"); // 3. 启动生产者 producer.start(); // 4. 生产者发送消息 for (int i = 0; i < 10; i++) { Message message = new Message("TopicTest", "TagA", "OrderID_" + i, ("Hello Broadcast:" + i).getBytes(RemotingHelper.DEFAULT_CHARSET)); SendResult result = producer.send(message); System.out.printf("发送结果：%s%n", result); } // 5. 停止生产者 producer.shutdown(); } }
/** * 发布订阅消息生产者 */ public class BroadcastProducer { public static void main(String[] args) throws MQClientException, InterruptedException, RemotingException, MQBrokerException, UnsupportedEncodingException { // 1. 创建生产者对象 DefaultMQProducer producer = new DefaultMQProducer("GROUP_TEST"); // 2. 设置NameServer的地址，如果设置了环境变量NAMESRV_ADDR，可以省略此步 producer.setNamesrvAddr("192.168.32.128:9876"); // 3. 启动生产者 producer.start(); // 4. 生产者发送消息 for (int i = 0; i < 10; i++) { Message message = new Message("TopicTest", "TagA", "OrderID_" + i, ("Hello Broadcast:" + i).getBytes(RemotingHelper.DEFAULT_CHARSET)); SendResult result = producer.send(message); System.out.printf("发送结果：%s%n", result); } // 5. 停止生产者 producer.shutdown(); } }
以上是脚本宝典为你收集整理的rocketmq广播消息的（五）全部内容，希望文章能够帮你解决rocketmq广播消息的（五）所遇到的问题。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。