发送单向消息是指producer向 broker 发送消息,执行 API 时直接返回,不等待broker 服务器的结果 。
这种方式主要用在不特别关心发送结果的场景,举例:日志发送;
RocketMQTemplate
给我们提供了sendOneWay方法(有多个重载),来实现发送单向消息;
下面给一个实例:
/**
* 发送单向消息
*/
public void sendOneWayMessage(){
for(int i=0;i<10;i++){
rocketMQTemplate.sendOneWay("java1234-rocketmq", "rocketmg单向消息!"+i);
}
}
![在这里插入图片描述](https://img-blog.csdnimg.cn/102e401e164d45cab4f21083e545d188.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBAamF2YTEyMzRf5bCP6ZSL,size_7,color_FFFFFF,t_70,g_se,x_16)
运行测试OK!
微信搜一搜公众号【java1234】关注这个放荡不羁的程序员,关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。