springboot rocketmq 监听

要在 Spring Boot 中使用 RocketMQ 监听消息，需要按照以下步骤进行设置：

1. 添加 RocketMQ 的依赖

在 `pom.xml` 文件中添加以下依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.1.1</version>
</dependency>

2. 配置 RocketMQ

在 `application.properties` 文件中添加以下配置：

rocketmq.name-server=your.nameserver.addr:9876

3. 编写消息监听器

创建一个 `RocketMQListener` 类，实现 `RocketMQListener<T>` 接口，并在 `onMessage` 方法中处理消息。例如：

@Component
public class DemoRocketMQListener implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
        // 处理消息
    }
}

4. 注册消息监听器

在 `@RocketMQMessageListener` 注解中设置 `topic` 和 `consumerGroup`，并将监听器类作为 `consumerBeanRef` 参数传递。

@RocketMQMessageListener(topic = "test-topic", consumerGroup = "test-group", consumerBeanRef = "demoRocketMQListener")
@Component
public class DemoRocketMQListener implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
        // 处理消息
    }
}

现在，当 RocketMQ 接收到 `test-topic` 主题中的消息时，`DemoRocketMQListener` 类中的 `onMessage` 方法将被调用。