..................................................................................... 44 14.3.4 优化每条消息消费过程 .......................................................................................... 20 6 C1: 4 C2: 4 c3~C6: 3 项目开源主页：https://github.com/alibaba/RocketMQ 25 7.10 单队列并行消费 0 1 2 3 4 5 6 7 8 9 10 单队列幵行消费采用滑劢窗口方式幵行消费，如图所示，3~7 的消息在一个滑劢窗口区间，可以有多个线程幵行消 费，但是每次提交的 Offset consumeThreadMin 10 消费线程池数量 consumeThreadMax 20 消费线程池数量 consumeConcurrentlyMaxSpan 2000 单队列并行消费允许的最大跨度 pullThresholdForQueue 1000 拉消息本地队列缓存消息最大数 pullInterval 0 拉消息间隔，由于是长轮询，所以 为 0，但是如果应用为了流控，也

默认批量个数为一个 ConsumeRequest 任务 run 方法执行 判断 proccessQueue 是否被 droped 的， 废弃直接返回，不在消费消息 构建并行消费上下文 给消息设置消费失败时候的 retry topic，当消息发送失败的时候发送到 topic 为%RETRY%groupname 的队列中 调 MessageListenerConcurrently

en M essa gin g 主从复制架构升级，性能提升数倍 RAFT 存储生产可用 rocketm q-con n ect 进入孵化 2021 5.0 -p rev iew 发布 性能优化、PoP 消费，多存储目录， 轻量级队列 rocketm q-strea m s 轻量级实时计算 引擎发布 5.0 消息事件流融合处理平台 Sta r: 1 .7w C on tributor:

息订阅机制，满足大多数消费场景。 特点 ● RocketMQ支持异步实时刷盘，同步刷盘，同步复制，异步复制。具有高可靠性。不会因为操作系 的崩溃而导致数据丢失。 ● RocketMQ经过一系列的实践和优化，处理速度从最初的10,000TPS到目前已经超过50,000TPS。 纯比较TPS的话虽然还不如Kafka的百万级别，但在支持事务的消息中间件来说已经是非常优秀了。 ● RocketMQ采用长轮询，消息投递延迟通常在几个毫秒左右。