rocketmq标签_AtomGit开源社区

rocketmq

RocketMQ高可用集群与Raft协议

可以把Broker的运行容器、统一运行基座。所有功能全部耦合在一个巨大的Broker进程里，选主、存储、网络、日志、元数据、同步机制全部堆在一起，模块混杂，牵一发动全身。用Container容器统一管理所有核心模块，把复杂的Broker拆分成一个个独立可插拔的组件，容器负责统一加载、启动、调度、销毁，实现组件隔离、按需加载、解耦运行。

cfm_2914
2026-06-09 12:11:12

 542

 11

#rocketmq
《Java 100 天进阶之路》第95篇：消息队列基础（RocketMQ/Kafka）（2026版）

消息队列基础（RocketMQ/Kafka）（2026版）一文搞懂消息队列三大作用（解耦、异步、削峰）、两大模型（点对点/发布订阅）。深度解析 RocketMQ（NameServer/Broker/Tag）与 Kafka（Partition/Offset/ISR/KRaft）核心概念，提供 Spring Boot 生产级代码（异步发送 + 本地消息表补偿、Redis 幂等去重）。附避坑清单与面试高

 折哥|智能物流与Java实战
2026-06-09 08:30:00

 678

 15

#java-rocketmq #java #rocketmq +3
RocketMQ消息机制初步了解

RocketMQ消息是分布式系统中业务数据传输的最小载体单元，是生产者向Broker投递、消费者拉取处理的核心数据实体，用于跨服务、跨模块异步传递业务信息，实现系统解耦、异步通信、流量削峰等分布式能力。所有RocketMQ的发送、消费、重试、事务、过滤等机制，全部基于消息实体展开。RocketMQ事务消息是为解决本地数据库事务与消息发送一致性设计的高级消息模型，核心实现半消息预提交 + 本地事务执

 cfm_2914
2026-06-04 21:20:21

 389

 5

#rocketmq
RocketMQ-客户端编程模型

实际存储的消息是topic下面对应的一系列的message消息队列，这些消息队列会尽量平均的分配到多个不同的broker当中，在集群当中，根据broker的数量均匀分配，这样有利于发挥broker的这种集群的性能优势。2、消费者需要实现MessageListenerOrderly接⼝，实际上在broker服务端，处理MessageListenerOrderly时，会给⼀个MessageQueue

一本正经的不务正业
2026-06-03 20:51:38

 187

 6

#java-rocketmq #rocketmq #java
全新 AI 消息模型：Apache RocketMQ 如何让 AI 应用拥抱事件驱动架构？

作者 | 阿里云消息团队文婷、不铭、墨岭、稚柳前言随着 AIGC（生成式人工智能）浪潮席卷全球，大语言模型（LLM）正在深刻重塑千行百业、重构应用开发范式。这场由模型与算法驱动的技术革命，带来了前所未有的机遇，也为开发者构建 AI 应用带来了全新而严峻的工程挑战：如何保障长耗时对话的连续性？如何公平高效地调度有限的算力资源？如何避免多 AI Agent 或复杂工作流的级联阻塞问题？......这些

 Apache RocketMQ
2026-05-28 15:11:06

 507

 8

#人工智能 #apache #rocketmq
Apache RocketMQ for AI 战略升级，开启 AI MQ 新时代

在 AI 时代，如何应对复杂多变的业务场景、满足更高的性能与体验要求，已成为 Apache RocketMQ 演进过程中的关键课题。

Apache RocketMQ
2026-05-28 14:49:04

 332

 7

#apache #rocketmq #人工智能
Apache RocketMQ EventBridge：为什么 GenAI 需要 EDA？

本文主要探讨在 AI 时代，EDA 的重要价值及它可以帮助我们解决的问题。

Apache RocketMQ
2026-05-28 14:43:04

 397

 6

#apache #rocketmq
多源 RAG 自动化处理：从 0 到 1 构建事件驱动的实时 RAG 应用

本文将介绍构建 RAG 的最佳实践：通过阿里云事件总线 EventBridge 提供的多源 RAG 处理方案，基于事件驱动架构为企业 AI 应用打造高效、可靠、自动化的数据管道，轻松解决 RAG 数据处理难题。

Apache RocketMQ
2026-05-28 13:57:37

 390

 9

#自动化 #运维 #java-rocketmq +2
Docker Compose部署RocketMQ

虽然官网里面的文档自带有Docker，Docker Compose部署MQ的教材，但是实际上是不够用的，缺少了一些配置，我查看官方文档，再使用AI，实际动手部署后，能够成功部署上MQ，然后发个文章，做个记录，也希望对有需要的朋友提供帮助。

qq_43355010
2026-05-28 10:06:38

 432

 9

#docker #rocketmq #容器
AI 时代的消息底座变了！RocketMQ 5.5.0 发布，LiteTopic 开启 AI 原生通信新时代

Apache RocketMQ 5.5.0 已正式发布。本次版本的重要特性之一，是社区提案 RIP-83 定义的全新消息模型 LiteTopic 进入开源版本。

阿里云云原生
2026-05-27 17:50:03

 568

 11

#人工智能 #rocketmq #apache
Apache RocketMQ 5.5.0 开源 LiteTopic：百万级 AI 会话专属通道

Apache RocketMQ 5.5.0 已正式发布。本次版本的重要特性之一，是社区提案 RIP-83 定义的全新消息模型 LiteTopic 进入开源版本。LiteTopic 面向 AI Agent、异步任务和海量轻量会话场景，支持百万级轻量会话通道共存，并在轻量通道管理、消费状态持久化和事件驱动分发等方面进行了针对性设计。此前，阿里云云消息队列 RocketMQ 版已围绕相关 AI 通信场景

 Apache RocketMQ
2026-05-27 10:11:32

 426

 10

#apache #rocketmq #开源
传统MQ彻底扛不住大模型流量！火山引擎RocketMQ For AI：重构AI原生通信底座

百万 AI 会话把传统队列干到崩溃？实时对话被离线任务插队？别急！全新 RocketMQ For AI 重构通信架构，轻松拿捏海量会话与算力调度，AI 落地再也不卡壳。

2301_80289431
2026-05-26 22:49:55

 817

 17

#火山引擎 #rocketmq #人工智能
深入理解 RocketMQ 消息模型：从客户端机制到 Spring Boot 实战与生产最佳实践

RocketMQ 的价值并不仅仅是“把消息发送出去”，而是围绕可靠性、一致性、吞吐量和业务治理提供了一套完整机制。普通消息解决异步解耦问题。广播消息用于每个实例都需要执行的通知类场景。Tag 与 SQL 过滤帮助消费者只处理关心的消息。顺序消息保证同一业务实体的状态流转顺序。延迟消息适用于订单超时、定时提醒等场景。批量消息提高大量小消息的发送效率。事务消息用于解决本地事务与消息发送的一致性问题。A

进阶の小白
2026-05-23 23:13:07

 392

 12

#java-rocketmq #rocketmq #spring boot
@RemoteEvent 自动事件总线：1 个注解换 60 个 Consumer，赚还是亏？

一种 Spring + RocketMQ "自动事件总线"设计：业务 Bean 加 @RemoteEvent 注解，启动时自动创建独立 Consumer + Topic + Group。本文剖析发送侧用 ApplicationEventMulticaster 接管 Spring事件分发、消费侧扫描注解自动注册 Container 的双端实现，量化每个 Bean 至少新增 21 个线程的代价（60

fengquan8866
2026-05-21 21:15:42

 689

 23

#rocketmq #java #系统架构
RocketMQ 从入门到实战：一篇文章搞懂消息队列、架构模型与集群部署

这篇文章我们从 0 到 1 梳理了 RocketMQ 的核心内容。可以总结为几句话：1. MQ 的核心价值是：解耦、异步、削峰、可靠2. RocketMQ 是一款高性能、高可靠的分布式消息中间件3. RocketMQ 核心组件包括：NameServer、Broker、Producer、Consumer4. NameServer 负责路由发现，Broker 负责消息存储和投递5. Producer

进阶の小白
2026-05-21 17:39:45

 418

 9

#rocketmq #架构
Java-220 RocketMQ 核心原理与最佳实践：消息发送、消费、存储详解

