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

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

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

使用场景

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

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

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

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

……

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

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

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

1、引入 Redisson 依赖

org.redissonredisson-spring-boot-starter3.10.5

2、Nacos 配置Redis 连接

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

3、创建 RedissonConfig 配置

/***CreatedbyLPBon2020/04/20.*/@ConfigurationpublicclassRedissonConfig{@Value("${spring.redis.host}")privateStringhost;@Value("${spring.redis.port}")privateintport;@Value("${spring.redis.database}")privateintdatabase;@Value("${spring.redis.password}")privateStringpassword;@BeanpublicRedissonClientredissonClient(){Configconfig=newConfig();config.useSingleServer().setAddress("redis://"+host+":"+port).setDatabase(database).setPassword(password);returnRedisson.create(config);}}

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

/***redis延迟队列工具*CreatedbyLPBon2021/04/20.*/@Slf4j@ComponentpublicclassRedisDelayQueueUtil{@AutowiredprivateRedissonClientredissonClient;/***添加延迟队列*@paramvalue队列值*@paramdelay延迟时间*@paramtimeUnit时间单位*@paramqueueCode队列键*@param*/publicvoidaddDelayQueue(Tvalue,longdelay,TimeUnittimeUnit,StringqueueCode){try{RBlockingDeque