RocketMQ

RocketMQ发布5.0版本：架构大重构，代码变更比例高达60%

RocketMQ 是一个来自阿里巴巴的分布式消息中间件，于 2012 年开源，并在 2017 年正式成为 Apache 顶级项目。

RocketMQ消息轨迹指南(Message Trace)

这里贴出Broker端开启消息轨迹特性的properties配置文件内容：

RocketMQ最佳实践

一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags("...

RocketMQ设计

在上面的RocketMQ的消息存储整体架构图中可以看出，RocketMQ采用的是混合型的存储结构，即为Broker单个实例下所有的队列共用一个日志数据文件（即为CommitLog）来存储。(1)同步刷盘：如上图所示，只有在消息真正持久化至磁盘后RocketMQ的Broker端才会真正返回给Producer端一个成功的ACK响应。

RocketMQ样例

在基本样例中我们提供如下的功能场景：

RocketMQ权限管理(Auth Management)

对RocketMQ的Topic资源访问权限控制定义主要如下表所示，分为以下四种

RocketMQ架构

RocketMQ运维管理

这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。

RocketMQ Dledger快速搭建(Quick Start)

该文档主要介绍如何快速构建和部署基于 DLedger 的可以自动容灾切换的 RocketMQ 集群。

RocketMQ特性（features）

消息的发布是指某个生产者向某个topic发送消息；消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。