Kafka延时队列如何实现高效消息处理？

本文共计6236个文字，预计阅读时间需要25分钟。

一、简介

TimingWheel是Kafka时间轮的实现，内部包含了一个TimerTaskList数组。每个数组包含一些链表组成的TimerTaskEntry事件，每个TimerTaskList表示时间轮的某个时间格。这个时间格代表的时间。

一、延时队列 1. 简介

TimingWheel是kafka时间轮的实现，内部包含了⼀个TimerTaskList数组，每个数组包含了⼀些链表组成的TimerTaskEntry事件，每个TimerTaskList表示时间轮的某⼀格，这⼀格的时间跨度为tickMs，同⼀个TimerTaskList中的事件都是相差在⼀个tickMs跨度内的，整个时间轮的时间跨度为interval = tickMs * wheelSize，该时间轮能处理的时间范围在cuurentTime到currentTime + interval之间的事件。