目录JAVA全系列 教程
3762个小节阅读：7090.5k
目录
C语言快速入门
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本，未来主流的版本
人工智能 教程
顺势而为，AI创新未来
大厂算法 教程
算法，程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
当使用广播消费模式时，每条消息推送给集群内所有的消费者，保证消息至少被每个消费者消费一次。
xxxxxxxxxx @Test public void consumer() throws MQClientException { DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("SimpleConsumer"); consumer.setNamesrvAddr("192.168.47.100:9876"); consumer.subscribe("Simple","*"); consumer.setMessageModel(MessageModel.BROADCASTING); consumer.setMessageListener(new MessageListenerConcurrently() { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) { for (int i = 0; i < list.size(); i++) { System.out.println(i+"_消息消费成功_"+ new String(list.get(i).getBody())); } return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); consumer.start(); System.out.println("consumer started.%n"); }实时效果反馈
1.在RocketMQ中关于广播消费模式说法正确的是______。
A 每条消息推送给集群内所有的消费者
B 每条消息推送给集群某一个的消费者
C 同一 Topic 下的多条消息只会被同一消费组中的一个消费者消费
D 以上都是错误
答案
1=>A