SpringBoot怎么集成Redisson实现延迟队列

今天小编给大家分享一下SpringBoot怎么集成Redisson实现延迟队列的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。

使用场景

1、下单成功，30分钟未支付。支付超时，自动取消订单

2、订单签收，签收后7天未进行评价。订单超时未评价，系统默认好评

3、下单成功，商家5分钟未接单，订单取消

4、配送超时，推送短信提醒

……

对于延时比较长的场景、实时性不高的场景，我们可以采用任务调度的方式定时轮询处理。如：xxl-job

今天我们采用一种比较简单、轻量级的方式，使用 Redis 的延迟队列来进行处理。当然有更好的解决方案，可根据公司的技术选型和业务体系选择最优方案。如：使用消息中间件Kafka、RabbitMQ 的延迟队列

先不讨论其实现原理，直接实战上代码先实现基于 Redis 的延迟队列

1、引入 Redisson 依赖

    org.redisson    redisson-spring-boot-starter    3.10.5

2、Nacos 配置 Redis 连接

spring:  redis:    host: 127.0.0.1    port: 6379    password: 123456    database: 12    timeout: 3000

3、创建 RedissonConfig 配置

/** * Created by LPB on 2020/04/20. */@Configurationpublic class RedissonConfig {        @Value("${spring.redis.host}")        private String host;        @Value("${spring.redis.port}")        private int port;        @Value("${spring.redis.database}")        private int database;        @Value("${spring.redis.password}")        private String password;        @Bean        public RedissonClient redissonClient() {                Config config = new Config();                config.useSingleServer()                        .setAddress("redis://" + host + ":" + port)                        .setDatabase(database)                        .setPassword(password);                return Redisson.create(config);        }}

4、封装 Redis 延迟队列工具类

/** * redis延迟队列工具 * Created by LPB on 2021/04/20. */@Slf4j@Componentpublic class RedisDelayQueueUtil {    @Autowired        private RedissonClient redissonClient;    /**     * 添加延迟队列     * @param value 队列值     * @param delay 延迟时间     * @param timeUnit 时间单位     * @param queueCode 队列键     * @param      */    public  void addDelayQueue(T value, long delay, TimeUnit timeUnit, String queueCode){        try {            RBlockingDeque