一.消息的发送
启动服务,加入依赖
![](https://img-blog.csdnimg.cn/img_convert/934ec6475dfd970f936b2f1c397a5ae1.png)
加入配置
![](https://img-blog.csdnimg.cn/img_convert/541948aacb14142d94897c7dc4d83f22.png)
在发送类中注入topic,类型为String
![](https://img-blog.csdnimg.cn/img_convert/d849d04de175daf5fd951b52620d2f35.png)
1.同步消息的发送
写方法rocketMQTemplate.syncSend同步方法
![](https://img-blog.csdnimg.cn/img_convert/2a2b5af46780c99f239e63bee523e42c.png)
2.异步消息的发送
![](https://img-blog.csdnimg.cn/img_convert/cfc7293ceedebb65e9d6fa6f9f066425.png)
调用自己定义的异步方法
![](https://img-blog.csdnimg.cn/img_convert/14576f5f19ed2a98118ee73d17ad6a95.png)
3.事务消息的发送
![](https://img-blog.csdnimg.cn/img_convert/76360cfdf9358d737da96268245a1d54.png)
加入事务消息固定配置类
![](https://img-blog.csdnimg.cn/img_convert/95fbb9d1e60ec5e2ffd221f3b36a844f.png)
二.消息的接收
![](https://img-blog.csdnimg.cn/img_convert/5044d4c48fd6648cedc119a0091b0828.png)
接收到消息输出到控制台,查看是否正确。
一.消息的发送
启动服务,加入依赖
加入配置
在发送类中注入topic,类型为String
1.同步消息的发送
写方法rocketMQTemplate.syncSend同步方法
2.异步消息的发送
调用自己定义的异步方法
3.事务消息的发送
加入事务消息固定配置类
二.消息的接收
接收到消息输出到控制台,查看是否正确。