作者：家泽 ApsaraMQ 与时俱进，砥砺前行 阿里云消息队列从诞生开始，至今已有十余年。今年，阿里云消息产品全面品牌升级为 ApsaraMQ，与时俱进，砥砺前行。 2012 年，RocketMQ 诞生于集团内部，用于淘宝交易等核心业务链路。历经集团多年来双 11 万亿级的考验、稳定性的打磨，依托云计算孵化，以及开源社区的协力。 于 2015 年，RocketMQ 在阿里云上，面向企业提供商业化

本文整理于 2023 年云栖大会林清山带来的主题演讲《Apache RocketMQ 云原生统一消息引擎》 演讲嘉宾： 林清山（花名：隆基），Apache RocketMQ 联合创始人，阿里云资深技术专家，阿里云消息产品线负责人。国际消息领域专家，致力于消息、实时计算、事件驱动等方向的研究与探索，推进 RocketMQ 云原生架构、超融合架构的演进。 Apache RocketMQ 简介 消息队列

这篇文章，我们聊聊如何应对 RocketMQ 消息堆积。 图片 1 基础概念 消费者在消费的过程中，消费的速度跟不上服务端的发送速度，未处理的消息会越来越多，消息出现堆积进而会造成消息消费延迟。 虽然笔者经常讲：RocketMQ 、Kafka 具备堆积的能力，但是以下场景需要重点关注消息堆积和延迟的问题： 业务系统上下游能力不匹配造成的持续堆积，且无法自行恢复。 业务系统对消息的消费实时性要求较高

RocketMQ是Java兄弟们常用的消息中间件，虽说常用，但对于RocketMQ架构经常忘记。究其原因就l两点：忙于业务开发然后长时间不看则忘了、不理解架构设计的根本原因记不牢。本文用大白话描述架构设计过程，牢记RocketMQ架构。 一、架构的思考过程 首先，在记框架的原理和架构时，要先把握全局的脉络，在思考为什么这么设计，最后才是思考细节，这样才能记得牢。本文通过层层追问的方式，一步步解说R

嗨，小伙伴们！小米在这里啦！今天我们要聊的话题是社招面试中一个经典而又百思不得其解的问题——“RocketMQ如何保证顺序性？”不用担心，小米来给你揭秘RocketMQ的秘密武器，让你轻松过关面试大关！ 引言：为什么要谈顺序性？ 首先，我们得明白为什么在消息队列中要讲究消息的顺序性。假设你正在开发一个电商平台，用户下单、支付、发货这些操作，可不能搞乱了顺序，否则后果不堪设想！所以，RocketMQ

大家好，我是三友~~ 故事的开头是这样的 最近有个兄弟私信了我一张截图 图片 我一看截图内容，好家伙，原来是我一年多前立的flag 倒不是我忘了这件事，我后来也的确写了一篇的关于RocketMQ运行的原理的文章 只不过这篇文章是从上帝的视角去看待RocektMQ一条消息整个生命周期的过程 所以就没有具体的分析事务和延迟消息的实现原理，也算是留下了一个小小的坑吧 不过，既然现在有兄弟问了，那么今天我

这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ 版本 5.1.0 背景 继之前研究过的RocketMQ发送消息还有这种坑？遇到SYSTEM_BUSY不重试？ 今天我们来分析分析RocketMQ什么情况下会出现system busy，因为线上的RocketMQ集群偶尔会出现[PCBUSY_CLEAN_QUEUE]broker bus

RocketMQ的下载、安装和配置 RocketMQ的Binary版是一些编译好的jar和辅助的shell脚本，可以直接从官网找到下载链接（http://rocketmq.apache.org/dowloading/releases/），也可以下载源码自己编译。 系统要求：64bit的Linux、Unix或Mac。Java版本大于等于JDK1.8。如果需要从GitHub上下载源码和编译的话，需要安

RabbitMQ 和 RocektMQ 属于业务消息类的消息队列，它们的特点是功能丰富、低延时、数据高可靠性、消息可追踪等等，同时也支持延时消息、优先级队列、消息过滤等功能特性。 RabbitMQ 发展较早，RocketMQ 则是新生的消息类的消息队列，从功能、集群化、稳定性、性能来看，RocketMQ 都是比 RabbitMQ 表现要好的。所以从某种意义上说，RocketMQ 是可以替代 Rab

