springboot整合rocketmq：一个消费者组怎么订阅多个topic

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

下面贴了如下结构的代码

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

@Component
@RocketMQMessageListener(topic = "",consumerGroup="group1")
public class MessageListener1 implements RocketMQListener<String>, RocketMQPushConsumerLifecycleListener {@Overridepublic void onMessage(String str) {}@Overridepublic 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();}}
}

结果：

springboot整合rocketmq：一个消费者组怎么订阅多个topic相关推荐

Springboot整合Rocketmq系列教程
Springboot整合Rocketmq系列教程本教程是基于Springboot2.6.3整合Rocketmq5.0,其中涉及了Rocketmq的安装,消息的发送及消费的代码实现. 本文不会对roc ...
springboot整合rocketMQ记录实现发送普通消息，延时消息
一.为什么选择RocketMQ消息队列?(可跳过看三的整合代码实例) 首先RocketMQ是阿里巴巴自研出来的,也已开源.其性能和稳定性从双11就能看出来,借用阿里的一句官方介绍:历年双 11 购物狂 ...
Springboot整合RocketMQ实战
本文来说下Springboot如何整合RocketMQ. 文章目录概述 Springboot整合RocketMQ 引入pom依赖 yaml文件简单实例本文小结概述消息队列rocketmq是A ...
RocketMQ 实战-SpringBoot整合RocketMQ
1. 消息生产者 1.1 maven 依赖 <?xml version="1.0" encoding="UTF-8"?> <project x ...
springboot整合rocketmq，支持多连接生产者和消费者配置。不同topic适配不同业务处理类
1.代码仓库 rocketmq版本4.5.2 直接上代码,下面再逐步讲解,仓库地址本地启动后,访问swagger地址测试,http://127.0.0.1:8099/mq/swagger-ui/in ...
SpringBoot整合RocketMQ
0. 启动Name Server与 Broker 1. 引入依赖添加 RocketMQ 客户端访问支持,具体版本和安装的 RocketMQ 版本一致即可. <dependency>< ...
SpringBoot整合RocketMQ，三种测试附带源码【rocketmq-spring-boot-starter】
我们整合boot项目的时候都是引入 xxx-start 依赖,但是现在大多数的整合RocketMQ都还不是这样. 我花了一天时间使用rocketmq-spring-boot-starter整合,使得操 ...
SpringBoot整合RocketMQ报错：“PullMessageService“ NoClassDefFoundError xxx/protocol/FastCodesHeader解决
问题阐述学习RocketMQ到整合SpringBoot时,遇到问题,以下问题排除: 配置完整性(很多博文都会跳到group组名未定义问题) 服务器/虚拟机,防火墙或外网设置问题(请先去玩玩客户端发送 ...
RocketMQ 实战-SpringBoot整合RocketMQ同步消息、异步消息、单向消息
官方样例:https://gitee.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md 1. 同步消息 producer向 bro ...

springboot整合rocketmq：一个消费者组怎么订阅多个topic

springboot整合rocketmq：一个消费者组怎么订阅多个topic相关推荐

最新文章

热门文章