正文 

当前位置： 首页 > 技术 > java教程

9springboot整合rocketmq实现顺序消息(代码片段)

java1234_小锋 java1234_小锋     2023-01-01     646

关键词：

rocketmq默认发送的消息是进入多个消息队列，然后消费端多线程并发消费，所以默认情况，不是顺序消费消息的；

有时候，我们需要实现顺序消费一批消息，比如电商系统，订单创建，支付，完成等操作，需要顺序执行；

RocketMQTemplate给我们提供了SendOrderly方法(有多个重载)，来实现发送顺序消息；包括以下：

syncSendOrderly，发送同步顺序消息；

asyncSendOrderly，发送异步顺序消息；

sendOneWayOrderly，发送单向顺序消息；

一般我们用第一种发送同步顺序消息；

第三个参数hashKey,方法点进去：

因为broker会管理多个消息队列，这个hashKey参数，主要用来计算选择队列的，一般可以把订单ID，产品ID作为参数值；

发送到一个队列，这样方便搞顺序队列；

以及消费端接收的时候，默认是并发多线程去接收消息。RocketMQMessageListener有个属性consumeMode，默认是ConsumeMode.CONCURRENTLY ，我们要改成ConsumeMode.ORDERLY，单线程顺序接收消息；

下面给具体事例，模拟两个订单发送消息；

消息生产者端：

/**
 * 发送同步顺序消息
 */
public void sendOrderlyMessage()
	// hashKey用来计算决定消息发送到哪个消息队列 一般是订单ID，产品ID等
	rocketMQTemplate.syncSendOrderly("java1234-rocketmq-orderly", "98456231,创建", "98456231");
	rocketMQTemplate.syncSendOrderly("java1234-rocketmq-orderly", "98456231,支付", "98456231");
	rocketMQTemplate.syncSendOrderly("java1234-rocketmq-orderly", "98456231,完成", "98456231");

	rocketMQTemplate.syncSendOrderly("java1234-rocketmq-orderly", "98456232,创建", "98456232");
	rocketMQTemplate.syncSendOrderly("java1234-rocketmq-orderly", "98456232,支付", "98456232");
	rocketMQTemplate.syncSendOrderly("java1234-rocketmq-orderly", "98456232,完成", "98456232");

消费者端：

/**
 * 消息消费者
 * @author java1234_小锋
 * @site www.java1234.com
 * @company 南通小锋网络科技有限公司
 * @create 2021-08-22 22:40
 */
@RocketMQMessageListener(topic = "java1234-rocketmq-orderly",consumerGroup ="$rocketmq.consumer.group",consumeMode =ConsumeMode.ORDERLY )
@Component
public class ConsumerService implements RocketMQListener<String> 

    @Override
    public void onMessage(String s) 
        System.out.println("消费者：收到消息内容："+s);

运行测试：


说明：这个是锋哥的RocketMQ备课笔记，等备课完，会发布配套的视频教程，如有需要，可以先加锋哥WX：java1239 欢迎白嫖

没问题！

微信搜一搜公众号【java1234】关注这个放荡不羁的程序员，关注后回复【资料】有我准备的一线大厂笔试面试资料以及简历模板。

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

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

springboot整合rocketmq

上篇博客讲解了服务器集群部署RocketMQ博客地址：RocketMQ(2)---Docker部署RocketMQ集群这篇在上篇搭建好的基础上,将SpringBoot整合RocketMQ实现生产消费。GitHub地址: https://github.com/yudiandemingzi/spring-boot-study一、搭建步骤先说下技术大致... 查看详情

11springboot整合rocketmq实现事务消息(代码片段)

事务消息是RocketMQ提供的非常重要的一个特性，在4.x版本之后开源，可以利用事务消息轻松地实现分布式事务。RocketMQ在其消息定义的基础上，对事务消息扩展了两个相关的概念：Half(Prepare)Message——半消息(预处理... 查看详情

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

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

rocketmq-如何实现顺序消息

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

10springboot整合rocketmq实现延迟消息(代码片段)

延迟消息对于消息中间件来说，producer将消息发送到mq的服务器上，但并不希望这条消息马上被消费，而是推迟到当前时间节点之后的某个时间点，再将消息投递到queue中让consumer进行消费。​延迟消息的使用场景... 查看详情

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

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

聊一聊顺序消息（rocketmq顺序消息的实现机制）(代码片段)

当我们说顺序时，我们在说什么？日常思维中，顺序大部分情况会和时间关联起来，即时间的先后表示事件的顺序关系。比如事件A发生在下午3点一刻，而事件B发生在下午4点，那么我们认为事件A发生在事件B之前，他们的顺序关... 查看详情

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

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

13springboot整合rocketmq实现过滤消息-根据sql表达式过滤消息(代码片段)

...达式方式可以根据发送消息时输入的属性进行一些计算。RocketMQ的SQL表达式语法只定义了一些基本的语法功能。数字比较，如>，>=，<，<=，BETWEEN，=；字符比较，如：=，&... 查看详情

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

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

rocketmq的关键特性

...序消费才有意义。但同时订单之间又是可以并行消费的。RocketMQ是通过将“相同ID的消息发送到同一个队列，而一个队列的消息只由一个消费者处理“来实现顺序消息。这样对于同一个订单的创建、付款和完成消息，他们将保持... 查看详情

rocketmq的顺序消息（顺序消费）(代码片段)

简单介绍了消息有序性的概念，以及RocketMQ如何实现消息的顺序消费。文章目录1消息的有序性2生产者有序发送3消费者有序消费1消息的有序性消息有序指的是一类消息消费时，能按照发送的顺序来消费。例如：一个订... 查看详情

springboot整合rocketmq

参考技术A运行脚本org.apache.rocketmq.common.message.MessageExt属性说明: 查看详情

rocketmq使用顺序消息(代码片段)

目录说明生产端消费端总结说明RocketMQ与其它消息队列一样，一个Topic利用多个队列来存储数据，单个队列内的数据是顺序存储的，但队列间的数据无法保证顺序性。RocketMQ目前支持保证某类数据或部分数据的顺序性。... 查看详情

rocketmq（20）——整合springboot(代码片段)

整合SpringBootApacheRocketMQ提供了对SpringBoot的支持，目前最新的整合版本使用的是RocketMQ4.5.1版本，使用SpringBoot是2.0.5版本。整合SpringBoot需要引入rocketmq-spring-boot-starter依赖，目前最新版本是2.0.3。<dependency><groupId>org.apache.rock... 查看详情

8springboot整合rocketmq实现消费者广播模式和负载均衡模式(代码片段)

如上图，假如我们有多个消费者，消息生产者发送的消息，是每一个消费者都消费一次呢？还是通过一些机制，比如轮询机制，每个消息只被某一个消费者消费一次呢？这里涉及到消费者的消费模式... 查看详情

rocketmq（20）——整合springboot(代码片段)

整合SpringBootApacheRocketMQ提供了对SpringBoot的支持，目前最新的整合版本使用的是RocketMQ4.5.1版本，使用SpringBoot是2.0.5版本。整合SpringBoot需要引入rocketmq-spring-boot-starter依赖，目前最新版本是2.0.3。<dependency><groupId>org.apache.ro 查看详情