Spring Cloud 微服务系列文章，点击上方合集↑ 1. 简介 RocketMQ是一款开源的分布式消息中间件，它具有高可靠性、高性能和可伸缩性，被广泛用于构建分布式系统中的可靠消息传递服务。 官网地址： rocketmq.apache.org/ 2. 工作流程 启动 NameServer 启动 Broker 创建 Topic 生产者发送消息 消费者接受消息 3. 下载安装 3.1 直接下载（

前言 延迟消息在业务场景中使用的非常多，订单失效，过期通知等功能都可以借助延迟消息机制来实现。本文将从源码层面来分析Rocketmq的延迟消息实现原理机制。 一、延迟消息的使用             先看下延迟消息的使用，发送消息逻辑和普通消息一样，只要在生产者端将Message对象中设置延迟消息的等级，Rocketmq的开源版本支持18个等级，每个等级代表一个延迟时间。 Rocketmq有18

前言 上一篇文章已经介绍了RocketMQ的功能，架构，从本文开始，我们将开始深入源码层面，一步一步学习RocketMQ设计原理。 在消息队列中，生产者负责发送消息到Broker,本文分享RocketMQ发送消息的实现原理以及一些注意的事项。 一、生产者端的发送流程 一般来说我们的业务应用端是生产者，负责和Broker和nameserver通信完成消息投递的功能。 在源码中，发送消息的主逻辑在 o

前言 上文已经介绍了分布式消息队列的常见概念，从本文开始，将分多篇文章逐步对RocketMQ这款分布式消息队列的架构，功能，以及不同功能的源码实现原理进行分析。本文主要是介绍RocketMQ的功能，架构，加深对RocketMQ的认识。 RocketMQ是什么？     Rocketmq是由阿里巴巴2012年开源的分布式消息中间件，现在已经是apache顶级项目。他是一个队列模型的消息中间件，具有高

windows RocketMQ与可视化监控平台安装 安装日期2023.09.21 最新版 RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件，搭建RocketMQ需要先配置JAVA环境变量,需要有JAVA_HOME。 下载安装包 进入官网选择需要的版本下载安装包（以下以5.1.3为例）。官网下载地址：官网 下载编译好的二进制文件，也可以自己选择源文件。这边主要以二进制包的方式来进

Golang微服务框架Kratos应用RocketMQ消息队列 消息队列是一种异步的服务间通信方式，适用于无服务器和微服务架构。消息在被处理和删除之前一直存储在队列上。每条消息仅可被一位用户处理一次。消息队列可被用于分离重量级处理、缓冲或批处理工作以及缓解高峰期工作负载。 消息队列是大型分布式系统不可缺少的中间件，也是高并发系统的基石中间件，所以掌握好消息队列MQ就变得极其重要。 在本文当中，您将

本地docker搭建RocketMQ用于测试参考# Docker 部署 RocketMQ 5.x RocketMQ官方的Python客户端是 rocketmq-client-python 这个客户端只支持Linux和macOS，并且需要安装额外的C++库支持。 以centos为例，安装rocketmq-client-cpp库： wget https://github.com/apache/rock

Apache RocketMQ 是一个分布式消息中间件系统，用于实现高可用、高性能的消息传递。 1、创建RocketMQ容器共享网络 RocketMQ有多个服务，需要分别创建容器，并且需要互相通信。 docker network create rocketmq # docker network ls #列出已有docker网络 # docker network inspect rocketmq #

环境：springboot2.4.12 + RocketMQ4.8.0 依赖 org.springframework.boot spring-boot-starter-web org.apache.rocketmq rocketmq-spring-boot-starter 2.2.0 配置文件 server: port: 8080 --- rocketmq: nameServer: localho

作者：隆基 一致性 首先来看 RocketMQ 的第一个特性-事务消息，事务消息是 RocketMQ 与一致性相关的特性，也是 RocketMQ 有别于其他消息队列的最具区分度的特性。 以大规模电商系统为例，付款成功后会在交易系统中订单数据库将订单状态更新为已付款。然后交易系统再发送一条消息给 RocketMQ，RocketMQ 将订单已付款的事件通知给所有下游应用，保障后续的履约环节。 但上述流

我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。 前面已经介绍了 生产消息、存储消息 两大块内容，那接下来，我们白话一下RocketMQ是如何消费消息的，揭秘消息消费全过程。 注意，如果白话中不小心提到相关代码配置与类名，请参考RocketMQ 4.9.4版本 关键字摘要 核心概念：消费者与消费组、订阅关系、消费模式 核心流程：消费拉取、负载均衡、消息消费 Q1: