SpringBoot使用Redisson做延迟队列案列(超详细)

背景：

有些场景下，需要延迟触发一些任务。比如：延迟几秒钟发送短信或者邮件；某些业务系统回调，需要延时几秒钟后回调。

当然，实现延时触发的方式有很多，我这里采用 redisson 的 RDelayedQueue，一是因为接入简单，二是没有分布式的问题。毕竟现在微服务大行其道。

接下来，我们进入正题。

使用步骤：

使用 延迟队列呢，一般就几个步骤:

1. 添加消息进入延迟队列
2. 从延迟队列中取出消息消费

具有步骤:

1. 新建springBoot项目,并导入pom.xml相关依赖 <dependencies> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!--Redisson支持--> <dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.12.0</version> </dependency> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.9</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> </dependencies>
2. 项目结构如下

调试

1.正常情况

2.我调用完接口,redisson突然down调,消息依然能正常被消费

我的demo也贡献给大家,有需要的可以随时去下载 Gitee地址: