文章目录
- 概要
- Redisson实现订单到期关闭
- 引入依赖
- application.yml配置文件中配置redis
- 项目中使用
概要
在电商、支付等系统中,一般都是先创建订单(支付单),再给用户一定的时间进行支付,如果没有按时支付的话,就需要把之前的订单(支付单)取消掉。这种类似的场景有很多,还有比如到期自动收货、超时自动退款、下单后自动发送短信等等都是类似的业务问题。
订单的到期关闭的实现有很多种方式,分别有:
1、被动关闭(不推荐)
2、定时任务
(推荐,适合时间精确度要求不高的场景)
3、DelayQueue(不推荐,基于内存,无法持久化)
4、时间轮(不推荐,基于内存,无法持久化)
5、kafka(MQ 方案不推荐,大量无效调度)
6、RocketMQ延迟消息(MQ 方案不推荐,大量无效调度)
7、RabbitMQ死信队列(MQ 方案不推荐,大量无效调度)
8、RabbitMQ插件(MQ 方案不推荐,大量无效调度)
9、Redis过期监听(不推荐,容易丢消息)
10、Redis的ZSet(不推荐,可能会重复消费)
11、Redisson
(推荐,可以用)
Redisson实现订单到期关闭
Redisson
的 RDelayedQueue
底层利用了 Redis 的 有序集合(ZSet) 数据结构来存储延时消息。
引入依赖
<dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.10.7</version>
</dependency>
application.yml配置文件中配置redis
spring:redis:host: 112.153.214.15port: 6379password: 123456
项目中使用
要实现订单到期关闭,可以使用Redisson来处理延时任务。我将展示核心简单的实现步骤
创建延时队列:
使用Redisson的延时队列来处理订单的延时关闭。
- RBlockingQueue:存储任务的阻塞队列,用于实际的订单处理。
- RDelayedQueue:延时队列,用于在指定时间后将任务推送到 RBlockingQueue
@Componentpublic class UnpaidOrderQueue {@Autowiredprivate RedissonClient redissonClient;public void addUnpaidOrder(String orderId) {RBlockingQueue<String> blockingQueue = redissonClient.getBlockingQueue("orderQueue");RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue(blockingQueue);delayedQueue.offer(orderId, 30, TimeUnit.MINUTES); // 设置延迟时间为30分钟}}
监听队列:
创建一个监听器来处理延时队列中的订单。
CommandLineRunner
是一个接口,用于在 Spring Boot 应用程序启动后立即执行一些特定的代码逻辑。
@Component
public class QueueListener implements CommandLineRunner {@Autowiredprivate RedissonClient redissonClient;@Autowiredprivate OrderService orderService;@Overridepublic void run(String... args) throws Exception {// 异步线程,监听延时队列new Thread(() -> {RBlockingQueue<String> blockingQueue = redissonClient.getBlockingQueue("orderQueue");while (true) {try {String orderId = blockingQueue.take(); // 阻塞拿if (orderService.isOrderExpired(orderId)) {orderService.closeOrder(orderId); // 关闭}} catch (InterruptedException e) {Thread.currentThread().interrupt();}}}).start();}
}
❤觉得有用的可以留个关注~❤