RocketMQListener如何使用

首先，你需要在你的项目中引入 RocketMQ 的相关依赖，例如：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>${rocketmq.version}</version>
</dependency>
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>${rocketmq.spring.boot.version}</version>
</dependency>

接着，你需要在 Spring Boot 启动类上添加 @EnableRocketMQ 注解，开启 RocketMQ 的自动配置功能。例如：

@SpringBootApplication
@EnableRocketMQ
public class RocketMQApplication {
    public static void main(String[] args) {
        SpringApplication.run(RocketMQApplication.class, args);
    }
}

然后，你需要编写一个消息监听器，实现 RocketMQListener 接口，并实现 onMessage 方法。例如：

@Component
@RocketMQMessageListener(topic = "test-topic", consumerGroup = "test-group")
public class TestListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

在该示例中，我们定义了一个名为 TestListener 的消息监听器，用于监听名为 test-topic 的主题下的消息。该监听器使用了 @RocketMQMessageListener 注解，指定了消费者组名为 test-group。在 onMessage 方法中，我们只是简单地打印了接收到的消息。

最后，你可以在其他地方发送消息到 test-topic 主题，TestListener 就会自动接收并处理消息。

需要注意的是，RocketMQListener 的类型参数需要与发送消息时的类型参数一致，如果你发送的是 JSON 字符串，则可以使用 RocketMQ 的 JSON 序列化器，将类型参数设置为 com.alibaba.fastjson.JSONObject。如果你需要处理其他类型的消息，可以自定义序列化器。