如何利用Redis實現延時處理

背景 最近需要做一個延時處理的功能，主要是從kafka中消費消息後根據消息中的某個延時字段來進行延時處理，在實際的實現過程中有一些需要注意的地方，記錄如下。 實現過程 說到java中的定時功能，首先想到的Timer和ScheduledThreadPoolExecutor，但是相比之下Timer可以排除，主要原因有以下幾點： Timer使用的是絕對時間，系統時間的改變會對Timer產生一定的影響；而

>>阅读原文<<