消息消費者

1）添加依賴

同消息生產者

2）配置文件

同消息生產者

3）啟動類

@SpringBootApplication public class MQConsumerApplication {public static void main(String[] args) {SpringApplication.run(MQSpringBootApplication.class);} }

4）消息監聽器

@Slf4j @Component @RocketMQMessageListener(topic = "springboot-mq",consumerGroup = "springboot-mq-consumer-1") public class Consumer implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {log.info("Receive message："+message);} }

?

總結

以上是生活随笔為你收集整理的springboot集成rocketmq消费者的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。