在支付系统中，订单通常是具有时效性的，例如在下单 30 分钟后如果还没有完成支付，那么就要取消订单，不能再执行后续流程。说到这，可能大家的第一反应是启动一个定时任务，来轮询订单的状态是否完成了支付，如果超时还没有完成，那么就去修改订单的关闭字段。当然，在数据量小的时候这么干没什么问题，但是如果订单的数量上来了，那么就会出现读取数据的瓶颈，毕竟来一次全表扫描还是挺费时的。
针对于定时任务的这种缺陷，关闭订单的这个需求大多依赖于延时任务来实现，这里说明一下延时任务与定时任务的最大不同，定时任务有执行周期的，而延时任务在某事件触发后一段时间内执行，并没有执行周期。
对于延时任务，可能大家对于RabbitMQ的延时队列会比较熟悉，用起来也是得心应手，但是你是否知道使用 Redis 也能实现延时任务的功能呢，今天我们就来看看具体应该如何实现。
使用 Redis 实现的延时队列，需要借助 Redisson 的依赖：
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter</artifactId> <version>3.10.7</version></dependency>
复制代码
首先实现往延时队列中添加任务的方法，为了测试时方便，我们把延迟时间设为 30 秒。
@Componentpublic class UnpaidOrderQueue { @Autowired RedissonClient redissonClient;
public void addUnpaid(String orderId){ RBlockingQueue<String> blockingFairQueue = redissonClient.getBlockingQueue("orderQueue"); RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue);
System.out.println(DateTime.now().toString(JodaUtil.HH_MM_SS)+" 添加任务到延时队列"); delayedQueue.offer(orderId,30, TimeUnit.SECONDS); }}
复制代码
添加一个对队列的监听方法，通过实现CommandLineRunner接口，使它在springboot启动时就开始执行：
@Componentpublic class QueueRunner implements CommandLineRunner { @Autowired private RedissonClient redissonClient;
@Autowired private OrderService orderService;
@Override public void run(String... args) throws Exception { new Thread(()->{ RBlockingQueue<String> blockingFairQueue = redissonClient.getBlockingQueue("orderQueue"); RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue); delayedQueue.offer(null, 1, TimeUnit.SECONDS); while (true){ String orderId = null; try { orderId = blockingFairQueue.take(); } catch (Exception e) { continue; } if (orderId==null) { continue; } System.out.println(String.format(DateTime.now().toString(JodaUtil.HH_MM_SS)+" 延时队列收到："+orderId)); System.out.println(DateTime.now().toString(JodaUtil.HH_MM_SS)+" 检测订单是否完成支付"); if (orderService.isTimeOut(orderId)) { orderService.closeOrder(orderId); } } }).start(); }}
复制代码
在方法中，单独启动了一个线程来进行监听，如果有任务进入延时队列，那么取到订单号后，调用我们OrderService提供的检测是否订单过期的服务，如果过期，那么执行关闭订单的操作。
创建简单的OrderService用于测试，提供创建订单，检测超时，关闭订单方法：
@Servicepublic class OrderService {
@Autowired UnpaidOrderQueue unpaidOrderQueue;
public void createOrder(String order){ System.out.println(DateTime.now().toString(JodaUtil.HH_MM_SS)+" 创建订单:"+order); unpaidOrderQueue.addUnpaid(order); }
public boolean isTimeOut(String orderId){ return true; }
public void closeOrder(String orderId){ System.out.println(DateTime.now().toString(JodaUtil.HH_MM_SS)+ " 关闭订单"); }}
复制代码
执行请求，看一下结果：
在订单创建 30 秒后，检测到延时队列中有任务任务，调用检测超时方法检测到订单没有完成后，自动关闭订单。
除了上面这种延时队列的方式外，Redisson还提供了另一种方式，也能优雅的关闭订单，方法很简单，就是通过对将要过期的 key 值的监听。
创建一个类继承KeyExpirationEventMessageListener，重写其中的onMessage方法，就能实现对过期 key 的监听，一旦有缓存过期，就会调用其中的onMessage方法：
@Componentpublic class RedisExpiredListener extends KeyExpirationEventMessageListener { public static final String UNPAID_PREFIX="unpaidOrder:";
@Autowired OrderService orderService;
public RedisExpiredListener(RedisMessageListenerContainer listenerContainer) { super(listenerContainer); }
@Override public void onMessage(Message message, byte[] pattern) { String expiredKey = message.toString(); if (expiredKey.startsWith(UNPAID_PREFIX)){ System.out.println(DateTime.now().toString(JodaUtil.HH_MM_SS)+" " +expiredKey+"已过期"); orderService.closeOrder(expiredKey); } }}
复制代码
因为可能会有很多 key 的过期事件，因此需要对订单过期的 key 加上一个前缀，用来判断过期的 key 是不是属于订单事件，如果是的话那么进行关闭订单操作。
再在写一个测试接口，用于创建订单和接收支付成功的回调结果：
@RestController@RequestMapping("order")public class TestController { @Autowired RedisTemplate redisTemplate;
@GetMapping("create") public String setTemp(String id){ String orderId= RedisExpiredListener.UNPAID_PREFIX+id; System.out.println(DateTime.now().toString(JodaUtil.HH_MM_SS)+" 创建订单:"+orderId); redisTemplate.opsForValue().set(orderId,orderId,30, TimeUnit.SECONDS); return id; }
@GetMapping("fallback") public void successFallback(String id){ String orderId= RedisExpiredListener.UNPAID_PREFIX+id; redisTemplate.delete(orderId); }}
复制代码
在订单支付成功后，一般我们会收到第三方的一个支付成功的异步回调通知。如果支付完成后收到了这个回调，那么我们主动删除缓存的未支付订单，那么也就不会监听到这个订单的orderId的过期失效事件。
但是这种方式有一个弊端，就是只能监听到过期缓存的 key，不能获取到对应的 value。而通过延时队列的方式，可以通过为RBlockingQueue添加泛型的方式，保存更多订单的信息，例如直接将对象存进队列中：
RBlockingQueue<OrderDTO> blockingFairQueue = redissonClient.getBlockingQueue("orderQueue");RDelayedQueue<OrderDTO> delayedQueue = redissonClient.getDelayedQueue(blockingFairQueue);
复制代码
这样的话我们再从延时队列中获取的时候，能够拿到更多我们需要的属性。综合以上两种方式，监听过期更为简单，但存在的一定的局限性，如果我们只需要对订单进行判断的话那么功能也能够满足我们的需求，如果需要在过期时获取更多的订单属性，那么使用延时队列的方式则更为合适。究竟选择哪种，就要看大家的业务场景了。
如果文章对您有所帮助，欢迎关注公众号 码农参上
加号主好友，来围观朋友圈啊~
评论