7 SpringBoot整合RocketMQ发送单向消息
Posted java1234_小锋
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了7 SpringBoot整合RocketMQ发送单向消息相关的知识,希望对你有一定的参考价值。
发送单向消息是指producer向 broker 发送消息,执行 API 时直接返回,不等待broker 服务器的结果 。
这种方式主要用在不特别关心发送结果的场景,举例:日志发送;
RocketMQTemplate
给我们提供了sendOneWay方法(有多个重载),来实现发送单向消息;
下面给一个实例:
/**
* 发送单向消息
*/
public void sendOneWayMessage(){
for(int i=0;i<10;i++){
rocketMQTemplate.sendOneWay("java1234-rocketmq", "rocketmg单向消息!"+i);
}
}
运行测试OK!
微信搜一搜公众号【java1234】关注这个放荡不羁的程序员,关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。
以上是关于7 SpringBoot整合RocketMQ发送单向消息的主要内容,如果未能解决你的问题,请参考以下文章