发送单向消息是指producer向 broker 发送消息,执行 API 时直接返回,不等待broker 服务器的结果 。
这种方式主要用在不特别关心发送结果的场景,举例:日志发送;
RocketMQTemplate
给我们提供了sendOneWay方法(有多个重载),来实现发送单向消息;
下面给一个实例:
/** * 发送单向消息 */
public void sendOneWayMessage(){
for(int i=0;i<10;i++){
rocketMQTemplate.sendOneWay("java1234-rocketmq", "rocketmg单向消息!"+i);
}
}
运行测试OK!
版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : https://blog.csdn.net/caoli201314/article/details/120094904
内容来源于网络,如有侵权,请联系作者删除!