5 SpringBoot整合RocketMQ发送同步消息
Posted java1234_小锋
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了5 SpringBoot整合RocketMQ发送同步消息相关的知识,希望对你有一定的参考价值。
发送同步消息是指producer向 broker 发送消息,执行 API 时同步等待, 直到broker 服务器返回发送结果;
相对异步发送消息,同步会阻塞线程,性能相对差点,但是可靠性高,这种方式得到广泛使用,比如:短信通知,邮件通知,站内重要信息通知等。
RocketMQTemplate
给我们提供了syncSend方法(有多个重载),来实现发送同步消息;
下面给一个实例:
/**
* 发送同步消息
*/
public void sendSyncMessage(){
for(int i=0;i<10;i++){
SendResult sendResult = rocketMQTemplate.syncSend("java1234-rocketmq","rocketmq同步消息!"+i);
System.out.println(sendResult);
}
}
这里执行完发送同步消息返回执行结果SendResult
;
运行测试OK;
说明:这个是锋哥的RocketMQ备课笔记,等备课完,会发布配套的视频教程,如有需要,可以先加锋哥WX:java1239 欢迎白嫖
微信搜一搜公众号【java1234】关注这个放荡不羁的程序员,关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。
以上是关于5 SpringBoot整合RocketMQ发送同步消息的主要内容,如果未能解决你的问题,请参考以下文章
4 SpringBoot整合RocketMQ实现消息发送和接收