本文深入剖析 Apache RocketMQ 核心原理与生产最佳实践，涵盖消息发送（同步/异步/OneWay）、消息消费（Push/Pull、集群/广播、并行度调优）、消息存储（CommitLog、ConsumeQueue、IndexFile）三大核心维度。详解 SendStatus 四种状态（FLUSH_DISK_TIMEOUT、FLUSH_SLAVE_TIMEOUT、SLAVE_NOT_AVA

武子康
2026-05-19 11:51:21

 417

 9

#rocketmq #java-rocketmq #java +3
Apache RocketMQ 5.4 新版 POP 消费机制详解

6.1 FIFO 为什么不是这套模型前面讲的这套模型里，核心一直是“每条消息对应一条 PopConsumerRecord，再围绕它做 ACK、续租和 revive”。FIFO 不是这套思路。FIFO 更像“带不可见期的顺序消费”。Broker 关心的不是每条消息各自有没有一条独立投递记录，而是同一队列上的顺序窗口有没有被前面的未 ACK 消息卡住。对应到源码上，核心状态从 PopConsumerR

Apache RocketMQ
2026-05-18 11:01:18

 405

 9

#java-rocketmq #rocketmq #java
RocketMQ 源码解析——Controller 高可用切换架构

延伸阅读：🔍「」持续更新源码解析/最佳实践，提供 RocketMQ 专家 AI 答疑服务。

Apache RocketMQ
2026-05-18 10:43:31

 425

 9

#java-rocketmq #rocketmq #架构
消息队列深度对比：Kafka vs RabbitMQ vs RocketMQ

消息队列（Message Queue，MQ）是一种异步通信机制，用于在分布式系统中实现应用解耦、异步处理、流量削峰等目标。生产者将消息发送到队列，消费者从队列中读取消息进行处理。特性RabbitMQ开发语言Scala/JavaErlangJava最初开发者LinkedInAlibaba开源时间201120072012最新版本3.7.x3.13.x5.2.x协议支持自定义协议自定义协议、gRPC定位

 monkeyMrHou
2026-05-18 09:31:08

 689

 14

#kafka #rabbitmq #rocketmq
古茗奶茶：借助 RocketMQ Serverless 实现下单丝滑、大促自由，综合降本 40%

最近，“千问请全国人民喝奶茶”活动火爆全网，这种瞬时爆发的流量洪峰已成为新茶饮行业的常态化挑战。新茶饮行业的数字化演进已从最初的基础设施上云，演进为深度的云原生架构共创与能力共建，再到为 AI 原生提供确定性基座，古茗奶茶在阿里云云原生上的深度实践，正是这种演进的代表。在新茶饮行业，每一次刷屏级的营销活动，每一杯奶茶的“丝滑”下单，背后都是对数字化基座的严峻考验，是一场应对瞬时高并发流量的技术硬仗

 Apache RocketMQ
2026-05-14 11:39:17

 155

 1

#rocketmq #serverless #云计算
打造你的专属 AI 导游：基于 RocketMQ 的多智能体异步通信实战

在现代 AI 应用中，多智能体（Multi-Agent）系统已成为解决复杂问题的关键架构。然而，随着智能体数量增多和任务复杂度提升，传统的同步通信模式逐渐暴露出级联阻塞、资源利用率低和可扩展性差等瓶颈。为应对这些挑战，RocketMQ for AI 提供了面向 AI 场景的异步通信解决方案，通过事件驱动架构实现智能体间的高效协作。本文将探讨和演示如何利用 RocketMQ 构建一个高效、可靠且可扩

 Apache RocketMQ
2026-05-14 11:34:37

 169

 3

#人工智能 #rocketmq #microsoft +3
乐言科技：云原生加速电商行业赋能，云消息队列助力降本 37%

乐言科技作为国内领先的AI企业，专注于为电商等行业提供智能客服等解决方案。随着业务规模扩大，其自建Kafka消息队列面临稳定性差、运维成本高等痛点。通过采用阿里云消息队列RocketMQ版Serverless系列，实现了业务解耦与弹性伸缩，整体成本降低37%，同时提升了系统稳定性和开发效率。结合云原生架构，乐言科技进一步优化了智能客服系统，为电商客户提供更高效的数智化转型服务。

