springboot 集成rocketmq多个topic怎么配置

Spring Boot 集成 RocketMQ 来使用多个 topic 的配置一般涉及几个步骤：

1. 首先，在项目中添加 Spring Boot 与 RocketMQ 的相关依赖。通常使用 Spring Boot Starter 来简化配置。在 pom.xml 文件中添加如下依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.2.0</version> <!-- 请使用最新的版本号 -->
</dependency>

2. 接下来，在 application.properties 或 application.yml 文件中配置 RocketMQ 连接信息，包括 NameServer 地址和 Producer/Consumer 的相关属性。如果有多个 topic，可以进行如下配置：

application.yml 示例：

rocketmq:
  name-server: 127.0.0.1:9876
  producer:
    group: producer_group_name
  consumer:
    group: consumer_group_name

3. 在配置文件中指定多个 topic。这可以通过配置 `rocketmq.producer.topics` 和 `rocketmq.consumer.topics` 来实现：

rocketmq:
  producer:
    topic:
      - topicNameA
      - topicNameB
  consumer:
    topic:
      - topicNameA
      - topicNameB

4. 根据需要配置 producer 和 consumer 的其他属性，比如发送消息模式（同步、异步、单向）、消息过滤模式、消费者重试次数等。

5. 在代码中使用 @RocketMQMessageListener 注解来监听特定的 topic。如果要监听多个 topic，可以在不同的类中使用相同的 Consumer Group 并添加 @RocketMQMessageListener 注解。

@RocketMQMessageListener(
    consumerGroup = "consumer_group_name",
    topic = "topicNameA",
    selectorExpression = "tagA"
)
public class TopicAListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        // 处理消息
    }
}

以上步骤仅提供了一个基础的配置示例。在实际应用中，你可能需要根据业务需求做更多的定制化配置。