当前位置：首页 > article >正文

Redisson实现订单到期关闭

article 2024/11/20 2:23:39

文章目录

- 概要
- 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.15
    port: 6379
    password: 123456

项目中使用

要实现订单到期关闭，可以使用Redisson来处理延时任务。我将展示核心简单的实现步骤

创建延时队列：
使用Redisson的延时队列来处理订单的延时关闭。

RBlockingQueue：存储任务的阻塞队列，用于实际的订单处理。
RDelayedQueue：延时队列，用于在指定时间后将任务推送到 RBlockingQueue

   @Component
   public class UnpaidOrderQueue {
       @Autowired
       private 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 {
    @Autowired
    private RedissonClient redissonClient;
    @Autowired
    private OrderService orderService;

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