springboot整合rocketmq：一个消费者组怎么订阅多个topic-Toy模板网

这篇具有很好参考价值的文章主要介绍了springboot整合rocketmq：一个消费者组怎么订阅多个topic。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

一个消费者组中的所有消费者订阅关系，可以多个topic，多个tag，但是必须一致，否则就倒沫子了，如下图：

rocketmq订阅多个topic,java,开发语言,rocketmq

下面贴了如下结构的代码 rocketmq订阅多个topic,java,开发语言,rocketmq

一个消费组（消费者）订阅多个topic的代码（只写了一个消费组的，其他类似）：

@Component
@RocketMQMessageListener(topic = "",consumerGroup="group1")
public class MessageListener1 implements RocketMQListener<String>, RocketMQPushConsumerLifecycleListener {
    @Override
    public void onMessage(String str) {
    }

    @Override
    public void prepareStart(DefaultMQPushConsumer consumer) {
        try{
            consumer.subscribe("topic-a","*");
            consumer.subscribe("topic-b","*");
            consumer.registerMessageListener((List<MessageExt> messages, ConsumeConcurrentlyContext context) -> {
                    if (CollectionUtils.isNotEmpty(messages)) {
                        for (MessageExt message : messages) {
                            System.out.println(Thread.currentThread().getName()+"消费完成:"+message.getTopic()+ new String(message.getBody()));
                        }
                    }
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                });
            }catch (MQClientException e){
            e.printStackTrace();
        }
    }
}

结果：

rocketmq订阅多个topic,java,开发语言,rocketmq 文章来源地址https://www.toymoban.com/news/detail-612229.html