背景 在业务发展过程中，会出现一些需要延时处理的场景，比如： a.订单下单之后超过30分钟用户未支付，需要取消订单 b.订单一些评论，如果48h用户未对商家评论，系统会自动产生一条默认评论 c.点我达订单下单后，超过一定时间订单未派出，需要超时取消订单等。。。 处理这类需求，比较直接简单 ...

异步消息队列 说道消息队列，你肯定会想到Kafka、Rabbitmq等消息中间件，这些专业的消息中间件提供了很多功能特性，当然他的部署使用维护都是比较麻烦的。如果你对消息队列没那么高要求，想要轻量级的，使用Redis就没错啦。 Redis通过list数据结构来实现消息队列.主要 ...

一、需求切入点 在公司做的一个系统业务需要有个定时提醒的功能（数据在mysql中），要求提醒的时间差精准到分钟 解决方案有: 使用定时器，每分钟执行一次，查符合提醒的数据，发起提醒（数据库连接与系统的负载都承受不住的！！） 将待提醒数据提前查出存进redis中，根据提醒时间设置 ...

继之前用rabbitMQ实现延时队列，Redis由于其自身的Zset数据结构，也同样可以实现延时的操作 Zset本质就是Set结构上加了个排序的功能，除了添加数据value之外，还提供另一属性score，这一属性在添加修改元素时候可以指定，每次指定后，Zset会自动重新按新的值调整 ...

实现思路 方式一 1. 使用redis zset 数据结构 2.使用score排序 score为过期时间点 3.启动线程不断取出排序第一个 比较score和当前时间点 如果score小于或等于当前时间 说明此数据过期 需要处理 4.处理完毕在zset中移除 ...

直接上代码了 重点是控制器这里 ； 我这里执行没有任何问题 因为是前俩天做的 就不贴结果了。 ...

背景 项目中的流程监控，有几种节点，需要监控每一个节点是否超时。按传统的做法，肯定是通过定时任务，去扫描然后判断，但是定时任务有缺点：1，数据量大会慢；2，时间不好控制，太短，怕一次处理不完，太长状态就会有延迟。所以就想到用延迟队列的方式去实现。 一，redis的过期key监控 1，开启过期 ...

来源：blog.csdn.net/qq330983778/article/details/99341671 业务流程 首先我们分析下这个流程 用户提交任务。首先将任务推送至延迟队列中。 延迟队列接收到任务后，首先将任务推送至job pool中，然后计算其执行时间。 然后生 ...