RocketMQ 一行代码造成大量消息丢失 < 116 该方法是在 BrokerFastFailure 中定义的，通过名称即可以看成其设计目的： Broker 端快速失败机制。 Broker 端快速失败其原理图如下： 消息发送者向 Broker 发送消息写入请求，Broker 端在接收到请求后会首先放入一 个队列中(SendThreadPoolQueue)，默认容量为 10000。 Broker 会

判断是否是正常恢复，系统启动的启动存储服务(DefaultMessageStore)的时候会创 建一个临时文件 abort, 当系统正常关闭的时候会把这个文件删掉 ，这个类似在 linux 下打开 vi 编辑器生成那个临时文件， 所有当这个 abort 文件存在，系统认为是异常恢 复 1） 先按照正常流程恢复 Consume Queue 为什么说先正常恢复， 那么异常恢复在哪呢？ 当 broker