然后重启redis
2，使用redis过期监听实现延迟队列继承KeyExpirationEventMessageListener类，实现父类的方法，就可以监听key过期时间了。当有key过期，就会执行这里。这里就把需要的key过滤出来，然后发送给kafka队列。
可以看的出来，这种方式其实是很简单的，但是有几个问题需要注意，一是，这个尽量单机运行，因为多台机器都会执行，浪费cpu，增加数据库负担。二是，机器频繁部署的时候，如果有时间间隔，会出现数据的漏处理。
二，redis的zset实现延迟队列 1，生产者实现可以看到生产者很简单，其实就是利用zset的特性，给一个zset添加元素而已，而时间就是它的score。
2,消费者实现消费者的代码也不难，就是把已经过期的zset中的元素给删除掉，然后处理数据。
可以看到这种方式其实是比上个方式要好的。因为，他的那两个缺点都被克服掉了。多台机器也没事儿，也不用再担心部署时间间隔长的问题。
总结两个方式都是不错的，都能解决问题。碰到问题，多思考，多总结。
到此这篇关于redis实现延时队列的两种方式(小结)的文章就介绍到这了,更多相关redis 延时队列内容请搜索七叶笔记以前的文章或继续浏览下面的相关文章希望大家以后多多支持七叶笔记！