Apache RocketMQ
2026-05-14 11:00:40

 389

 8

#云原生 #rocketmq #科技
消息队列（MQ）技术全景科普：从选型到AI+未来

消息队列（MQ）是分布式系统的核心组件，主流产品各具特色：RabbitMQ擅长灵活路由和低延迟，适合企业级集成；Kafka以高吞吐著称，是流处理的首选；RocketMQ提供金融级可靠性，支持事务和顺序消息；Pulsar采用云原生架构，支持多租户和跨地域复制。在高可用方面，RabbitMQ通过镜像队列实现容灾，Kafka依赖分区副本机制，RocketMQ采用主从架构，Pulsar则通过计算存储分离保

 冷小鱼
2026-04-29 23:50:12

 1576

 23

#人工智能 #kafka #rabbitmq +1
RocketMQ之原理及对比其他MQ

文章目录1 RocketMQ1.1 为什么要选RocketMQ1.2 RocketMQ优缺点1.3 消息模型1.3.1 消息队列模型1.3.2 RocketMQ消息模型1.3.3 RocketMQ中成员1.3.3.1 Message1.3.3.2 Topic1.3.3.3 Tag1.3.3.4 Group1.3.3.5 Message Queue1.3.3.6 Offset1.3.3.7 总结图示

 爱吃牛肉的大老虎
2022-05-14 21:44:37

 1700

 2

#rocketmq
RocketMQ实战：异步处理长耗时API调用

本文围绕 AI 音视频处理项目，对比同步处理与 RocketMQ 异步架构差异，分析长耗时 AI 任务（FFmpeg 音频提取、ASR 转写、AI 总结、知识库向量化）直接同步执行存在 HTTP 超时、资源耗尽、级联失败等问题。介绍基于 RocketMQ 实现上传即返回、后台异步处理的生产级方案，包含分布式锁、顺序消费、失败重试、消息积压监控、状态流转等核心设计，阐述异步解耦、削峰填谷、可靠重试、

让代码运行一会
2026-04-21 21:23:14

 374

 10

#rocketmq #spring #音视频
RocketMQ 系列文章（进阶篇第 2 篇）：事务消息深度解析与分布式事务落地实践

摘要：RocketMQ事务消息解决分布式系统数据一致性问题本文介绍了RocketMQ事务消息在解决分布式系统中"业务操作与消息发送"原子性问题中的应用。通过两阶段提交机制，RocketMQ事务消息确保业务执行和消息发送要么都成功，要么都失败。核心流程包括：发送半事务消息、执行本地事务、提交/回滚消息、事务回查补偿机制。文章详细解析了事务消息原理、特性配置及Java实现方案，并

 qq_29757467
2026-04-21 09:48:28

 412

 7

#rocketmq #分布式
RabbitMQ - 与其他消息队列的对比：Kafka / RocketMQ / ActiveMQ

RabbitMQ与其他消息队列对比摘要本文对比了四种主流消息队列(RabbitMQ、Kafka、RocketMQ和ActiveMQ)的核心特性与适用场景。RabbitMQ基于AMQP协议，提供灵活路由和可靠消息传递，适合企业级应用；Kafka专为高吞吐量设计，适合日志处理和大数据场景；RocketMQ结合了RabbitMQ和Kafka的优点，适合金融级交易；ActiveMQ则适合传统企业应用集成

 Jinkxs
2026-04-19 05:00:00

 2.3w

 15

#rabbitmq #kafka #rocketmq
RocketMQ 入门：阿里巴巴开源分布式消息队列

RocketMQ是阿里巴巴开源的分布式消息队列，现为Apache顶级项目。它主打低延迟、高可靠，支持千万级QPS和亿级消息堆积，特别适合高并发场景如电商订单系统。核心特性包括：毫秒级延迟、消息持久化、事务消息支持、多种消费模式及延迟消息功能。相比Kafka和RabbitMQ，RocketMQ在分布式事务处理上更便捷，是国内互联网公司的主流选择。虽然多语言支持较弱，但对Java技术栈非常友好。目前5

