@RocketMqMessageLister 注解消费者代码示例
时间: 2023-10-05 12:07:21 浏览: 34
下面是一个使用 `@RocketMqMessageListener` 注解消费者的示例代码:
```java
import org.apache.rocketmq.spring.annotation.RocketMqMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
@Component
@RocketMqMessageListener(topic = "testTopic", consumerGroup = "testGroup")
public class TestConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
在上面的代码中,我们定义了一个名为 `TestConsumer` 的消费者类,并使用 `@RocketMqMessageListener` 注解标注该类为 RocketMQ 消费者。其中,`topic` 参数指定了消费者订阅的主题名称,`consumerGroup` 参数指定了消费者所属的消费组名称。
另外,我们还实现了 `RocketMQListener` 接口,并重写了其中的 `onMessage` 方法。该方法会在消费者接收到消息时被调用,我们可以在该方法中处理消息。
需要注意的是,使用 `@RocketMqMessageListener` 注解消费者时,消费者类必须被 Spring 所管理,因此我们还需要在消费者类上添加 `@Component` 注解。