使用Redis实现过期回调通知（redis 过期回调通知）

回调通知，是指在一条系统日志完成处理之前，要求系统调用另一个系统的接口来反馈处理的结果，称之为回调通知。系统在处理该系统日志时，必须正确通过回调方式及时通知给服务应用程序，因此，在现代高并发分布式系统中，回调通知功能是必不可少的。

最常用的延迟任务处理方式，就是使用Redis列队进行实现。实际上，Redis可以通过设置TTL（time to live）实现数据过期时自动回调处理程序，从而实现超时回调通知功能。

下面将介绍Redis实现TTL回调的流程：

1）先将任务放入Redis的某个列队中；

2）设置每个任务的TTL，在此时间内任务未完成，则该任务将被自动删除；

3）在每个任务的TTL时间到期时，Redis会自动发出一条信号（通知），以便调用回调处理程序；

4）调用回调函数后，若任务已经完成，则执行操作，若任务未完成，则可以重新设置TTL，也可以根据需要进行其它操作。

以上就是Redis实现TTL回调的流程，下面以一个简单的案例来说明如何使用Redis来实现回调，代码如下：

// 将任务放入Redis列队

const taskId = awt Redis.lpush(‘callback’,JSON.stringify(task))

// 设置任务的TTL

awt Redis.expire(‘callback’, 10)

// 设置回调函数

Redis.on(‘message’, async (channel, message) => {

// 获取任务

const task = JSON.parse(message)

// 判断任务是否可以执行

if(task.id === taskId && task.status === ‘pending’){

// 执行任务

awt execTask()

// 更新任务状态

awt updateTaskStatus()

}

})

// 订阅信道

Redis.subscribe(‘callback’)

以上代码，我们将任务放入Redis缓存列队中，并设置TTL，当任务未在规定时间内完成，Redis将发出“message”通知，触发回调处理程序，最终反馈处理结果。

Redis的TTL技术实现的超时回调，可以成功的解决高并发的任务在规定时间内完成的问题。它可以更大的简化系统开发，并且运行效率也能够达到很高的极限。