陈老师嵌入式
2026-04-17 13:50:43

 543

 12

#rocketmq #开源 #分布式 +1
消息中间件深度剖析：RocketMQ vs Kafka 实战指南（建议收藏）

本文围绕消息队列核心应用展开，先解析消息队列的使用必要性，再对RocketMQ 与 Kafka从开发语言、消息模型、功能特性、吞吐量、适用场景等维度进行核心对比，清晰区分二者差异。随后分别详解 RocketMQ 与 Kafka 的核心组件、架构原理，并提供Spring Boot 集成实战代码，覆盖普通消息、顺序消息、事务消息、延迟消息等常用场景。同时重点讲解消息可靠性保障、重复消费与幂等方案、延迟

 装满水杯的水
2026-04-16 09:30:00

 401

 11

#rocketmq #kafka #分布式 +1
《RocketMQ实战与进阶》 02 RocketMQ 核心概念扫盲篇

RocketMQ核心概念解析：本文系统梳理了RocketMQ的核心组件和消息模型。部署架构包含NameServer（路由注册中心）、Broker（消息存储服务器）和Client（生产者和消费者）；消息订阅采用发布-订阅模式，支持集群和广播两种消费模式；详细介绍了队列负载算法、消费重平衡机制及两种消费模型（并发消费和顺序消费）；还讲解了事务消息、定时消息和消息过滤等特性。这些基础概念为后续深入学习R

短剑重铸之日
2026-04-16 08:38:42

 504

 10

#rocketmq #中间件
从0到1搭建可靠消息链路：RocketMQ重试 + Redis幂等实战

三方消息对接的工业级解决方案针对三方平台对接中常见的消息重复消费、状态混乱等问题，本文提出了一套基于RocketMQ+Redis的完整解决方案。核心架构包括：定时任务拉取三方消息后通过RocketMQ分片发送，消费者端实现Redis幂等过滤和业务处理。关键设计点包括：消息处理：分页拉取+双重分片发送，失败自动重试幂等控制：基于业务键+版本时间的Redis幂等模型容错机制：Token过期自动

 heyongjin22
2026-04-10 16:20:35

 438

 10

#rocketmq #redis #bootstrap +1
【RocketMQ】RocketMQ核心知识体系全解（5大核心模块：架构模型、事务消息两阶段提交、回查机制、延迟消息、顺序消息）

本文全方位、结构化梳理RocketMQ的核心架构与五大核心特性（架构模型、事务消息两阶段提交、回查机制、延迟消息、顺序消息），形成完整的知识闭环，覆盖底层原理、执行流程、核心设计、容错机制与最佳实践。

小江的记录本
2026-04-05 23:48:17

 611

 10

#rocketmq #架构 #linux +4
RocketMQ客户端编程模型

RocketMQ的运行架构和消息模型可以总结为"一个中心化的存储集群 + 一套标准化的发布订阅模型"。它通过做服务发现，做消息存储，再配合这两大客户端，构成了一个高吞吐、低延迟的分布式消息系统。

SYLGGTC0015
2026-04-01 17:34:15

 402

 9

#rocketmq
Kafka与RocketMQ读写模型及零拷贝技术深度对比

每个ConsumeQueue条目都是固定长度的（20字节），其中存储了该消息在CommitLog中的物理偏移量（Offset）（8字节）、消息总大小（Size）（4字节）以及消息Tag的哈希码（8字节）。这种“先读索引，再读数据”分离的模式，既保证了写入的绝对顺序性，又实现了消费时的高效查找。当消费者请求数据时，Kafka Broker可以直接将硬盘上的日志段文件（通常已存在于操作系统的页面缓存中

 隔壁小邓
2026-04-01 08:42:57

 332

 5

#kafka #rocketmq #分布式
手把手教你搭建基于Matlab/Simulink的插电式混合动力汽车4驱PHEV模型

基于Matlab/simulink的插电式混合动力汽车建模仿真模型4驱PHEV（比亚迪唐DM混动系统P2P4发动机——三擎四驱），包括整车HCU控制单元、发动机模型、驱动电机模型、ISG电机模型、AMT5档自动变速箱模型、驾驶员模型、电池能量管理控制模型等，建模详细清晰基于模型的整车策略开发思路、整车模型搭建流程（从最初输入输出确定——最后整个模型建立全过程）相当于手把手教学，新能源混动控制建模方

 OwvtDlhCgIz
