Redisson实现订单到期关闭

概要

在电商、支付等系统中，一般都是先创建订单（支付单），再给用户一定的时间进行支付，如果没有按时支付的话，就需要把之前的订单（支付单）取消掉。这种类似的场景有很多，还有比如到期自动收货、超时自动退款、下单后自动发送短信等等都是类似的业务问题。

订单的到期关闭的实现有很多种方式，分别有：

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();}
}

---

❤觉得有用的可以留个关注~❤