JAVA全系列 教程
3762个小节阅读:7089.4k
目录
C语言快速入门
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
什么是集群消费
同一 Topic 下的一条消息只会被同一消费组中的一个消费者消费。也就是说,消息被负载均衡到了同一个消费组的多个消费者实例上。
xxxxxxxxxx
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("SimpleConsumer");
consumer.setNamesrvAddr("192.168.47.100:9876");
consumer.subscribe("SimpleMessageTest","*");
consumer.setMessageModel(MessageModel.CLUSTERING);
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();
Thread.sleep(Integer.MAX_VALUE);
实时效果反馈
1.在RocketMQ中关于集群消费模式说法正确的是______。
A 同一 Topic 下的一条消息只会被同一消费组中的一个消费者消费
B 同一 Topic 下的一条消息只会被同一消费组中的多个消费者消费
C 同一 Topic 下的多条消息只会被同一消费组中的一个消费者消费
D 以上都是错误
答案
1=>A