Java-214 RocketMQ 核心特性全解：顺序/过滤/事务/定时/重试/流控/死信队列

TL;DR

消息的发布是指某个生产者向某个Topic发送消息，消息的订阅是指某个消费者关注了某个Topic中带有某些Tag的消息。

消息有序是指一类消息消费时，能按照发送的顺序来消费，例如：一个订单产生了三条消息分别是订单创建、订单付款、订单完成。消费时要按照这个顺序消费才能有意义，但是同时订单之间是可以并行消费的，RocketMQ 可以严格的保证消息有序。

RocketMQ的消费者可以根据Tag进行消息过滤，也支持自定义属性过滤，消息过滤目前是在Broker端实现的，优点是减少了对于Consumer无用消息的网络传输，缺点是增加了Broker的负担、而且实现相对复杂。

RocketMQ支持消息的高可靠，影响消息可靠性的几种情况：

其中情况1-4都属于硬件资源可以恢复，RocketMQ在这四种情况下能保证消息不丢，或者丢失少量数据。情况5、6属于单点故障，且无法恢复。

RocketMQ 通过异步复制，可保证99%的消息不丢失，但仍然会有极少的消息可能丢失。通过同步双写技术可以完全避免单点。

至少一次 At Least Once 指的是每个消息必须投递一次，Consumer先Pull消息到本地，消息完成后，才向服务器返回ACK，如果没有消费一定不会ACK消息，所以RocketMQ可以很好的支持此特性。

回溯消费是指消费者(Consumer)已经成功消费的消息，由于业务需求需要重新消费时，Broker提供的一种消息重放机制。

RocketMQ 事务消息（Transactional Message）是一种特殊的消息机制，它能够将应用本地事务和消息发送操作绑定到一个全局事务中，确保这两个操作要么同时成功，要么同时失败。

半消息阶段：
- 生产者发送”半消息”（PREPARED状态）到Broker
- Broker将消息存入特殊队列，此时消费者不可见
本地事务执行：
- 生产者执行本地事务
- 根据本地事务结果提交或回滚事务消息
事务状态确认：
- 成功：Broker将消息转为可消费状态（COMMIT_MESSAGE）
- 失败：Broker丢弃该消息（ROLLBACK_MESSAGE）
状态回查机制：
- 若生产者未及时确认状态，Broker会主动回查事务状态
- 默认回查次数为15次，间隔时间可配置

定时消息（延迟队列）是指消息发送到Broker后，不会立即被消费，等待特定时间投递给真正的Topic。

Broker 有配置项 MessageDelayLevel，默认值为：

一共18个等级。

Consumer消费消息失败后，要提供一种重试机制，令消息再消费一次。Consumer 消费消息失败通常可以认为有以下几种情况：

生产者在发送消息时：

消息重投保证消息尽可能发送成功，不丢失，但可能会造成消息重复。

死信队列是消息队列系统中用于处理无法被正常消费消息的重要机制。