2026-03-30 18:00:00

 312

 9

#rocketmq
2、RocketMQ的消息模型

但是，这里还是会造成一种分裂，消息最终是由Consumer来处理，但是消息却是由Broker推送过来的，也就是说，Consumer无法确定自己将要处理的是哪些消息。这时，就可以创建另外一个新的消费者组，并通过ConsumerFromWhere属性指定这个消费者组的消费起点，从而让这个新的消费者组去消费之前发送过的历史消息。这种异步发送的机制能够比较好的兼容消息的安全性以及生产者的高吞吐需求，是

 Nandeska
2026-03-26 13:24:30

 433

 10

#rocketmq
悠悠有品：RocketMQ 稳扛核心交易，Kafka 驱动海量数据，支撑高并发游戏饰品交易平台

悠悠有品早期主要依赖自建开源消息平台。基于清晰的架构设计，悠悠有品针对不同业务场景进行了合理的技术选型，引入 RocketMQ 和 Kafka，分别解决交易链路与数据链路中的关键问题。

阿里云云原生
2026-03-25 11:57:14

 525

 11

#rocketmq #kafka #游戏
AI 推理精细化流量治理实战：RocketMQ LiteTopic 的“千人千面”流控方案

Apache RocketMQ 5.x 版本推出了专为 AI 场景设计的核心特性——轻量主题模型 LiteTopic。它支持百万级轻量主题的创建和高性能动态订阅。

阿里云云原生
2026-03-24 15:23:49

 330

 10

#人工智能 #rocketmq
RocketMQ 两大核心特性深度拆解：事务消息与延时消息，从原理到实战全打通

RocketMQ作为阿里开源的金融级消息中间件，以高可靠、高吞吐、低延迟著称。其事务消息通过两阶段提交+回查机制，解决本地事务与消息发送的原子性问题；延时消息在5.x中升级为毫秒级任意时间定时消息，基于TimerStore与时间轮实现高性能调度，二者共同支撑分布式系统核心一致性与定时场景。

一叶飘零_sweet_
2026-03-24 07:15:00

 820

 18

#rocketmq #架构
RabbitMQ、Kafka对比（超详细），Kafka、RabbitMQ、RocketMQ的区别

kafka是apache开源的消息队列顶级项目之一，在大数据场景下使用较多，由linkedin开源，目前社区活跃，全球较多组织开始使用kafka来进行数据交换。kafka采用mq结构，broker有part分区的概念RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（Advanced Message Queuing Protocol，高级消息队列协议）的标

 隔壁小邓
2026-03-19 20:31:51

 398

 9

#rabbitmq #kafka #rocketmq
在windows上部署RocketMQ步骤

Apache RocketMQ：定义与核心作用一、定义Apache RocketMQ 是由阿里巴巴开源、后捐赠给 Apache 基金会的分布式消息队列（Message Queue）中间件，是一款高性能、高可靠、可扩展的异步消息传递与事件驱动系统，用于在分布式系统中实现解耦、异步、削峰填谷等核心能力。二、核心作用（解决什么问题）RocketMQ 主要解决分布式架构下的三大核心问题：1. 系统解耦（

weixin_73863355
2026-03-14 21:32:29

 525

 9

#rocketmq
高频方波注入永磁同步电机无位置传感器Simulink模型及其在DSP/ARM平台上的实际应用

咱先从Simulink模型里的方波生成说起。（4）另有采用全C语言编写的高频方波注入Simulink仿真模型，启动、加载工况均可运行，可直接在你现有的DSP、ARM等平台进行算法程序移植和实际工程实现，详见商品序号2;（4）另有采用全C语言编写的高频方波注入Simulink仿真模型，启动、加载工况均可运行，可直接在你现有的DSP、ARM等平台进行算法程序移植和实际工程实现，详见商品序号2;（1）注

 XvjeLeOxlZ
2026-03-11 18:15:00

 41

#rocketmq