关于5.0定时消息原理问题

[rockit-ba]

我的一个疑问点是官方文档是这样说的

如果将定时消息存储到 磁盘，那么定时任务是每秒从磁盘全量遍历吗，虽然我知道肯定不是这样实现的，但是又不可能把所有的延迟消息全部放在内存的延迟队列中，而且磁盘上的消息也做不到按照时间戳排序，因为一直有新的不同的消息进来。

所以我比较好奇是如何实现的，或者有相关的文档吗

[rockit-ba]

RocketMQ 5.0 实现定时消息功能通过延迟队列和磁盘存储两种方式来实现。在内存中有一个延迟队列，它维护着所有的延迟消息，这些消息会在到达指定的延迟时间后被发送。定时任务会定期扫描延迟队列，将到期的消息发送出去。但是，如果延迟队列存储的消息太多，不可能全部存储在内存中。所以部分消息会存储到磁盘上。对于磁盘上的消息，RocketMQ会采用分块存储的方式，并使用二进制堆结构将其按照时间戳排序。这样可以避免频繁的磁盘读写操作，提高系统的性能。

是这样做的吗

[mxsm]

@rockit-ba 看一下这个文档https://shimo.im/docs/gXqme9PKKpIeD7qo/read

[rockit-ba]

@rockit-ba 看一下这个文档https://shimo.im/docs/gXqme9PKKpIeD7qo/read

好的，谢谢