系列 · 后端与中间件
RocketMQ 系列
共 16 篇,按发布顺序排列。完整路线图与合订版在公众号「方家小白」回复关键词 BACKEND 领取;本页全部文章免费可读。
RocketMQ系列-开篇
开篇 写这篇文章的时间是 2021 年 9 月 1 日,不知道是否有勇气写完全部系列之后再发布给大家,这只能算是自己学习 RocketMQ 的笔记吧。希望在2021年的年底能够将整…
Rocket系列-入门
RocketMQ 介绍 截止 2021 年 9 月 1 日, RocketMQ 最新版本是 4.9.1 。 最新 Star 数为 1.5w . fork 数量是 8.4k . 发展…
RocketMQ系列-RocketMQ概念
RocketMQ概念 我在学习 RocketMQ 的时候,看到文档中介绍了很多的概念。我非常反感,但是又没有办法,没有这些概念,就没办法更好的去学习后面的内容,当后面使用很多名词来…
RocketMQ系列-搭建RocketMQ集群
搭建RocketMQ集群 根据之前的了解,我们已经知道了RocketMQ可以单机部署,支持集群部署。 RocketMQ 支持以下集中部署方式 1.单Master模式部署 , 2.多…
RocketMQ样例:基本的消息生产和消费
首先我们来学习一个简单的消费生产和消费的 demo . 生产消息 RocketMQ , 给我们提供了三种简单的消息生产方式, 1.同步发送 , 2.异步发送 , 3.直接发送,不关…
RocketMQ系列-在Java应用中的使用
上一篇文章中我们成功地搭建了几种RocketMQ的部署方式。 这篇文章,我们就来看一下RocketMQ所支持的消息类型在Java应用中的使用。 加入依赖 在上一篇文章中,我们已经使…
RocketMQ样例:全局顺序消息
消息有序指的是可以按照消息的发送顺序来消费( FIFO )。 RocketMQ 可以严格的保证消息有序,可以分为分区有序或者全局有序。 顺序消费的原理解析: 在默认的情况下消息发送…
RocketMQ样例:事务消息
事务消息共有三种状态,提交状态、回滚状态、中间状态: TransactionStatus.CommitTransaction : 提交事务,它允许消费者消费此消息。 Transac…
RocketMQ样例:延时消息
启动消费者等待传入订阅消息 发送延时消息 验证 您将会看到消息的消费比存储时间晚 10 秒。 延时消息的使用场景 比如电商里,提交了一个订单就可以发送一个延时消息, 1h 后去检查…
RocketMQ样例:批量消息
批量消息样例 批量发送消息能显著提高传递小消息的性能。限制是这些批量消息应该有相同的 topic ,相同的 waitStoreMsgOK ,而且不能是延时消息。此外,这一批消息的总…
RocketMQ样例:过滤消息
在大多数情况下, TAG 是一个简单而有用的设计,其可以来选择您想要的消息。例如: 消费者将接收包含 TAGA 或 TAGB 或 TAGC 的消息。但是限制是一个消息只能有一个标签…
RocketMQ系列-架构设计之启动
之前我们已经学习了 RocketMQ 是由四个部分组成的。这篇文章更加深入的来看看这个四个部分。 NameServer 接下来,我们来看 NameServer 的相关内容,我们都知…
RocketMQ系列-架构设计之消息
上一篇文章RocketMQ架构设计之启动过程解析 分析了 NameServer , Broker , Producer , Consumer 四个部分的启动过程, 这边文章我们分析…
RocketMQ事务实现原理
最近有点浮躁,玩了一个周, 没有写文章了。今天继续搞 RocketMQ 的事务实现。 往期文章 RocketMQ搭建 RocketMQ架构设计之启动 RocketMQ架构设计之消息…
RocketMQ 消息可靠性实现原理
常用的绝大多数消息队列,如 RocketMQ 、 RabbitMQ 等在消息传输上都只能保证 至少传输成功一次( At least once ) , 但是 不能保证只传输成功一次(…
RocketMQ 消息刷盘过程详解
在 RocketMQ架构设计之消息 这篇文章中, 我们学习了 消息发送到消费 的整体流程。这篇文章,我们一起来看看 MappedFile 的实现细节. 引言 我们都知道的是 Roc…
配套资料 · 免费领取
本文属于「BACKEND」资料包范围:中间件源码阅读路线图。按 RocketMQ / Redis / MySQL 分章节的完整路线。
在公众号「方家小白」回复关键词 BACKEND 即可领取。全文无需关注即可阅读。
BACKEND