7 SpringBoot整合RocketMQ发送单向消息

x33g5p2x  于2021-09-19 转载在 Spring  
字(0.3k)|赞(0)|评价(0)|浏览(592)

发送单向消息是指producer向 broker 发送消息,执行 API 时直接返回,不等待broker 服务器的结果 。

这种方式主要用在不特别关心发送结果的场景,举例:日志发送;

RocketMQTemplate给我们提供了sendOneWay方法(有多个重载),来实现发送单向消息;

下面给一个实例:

/** * 发送单向消息 */
public void sendOneWayMessage(){
	for(int i=0;i<10;i++){
		rocketMQTemplate.sendOneWay("java1234-rocketmq", "rocketmg单向消息!"+i);
	}
}

在这里插入图片描述

运行测试OK!

相关文章