- 在启动类HelloApplication上加上注解 @EnableRocketMq
- 在配置文件上填写相关配置
rocketmq:
# NameServer地址 若是集群,用;作为地址的分隔符
namesrvAddr: 127.0.0.1:9876
# 生产者的组名
producerId: hello
- 发布消息,请查看ProducerTest 类,增加了自定义的类RocketProducerService 进一步封装DefaultMQProducer ,包含日志打印,也为了以后进一步扩展,比如以后直接使用阿里云的rocketmq
- 监听消息请查看MqResultListener 类,监听消息只需要实现接口类MessageListener就可以,注意有顺序消息和无顺序消息不同,请查看注意事项说明
注意事项:
1、消费有顺序消息时,请使用@RocketMqOrderListener 注解,并且实现接口类MessageOrderListener
2、消费普通消息时,请使用@RocketMqListener 注解,并且实现接口类MessageListener