5springboot整合rocketmq发送同步消息(代码片段)

java1234_小锋 java1234_小锋     2022-12-28     179

关键词:

发送同步消息是指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】关注这个放荡不羁的程序员,关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。

4springboot整合rocketmq实现消息发送和接收(代码片段)

我们使用主流的SpringBoot框架整合RocketMQ来讲解,使用方便快捷;最终项目结构如下:具体步骤如下:第一步:新建SpringBoot项目rocketmq-test,引入rocketmq依赖,以及项目配置<dependency> <groupId>org.apac... 查看详情

7springboot整合rocketmq发送单向消息(代码片段)

...特别关心发送结果的场景,举例:日志发送;RocketMQTemplate给我们提供了sendOneWay方法(有多个重载),来实现发送单向消息;下面给一个实例: 查看详情

springboot实战项目整合阿里云rocketmq消息队列实现发送普通消息,延时消息(代码片段)

原文地址:Springboot实战项目整合阿里云RocketMQ消息队列实现发送普通消息,延时消息--附代码-学不会丶-博客园一.为什么选择RocketMQ消息队列?(可跳过看三的整合代码实例)首先RocketMQ是阿里巴巴自研出来的&#... 查看详情

rocketmq简单消息发送(代码片段)

有以下3种方式发送RocketMQ消息可靠同步发送reliablesynchronous可靠异步发送reliableasynchronous单向发送one-waytransmission可靠同步发送主要运用在比较重要一点消息传递/通知等业务publicclassSyncProducerpublicstaticvoidmain(String[]args)throwsExceptionDefa... 查看详情

rocketmq源码—producer发送单向同步异步消息源码一万字(代码片段)

基于RocketMQrelease-4.9.3,深入的介绍了Producer发送单向、同步、异步消息的源码。文章目录1invokeOneway单向发送1.1invokeOnewayImpl单向调用2sendMessageSync同步发送2.1invokeSync同步调用2.1.1invokeSyncImpl同步调用实现2.1.1.1请求的阻塞和唤醒2.... 查看详情

rocketmq发送同步异步单向消息(代码片段)

目录说明基础工具类测试代码效果展示说明后续打算根据RocketMQ官网的例子,也对各种类型的消息进行简单的使用。在熟悉基本使用,了解各类消息的特点之后,再抽时间进行内部原理剖析。后续所有的文章,都... 查看详情

rocketmq发送同步异步单向消息(代码片段)

目录说明基础工具类测试代码效果展示说明后续打算根据RocketMQ官网的例子,也对各种类型的消息进行简单的使用。在熟悉基本使用,了解各类消息的特点之后,再抽时间进行内部原理剖析。基础工具类在接下来的例... 查看详情

rocketmq—生产者客户端详解(代码片段)

...ACK与重试机制,消息的顺序生产,批量发送等。RocketMQ在具备这些特性的同时,有自己独有的特性。下面我们对RocketMQ的生产者开展讲解。一、消息发送1.同步发送消息同步发送是指消息发送方发出数据后,同步等... 查看详情

rocketmq笔记:普通消息(代码片段)

  普通消息为RocketMQ中最基础的消息,支持生产者和消费者的异步解耦通信。一、普通消息的生命周期 1、初始化  消息被生产者构建并完成初始化,待发送到服务端的状态。2、待消费  消息被发送到服务端,对消费... 查看详情

day368&369.rocketmq应用-rocketmq(代码片段)

RocketMQ应用一、普通消息1、消息发送分类Producer对于消息的发送方式也有多种选择,不同的方式会产生不同的系统效果。同步发送消息同步发送消息是指,Producer发出⼀条消息后,会在收到MQ返回的ACK之后才发下⼀条消... 查看详情

springboot实战项目整合阿里云rocketmq消息队列实现发送普通消息,延时消息(代码片段)

原文地址:Springboot实战项目整合阿里云RocketMQ消息队列实现发送普通消息,延时消息--附代码-学不会丶-博客园一.为什么选择RocketMQ消息队列?(可跳过看三的整合代码实例)首先RocketMQ是阿里巴巴自研出来的&#... 查看详情

rocketmq-如何实现顺序消息

...新增消息、修改消息。如何发送和消费顺序消息我们使用RocketMQ顺序消息来模拟一下订单的场景,顺序消息分为两部分:顺序发送、顺序消费。1.顺序发消息上面代码模拟了按顺序依次发送创建、支付、退款消息到TopicTest中。在ap... 查看详情

12springboot整合rocketmq实现过滤消息-根据tag方式过滤消息(代码片段)

消息发送端只能设置一个tag,消息接收端可以设置多个tag。接收消息端通过‘||’设置多个tag,如下:tag1||tag2||tag3||…上实例,生产端发送三个消息,TAG分别是TAG1,TAG2,TAG3/***发送带Tag消息,测试根据Tag过滤消息*/... 查看详情

springboot整合rocketmq的各种消息类型,生产者,消费者(代码片段)

...顺序消息消费者sql92过滤消息消费者事物消息消费者@RocketMQMessageListener参数解释我的rocketmq各种集群方案安装Springboot整合使用pom依赖<dependency><groupId>org.apache.roc 查看详情

rocketmq的消息可靠性(防止消息丢失)

详细介绍了RocketMQ消息丢失的问题,以及解决办法。消息的丢失问题,可能出现在生产者、MQ、消费者中。文章目录1生产者消息丢失2MQ消息丢失3消费者消息丢失1生产者消息丢失RocketMQ提供了三种方式发送消息:同步、... 查看详情

rocketmq(十三)普通消息(代码片段)

1、消息发送分类Producer对于消息的发送方式也有多种选择,不同的方式会产生不同的系统效果。1.1、同步发送消息同步发送消息是指,Producer发出⼀条消息后,会在收到MQ返回的ACK之后才发下⼀条消息。该方式的消息... 查看详情

rocketmq之消息的生产与消费(代码片段)

基本示例中提供了以下两个功能RocketMQ可用于以三种方式发送消息:可靠的同步、可靠的异步和单向传输。前两种消息类型是可靠的,因为无论它们是否成功发送都有响应。RocketMQ可以用来消费消息。1添加依赖maven:<depen... 查看详情

rocketmq(02)——发送消息的三种方式(代码片段)

发送消息的三种方式同步发送Producer在进行消息发送时可以是阻塞的,也可以是非阻塞的。具体对应到发送方式一共有三种,分别是同步、异步和单向的(ONEWAY)。之前介绍的调用send()返回SendResult的方法是阻塞的&... 查看详情