- 很多同学都在使用 RocketMQ 时，经常会遇到消息堆积的问题。这篇文章，我们聊聊消息堆积的概念，以及如何应对消息堆积。 1 基础概念消费者在消费的过程中，消费的速度跟不上服务端的发送速度，未处理的消息会越来越多，消息出现堆积进而会造成消息消费延迟。虽然笔者经常讲：RocketMQ 、Kafka 具备堆积的能力，但是以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不匹配造成的持... 很多同学都在使用 RocketMQ 时，经常会遇到消息堆积的问题。这篇文章，我们聊聊消息堆积的概念，以及如何应对消息堆积。 1 基础概念消费者在消费的过程中，消费的速度跟不上服务端的发送速度，未处理的消息会越来越多，消息出现堆积进而会造成消息消费延迟。虽然笔者经常讲：RocketMQ 、Kafka 具备堆积的能力，但是以下场景需要重点关注消息堆积和延迟的问题：业务系统上下游能力不匹配造成的持...
- 提到主从复制，我们可能立马会联想到 MySQL 的主从复制。MySQL 主从复制是 MySQL 高可用机制之一，数据可以从数据库服务器主节点复制到一个或多个从节点。这篇文章，我们聊聊 RocketMQ 的主从复制，希望你读完之后，能够理解主从复制的精髓。 1 同步与异步在 RocketMQ 的集群模式中，Broker 分为 Master 与 Slave，一个 Master 可以对应多个 Sl... 提到主从复制，我们可能立马会联想到 MySQL 的主从复制。MySQL 主从复制是 MySQL 高可用机制之一，数据可以从数据库服务器主节点复制到一个或多个从节点。这篇文章，我们聊聊 RocketMQ 的主从复制，希望你读完之后，能够理解主从复制的精髓。 1 同步与异步在 RocketMQ 的集群模式中，Broker 分为 Master 与 Slave，一个 Master 可以对应多个 Sl...
- RocketMQ 支持两种消息模式：集群消费（ Clustering ）和广播消费（ Broadcasting ）。集群消费：同一 Topic 下的一条消息只会被同一消费组中的一个消费者消费。也就是说，消息被负载均衡到了同一个消费组的多个消费者实例上。广播消费：当使用广播消费模式时，每条消息推送给集群内所有的消费者，保证消息至少被每个消费者消费一次。我们重点讲解下集群消费的消费流程 ，因为集... RocketMQ 支持两种消息模式：集群消费（ Clustering ）和广播消费（ Broadcasting ）。集群消费：同一 Topic 下的一条消息只会被同一消费组中的一个消费者消费。也就是说，消息被负载均衡到了同一个消费组的多个消费者实例上。广播消费：当使用广播消费模式时，每条消息推送给集群内所有的消费者，保证消息至少被每个消费者消费一次。我们重点讲解下集群消费的消费流程 ，因为集...
- RocketMQ 是大家耳熟能详的消息队列，开源项目 rocketmq-spring 可以帮助开发者在 Spring Boot 项目中快速整合 RocketMQ。 这篇文章会介绍 Spring Boot 项目使用 rocketmq-spring SDK 实现消息收发的操作流程**，同时笔者会从开发者的角度解读 SDK 的设计逻辑。 RocketMQ 是大家耳熟能详的消息队列，开源项目 rocketmq-spring 可以帮助开发者在 Spring Boot 项目中快速整合 RocketMQ。 这篇文章会介绍 Spring Boot 项目使用 rocketmq-spring SDK 实现消息收发的操作流程**，同时笔者会从开发者的角度解读 SDK 的设计逻辑。
- 大家好，我是勇哥 。1024 , 程序员节，圆了我一个小小的梦。花了半年时间，我写了一本电子书 ，书名是：《RocketMQ4.X设计精要》，我想在今天分享给各位。这本书一共包含十五章，接近 10 万字，180 张图，按照 RocketMQ 的知识体系一章一章展开。很多年前，一位七牛的资深架构师曾经说过这样一句话：Nginx+ 业务逻辑层 + 数据库 + 缓存层 + 消息队列 ，这种模型几乎... 大家好，我是勇哥 。1024 , 程序员节，圆了我一个小小的梦。花了半年时间，我写了一本电子书 ，书名是：《RocketMQ4.X设计精要》，我想在今天分享给各位。这本书一共包含十五章，接近 10 万字，180 张图，按照 RocketMQ 的知识体系一章一章展开。很多年前，一位七牛的资深架构师曾经说过这样一句话：Nginx+ 业务逻辑层 + 数据库 + 缓存层 + 消息队列 ，这种模型几乎...
- 首先确保安装了docker & docker-compose（建议参考官方文档：https://docs.docker.com/engine/ ，https://docs.docker.com/compose/install/）然后准备composer.yml文件（启动命令：docker-compose up -d)version: "3.0"services: namesrv: ... 首先确保安装了docker & docker-compose（建议参考官方文档：https://docs.docker.com/engine/ ，https://docs.docker.com/compose/install/）然后准备composer.yml文件（启动命令：docker-compose up -d)version: "3.0"services: namesrv: ...
- Apache RocketMQ是一款分布式消息中间件，由Apache软件基金会开发维护，具有高吞吐量、低延迟、高可靠性等特点，广泛应用于分布式系统中的异步通信、流量削峰、系统解耦等场景。随着容器化技术的普及，采用Docker部署RocketMQ可以显著简化环境配置、提高部署一致性和运维效率。 Apache RocketMQ是一款分布式消息中间件，由Apache软件基金会开发维护，具有高吞吐量、低延迟、高可靠性等特点，广泛应用于分布式系统中的异步通信、流量削峰、系统解耦等场景。随着容器化技术的普及，采用Docker部署RocketMQ可以显著简化环境配置、提高部署一致性和运维效率。
- 更全面的原理知识，更详细的参数说明，更多样的呈现方式，助您在业务中更高效的实现消息传递。 更全面的原理知识，更详细的参数说明，更多样的呈现方式，助您在业务中更高效的实现消息传递。
- 本文详细解析了 RocketMQ 的核心架构、消息领域模型、关键特性和应用场景，帮助深入理解消息中间件的工作原理。关注【mikechen的互联网架构】，10年+BAT架构经验倾囊相授。 本文详细解析了 RocketMQ 的核心架构、消息领域模型、关键特性和应用场景，帮助深入理解消息中间件的工作原理。关注【mikechen的互联网架构】，10年+BAT架构经验倾囊相授。
上滑加载中
推荐直播
-
用码道，让你的AI作品三步上朋友圈2026/08/04 周二 19:00-20:00
林华鼎-华为云AI开发者运营负责人
从入门 · 到做AI应用 · 到企业级开发。不教编程，只教用AI · 零代码、有产出、能带走、可炫耀 · 每课人人动手实操
回顾中 -
华为云码道Agent集成与鸿蒙实战2026/08/11 周二 19:00-21:00
王一男-华为云码道产品规划专家；李炎-华为云码道产品专家；彭江敏-华为云鸿蒙端云一体化开发专家
本次直播带你解读华为云码道7月份产品新特性、新功能。更有专家演示码道Agent Space × 钉钉机器集成实战，从0到1打通消息通道；码道鸿蒙端云一体化实战，快速搭建员工签到系统。
回顾中 -
基于华为云码道，构建你的定制化AI搭子2026/08/14 周五 09:00-11:30
明亮-华为云开发者发展与支持部部长
本期直播将向您全面介绍华为云码道产品，并基于码道手把手教你部署自己的定制化AI陪伴搭子。
回顾中
热门标签