背景

公司为了省钱，最近项目消息队列由rocketmq 转向自己搭建的rabbitMq。

简单认识

1 可靠性： 支持持久化，发布确认，传输确认来保证。

今天我们再来看看RocketMQ的另外两个小功能，消息的批量发送和过滤。这两个小功能提升了我们使用RocketMQ的效率。

批量发送

以前我们发送消息的时候，都是一个一个的发送，这样效率比较低下。能不能一次发送多个消息呢？当然是可以的，RocketMQ为我们提供了这样的功能。但是它也有一些使用的条件：

• 同一批发送的消息的Topic必须相同；
• 同一批消息的waitStoreMsgOK 必须相同；

在目前开源的RockeMQ版本中，并不支持发送任意时间精度的延迟消息。有很多同学应该也会碰到这样的问题：如果要发送任意时间精度的延迟消息，该如何做？碰到这个问题其实就要从MQ的实现原理上找切入点，今天通过查资料，把这种操作简单落地了。

常见的解决方案

延迟队列在实际项目中有非常多的应用场景，最常见的比如订单未支付，超时取消订单，在创建订单的时候发送一条延迟消息，达到延迟时间之后消费者收到消息，如果订单没有支付的话，那么就取消订单。

一、调用链跟踪实现原理

调用链跟踪的核心在于消息轨迹（Trace）功能，通过记录消息生产、存储、消费的全生命周期数据，形成完整的链路视图。RocketMQ通过以下机制实现：

1. 消息轨迹采集

顺序消息是指对于一个指定的 Topic ，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。

顺序消息分为

在当今互联网后端开发的领域中，高效的数据传输与处理至关重要。消息队列作为一种强大的工具，能够帮助我们解耦系统、实现异步处理以及提升系统的整体性能。其中，RocketMQ 以其高性能、高可靠、可扩展的特性，成为众多互联网大厂在分布式系统中处理消息的首选之一。而 Spring Boot 3 框架，凭借其便捷的开发体验和强大的生态支持，更是让开发者们爱不释手。那么，如何在 Spring Boot 3 中整合 RocketMQ 来实现高效的消息队列处理呢？接下来，就让我们一同深入探索。

本章节，继续跟大家分析RocketMQ Broker 基础概念及启动过程。RocketMQ Broker 启动分为 master、slave 启动。本章节主要集中在 master 启动过程。

什么是 RocketMQ Broker

RocketMQ版本

• version: 5.1.0

RocketMQ中consumer消费模型

在了解RocketMQ的Rebalance机制之前，我们必须先简单了解下rocketmq的消费模型

又是一篇rocketmq啊，最近是和rocketmq杠上了。本章带来的是，rocketmq实现顺序发送（原生版本和spring版本）。