如何利用Redis实现延时处理

背景 最近需要做一个延时处理的功能，主要是从kafka中消费消息后根据消息中的某个延时字段来进行延时处理，在实际的实现过程中有一些需要注意的地方，记录如下。 实现过程 说到java中的定时功能，首先想到的Timer和ScheduledThreadPoolExecutor，但是相比之下Timer可以排除，主要原因有以下几点： Timer使用的是绝对时间，系统时间的改变会对Timer产生一定的影响；而

>>阅读原文<<