DDMQ
DDMQ copied to clipboard
Chronos 内置的时间轮服务是哪个代码?
@flylee85 你说的是MqPushService.java吧。 其实不是严格的时间轮实现,而是根据当前的seekTimestamp去逐个seek。
// 迭代出当前 seekTimestamp 下所有数据
int count = 0;
try (RocksIterator it = RDB.newIterator(CFManager.CFH_DEFAULT)) {
// more code
}