作者：家泽 ApsaraMQ 与时俱进，砥砺前行 阿里云消息队列从诞生开始，至今已有十余年。今年，阿里云消息产品全面品牌升级为 ApsaraMQ，与时俱进，砥砺前行。 2012 年，RocketMQ 诞生于集团内部，用于淘宝交易等核心业务链路。历经集团多年来双 11 万亿级的考验、稳定性的打磨，依
2023-12-24
本文整理于 2023 年云栖大会林清山带来的主题演讲《Apache RocketMQ 云原生统一消息引擎》 演讲嘉宾： 林清山（花名：隆基），Apache RocketMQ 联合创始人，阿里云资深技术专家，阿里云消息产品线负责人。国际消息领域专家，致力于消息、实时计算、事件驱动等方向的研究与探索，推
2023-12-24
这篇文章，我们聊聊如何应对 RocketMQ 消息堆积。图片1 基础概念消费者在消费的过程中，消费的速度跟不上服务端的发送速度，未处理的消息会越来越多，消息出现堆积进而会造成消息消费延迟。虽然笔者经常讲：RocketMQ 、Kafka 具备堆积的能力，但是以下场景需要重点关注消息堆积和延迟的问题：业
2023-12-21
RocketMQ是Java兄弟们常用的消息中间件，虽说常用，但对于RocketMQ架构经常忘记。究其原因就l两点：忙于业务开发然后长时间不看则忘了、不理解架构设计的根本原因记不牢。本文用大白话描述架构设计过程，牢记RocketMQ架构。一、架构的思考过程首先，在记框架的原理和架构时，要先把握全局的脉
2023-12-18
嗨，小伙伴们！小米在这里啦！今天我们要聊的话题是社招面试中一个经典而又百思不得其解的问题——“RocketMQ如何保证顺序性？”不用担心，小米来给你揭秘RocketMQ的秘密武器，让你轻松过关面试大关！引言：为什么要谈顺序性？首先，我们得明白为什么在消息队列中要讲究消息的顺序性。假设你正在开发一个电
2023-12-15
大家好，我是三友~~故事的开头是这样的最近有个兄弟私信了我一张截图图片我一看截图内容，好家伙，原来是我一年多前立的flag倒不是我忘了这件事，我后来也的确写了一篇的关于RocketMQ运行的原理的文章只不过这篇文章是从上帝的视角去看待RocektMQ一条消息整个生命周期的过程所以就没有具体的分析事务
2023-11-08
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ 版本 5.1.0 背景 继之前研究过的RocketMQ发送消息还有这种坑？遇到SYSTEM_BUSY不重试？ 今天我们来分析分析RocketMQ什么情况下会出现system bu
2023-10-12
RocketMQ的下载、安装和配置 RocketMQ的Binary版是一些编译好的jar和辅助的shell脚本，可以直接从官网找到下载链接（http://rocketmq.apache.org/dowloading/releases/），也可以下载源码自己编译。 系统要求：64bit的Linux、U
2023-10-12
RabbitMQ 和 RocektMQ 属于业务消息类的消息队列，它们的特点是功能丰富、低延时、数据高可靠性、消息可追踪等等，同时也支持延时消息、优先级队列、消息过滤等功能特性。 RabbitMQ 发展较早，RocketMQ 则是新生的消息类的消息队列，从功能、集群化、稳定性、性能来看，Rocket
2023-10-04
Spring Cloud 微服务系列文章，点击上方合集↑ 1. 简介 RocketMQ是一款开源的分布式消息中间件，它具有高可靠性、高性能和可伸缩性，被广泛用于构建分布式系统中的可靠消息传递服务。 官网地址： rocketmq.apache.org/ 2. 工作流程 启动 NameServer 启
2023-09-28
前言 延迟消息在业务场景中使用的非常多，订单失效，过期通知等功能都可以借助延迟消息机制来实现。本文将从源码层面来分析Rocketmq的延迟消息实现原理机制。 一、延迟消息的使用 先看下延迟消息的使用，发送消息逻辑和普通消息一样，只要在生产者端将Message对象中设置延迟消息
2023-09-27
前言 上一篇文章已经介绍了RocketMQ的功能，架构，从本文开始，我们将开始深入源码层面，一步一步学习RocketMQ设计原理。 在消息队列中，生产者负责发送消息到Broker,本文分享RocketMQ发送消息的实现原理以及一些注意的事项。 一、生产者端的发送流程 一般来说我们的业务应用端是生产者
2023-09-25
前言 上文已经介绍了分布式消息队列的常见概念，从本文开始，将分多篇文章逐步对RocketMQ这款分布式消息队列的架构，功能，以及不同功能的源码实现原理进行分析。本文主要是介绍RocketMQ的功能，架构，加深对RocketMQ的认识。 RocketMQ是什么？ Rocketmq是由阿里巴巴
2023-09-24
windows RocketMQ与可视化监控平台安装 安装日期2023.09.21 最新版 RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件，搭建RocketMQ需要先配置JAVA环境变量,需要有JAVA_HOME。 下载安装包 进入官网选择需要的版本下载安装包（以下以5.1.3为
2023-09-22
Golang微服务框架Kratos应用RocketMQ消息队列 消息队列是一种异步的服务间通信方式，适用于无服务器和微服务架构。消息在被处理和删除之前一直存储在队列上。每条消息仅可被一位用户处理一次。消息队列可被用于分离重量级处理、缓冲或批处理工作以及缓解高峰期工作负载。 消息队列是大型分布式系统不
2023-09-22
本地docker搭建RocketMQ用于测试参考# Docker 部署 RocketMQ 5.x RocketMQ官方的Python客户端是 rocketmq-client-python 这个客户端只支持Linux和macOS，并且需要安装额外的C++库支持。 以centos为例，安装rocketm
2023-09-12
Apache RocketMQ 是一个分布式消息中间件系统，用于实现高可用、高性能的消息传递。 1、创建RocketMQ容器共享网络 RocketMQ有多个服务，需要分别创建容器，并且需要互相通信。 docker network create rocketmq # docker network ls
2023-09-12
环境：springboot2.4.12 + RocketMQ4.8.0依赖 org.springframework.boot spring-boot-starter-web org.apache.rocketmq rocketmq-spring-boot-starter 2.
2023-09-05
作者：隆基 一致性 首先来看 RocketMQ 的第一个特性-事务消息，事务消息是 RocketMQ 与一致性相关的特性，也是 RocketMQ 有别于其他消息队列的最具区分度的特性。 以大规模电商系统为例，付款成功后会在交易系统中订单数据库将订单状态更新为已付款。然后交易系统再发送一条消息给 R
2023-08-29
我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。前面已经介绍了 生产消息、存储消息 两大块内容，那接下来，我们白话一下RocketMQ是如何消费消息的，揭秘消息消费全过程。注意，如果白话中不小心提到相关代码配置与类名，请参考RocketMQ 4.9.4版本关键字摘要核
2023-08-24