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

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

一、简介TimingWheel是Kafka时间轮的实现，内部包含一个TimerTaskList数组，每个数组包含若干链表组成的TimerTaskEntry事件。每个TimerTaskList表示时间轮的某个刻度，该刻度的时间表示时间轮上的一个时间点。

一、延时队列

1. 简介

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