要提供一种机制，可以挄照时间维度来回退消费迕度。 RocketMQ 支持挄照时间回溯消费，时间维度精确到毫秒，可以吐前回溯，也可以吐后回溯。 4.12 消息堆积 消息中间件的主要功能是异步解耦，迓有个重要功能是挡住前端的数据洪峰，保证后端系统的稳定性，返就要 求消息中间件具有一定的消息堆积能力，消息堆积分以下两种情冴： (1). 消息堆积在内存 Buffer，一旦超过内存 Buffer，可以根据一定的丢弃策略来丢弃消息，如 直接迒回，而同步刷盘需要等待刷盘完成才迒回， 同步刷盘流程如下： (1). 写入 PAGECACHE 后，线程等待，通知刷盘线程刷盘。 (2). 刷盘线程刷盘后，唤醒前端等待线程，可能是一批线程。 (3). 前端等待线程吐用户迒回成功。 项目开源主页：https://github.com/alibaba/RocketMQ 20 7.3 消息查询 7.3.1 挄照 Message

RabbitMQ是AMQP规范的参考实现，AMQP是一个线路层协议，面面俱到，很系统，也稍显复杂。 前RabbitMQ已经成为OpenStack Iaas平台首选的消息服务，其背后的支持力度不言而喻。 ActiveMQ最初主要的开发者在LogicBlaze，现在主要开发红帽，是JMS规范的参考实现，也是Apach 旗下的老牌消息服务引擎。JMS虽说是一个API级别的协议，但其内部还是定义了一些实现约束，不 缺少多语言支撑。Act The Apache Software Foundation Announces Apache® RocketMQ™ as a Top-Level Project ● Apache RocketMQ开发者指南 ● 阿里RocketMQ是怎样孵化成Apache顶级项目的？ 原文链接：Apache RocketMQ 介绍

4.2 ReadSocketService 读取 slave 通过 HAClient 向 master 返回同步 commitLog 的物理偏移量 phyOffset 值 通知前端线程，如果是同步复制的话通知是否复制成功 Slave 通过 HAClient 建立与 master 的连接， 来定时汇报 slave 最大物理 offset，默认 5 秒汇报一次也代表了跟

OpenMessaging AMQP • 简单灵活 • 云原⽣生 • ⼚厂商中⽴立 • 语⾔言⽆无关 • ⾯面向消息和流的标准 关注阿⾥里里巴巴中间件微信公众号，与技术同⾏行行。 关注RocketMQ中国开发者公众号

扫一扫加入作者公众号 扫一扫关注 中间件兴趣圈 RocketMQ 官微 扫一扫关注【阿里巴巴云原生】公众号 阿里云开发者“藏经阁” 获取第一手技术干货 海量免费电子书下载 作者简介 作者简介 丁威，《RocketMQ 技术内幕》作者，RocketMQ 官方社区优秀布道师，荣获 CSDN2020 博客之星亚军；担任中通快递研发中心资深架构师，维护『中间件兴趣圈』公 众号，主打成体系剖析 busy 四、小结 本文主要对实际中常遇到的关于消息发送方面经常遇到的问题进行剖析，从而提出解决 方案。 扫一扫加入作者公众号 中间件兴趣圈 扫一扫关注 RocketMQ 官微 阿里云开发者“藏经阁” 扫一扫关注【阿里巴巴云原生】公众号 获取第一手技术干货 海量免费电子书下载