有些场景下,需要延迟触发一些任务。比如:延迟几秒钟发送短信或者邮件;某些业务系统回调,需要延时几秒钟后回调。
当然,实现延时触发的方式有很多,我这里采用 redisson 的 RDelayedQueue,一是因为接入简单,二是没有分布式的问题。毕竟现在微服务大行其道。
接下来,我们进入正题。
使用步骤:使用 延迟队列呢,一般就几个步骤:
- 添加消息进入延迟队列
- 从延迟队列中取出消息消费
- 新建springBoot项目,并导入pom.xml相关依赖
org.projectlombok lomboktrue org.springframework.boot spring-boot-starter-testtest org.redisson redisson3.12.0 org.apache.commons commons-lang33.9 org.springframework.boot spring-boot-starter-web - 项目结构如下
1.正常情况
2.我调用完接口,redisson突然down调,消息依然能正常被消费
我的demo也贡献给大家,有需要的可以随时去下载
Gitee地址:redisson延时队列demo: springBoot项目使用redisson做延迟队列



