SpringBoot 怎么实现订单 30 分钟自动取消？

来源：https://juejin.cn/post/7285167401821798400

目录

• 简介

• • 方案一：定时任务

  • 方案二：延迟队列

  • 方案三：Redis 过期事件

• 总结

简介

在电商和其他涉及到在线支付的应用中，通常需要实现一个功能：如果用户在生成订单后的一定时间内未完成支付，系统将自动取消该订单。

本文将详细介绍基于 Spring Boot 框架实现订单 30 分钟内未支付自动取消的几种方案，并提供实例代码。

方案一：定时任务

利用 Spring Boot 中的 @Scheduled 注解，我们可以轻松地实现定时任务。该任务将周期性地扫描数据库，检查未支付的订单，如果订单生成 30 分钟未支付，则自动取消。

@Component publicclassOrderCancelSchedule{ @Autowired private OrderService orderService; @Scheduled(cron = "0 0/1 * * * ?") publicvoidcancelUnpaidOrders(){ List<Order> unpaidOrders = orderService.getUnpaidOrders(); unpaidOrders.forEach(order -> { if (order.getCreationTime().plusMinutes(30).isBefore(LocalDateTime.now())) { orderService.cancelOrder(order.getId()); } }); } }

方案二：延迟队列

👉 欢迎加入小哈的星球，你将获得:专属的项目实战（多个项目） / 1v1 提问 /Java 学习路线 /学习打卡 / 每月赠书 / 社群讨论

• 新项目：《Spring AI 项目实战》正在更新中..., 基于 Spring AI + Spring Boot 3.x + JDK 21;

• 《从零手撸：仿小红书（微服务架构）》 已完结，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17..., 点击查看项目介绍；演示地址：http://116.62.199.48:7070/

• 《从零手撸：前后端分离博客项目（全栈开发）》2期已完结,演示链接：http://116.62.199.48/;

• 专栏阅读地址：https://www.quanxiaoha.com/column
  

截止目前，累计输出 100w+ 字，讲解图 4013+ 张，还在持续爆肝中..后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，Spring Cloud Alibaba 等等，戳我加入学习，解锁全部项目，已有4200+小伙伴加入

使用消息队列（如 RabbitMQ）的延迟队列功能，当订单生成时将订单 ID 推送到延迟队列，设置 30 分钟后过期，过期后消费该消息，取消订单。

@Service publicclassOrderService{ @Autowired private RabbitTemplate rabbitTemplate; publicvoidcreateOrder(Order order){ // 保存订单至数据库 saveOrderToDB(order); // 将订单 ID 推送至延迟队列 rabbitTemplate.convertAndSend("orderDelayExchange", "orderDelayKey", order.getId(), message -> { message.getMessageProperties().setDelay(30 * 60 * 1000); // 设置延迟时间 return message; }); } } @Component @RabbitListener(queues = "orderDelayQueue") publicclassOrderDelayConsumer{ @Autowired private OrderService orderService; @RabbitHandler publicvoidprocess(String orderId){ // 取消订单 orderService.cancelOrder(orderId); } }

方案三：Redis 过期事件

利用 Redis 的键过期事件功能，当订单生成时在 Redis 中存储一个键，设置 30 分钟过期，键过期时通过 Redis 的过期事件通知功能触发订单取消操作。

@Service publicclassOrderService{ @Autowired private StringRedisTemplate redisTemplate; publicvoidcreateOrder(Order order){ // 保存订单至数据库 saveOrderToDB(order); // 在 Redis 中存储一个键，设置 30 分钟过期 redisTemplate.opsForValue().set("order:" + order.getId(), order.getId(), 30, TimeUnit.MINUTES); } // 当键过期时，Redis 会自动调用该方法（需要配置 Redis 的过期事件通知功能） publicvoidonOrderKeyExpired(String orderId){ cancelOrder(orderId); } }

补充一下配置 Redis 的过期事件通知功能如下：

Redis 的键过期通知是一种典型的发布-订阅模式。在 Redis 中，我们可以订阅到某些特定的事件。键过期事件就是其中之一。但需要注意，要使用这个功能，需要确保你的 Redis 服务器开启了相关配置。下面是具体的步骤和示例：

1. 首先需要确保 Redis 的配置文件（通常是 redis.conf）中开启了键空间通知功能。你可以通过在配置文件中添加或修改如下配置实现：

notify-keyspace-events "Ex"

这里的 "Ex" 表示只监听键过期事件。如果需要监听其他类型的事件，可以参考 Redis 官方文档进行配置。

1. 然后在 Spring Boot 应用中，可以使用RedisMessageListenerContainer来订阅 Redis 的键过期事件，并指定回调方法进行处理。示例如下：

@Configuration publicclassRedisConfig{ @Autowired private RedisConnectionFactory redisConnectionFactory; @Bean RedisMessageListenerContainer container(){ RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(redisConnectionFactory); // 订阅所有 db 的过期事件 container.addMessageListener(new MessageListener() { @Override publicvoidonMessage(Message message, byte[] pattern){ String expiredKey = message.toString(); if (expiredKey.startsWith("order:")) { // 处理订单超时逻辑 String orderId = expiredKey.split(":")[1]; // 这里调用你的服务类方法，处理订单超时逻辑 // orderService.cancelOrder(orderId); } } }, new PatternTopic("__keyevent@*__:expired")); return container; } }

在这个示例中，"__keyevent@*__:expired" 是一个模式匹配的主题，它可以匹配所有数据库的键过期事件。当一个键过期时，onMessage 方法会被调用，你可以在这里加入你的逻辑来处理订单的超时取消。

请注意，这里的代码只是一个基本示例。在实际使用中，你可能需要根据自己的需要对代码进行相应的调整和优化。

总结

以上三种方案都可以实现订单在 30 分钟内未支付则自动取消的需求。根据实际业务需求、系统负载和其他因素，可以选择最适合自己系统的实现方案。每种方案都有其优缺点，需要根据具体情况权衡。

👉 欢迎加入小哈的星球，你将获得:专属的项目实战（多个项目） / 1v1 提问 /Java 学习路线 /学习打卡 / 每月赠书 / 社群讨论

• 新项目：《Spring AI 项目实战》正在更新中..., 基于 Spring AI + Spring Boot 3.x + JDK 21;

• 《从零手撸：仿小红书（微服务架构）》 已完结，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17..., 点击查看项目介绍；演示地址：http://116.62.199.48:7070/

• 《从零手撸：前后端分离博客项目（全栈开发）》2期已完结,演示链接：http://116.62.199.48/;

• 专栏阅读地址：https://www.quanxiaoha.com/column
  

截止目前，累计输出 100w+ 字，讲解图 4013+ 张，还在持续爆肝中..后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，Spring Cloud Alibaba 等等，戳我加入学习，解锁全部项目，已有4200+小伙伴加入

1. 我的私密学习小圈子，从0到1手撸企业实战项目~ 2. 加了 LIMIT 1，为什么查询反而变慢了？ 3. 面试官：为什么 Tomcat 默认最大线程数是 200，而不是 N+1？ 4. 9.5k star，一款高颜值、现代化的 Git 可视化管理工具

最近面试BAT，整理一份面试资料《Java面试BATJ通关手册》，覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。 获取方式：点“在看”，关注公众号并回复 Java 领取，更多内容陆续奉上。
PS：因公众号平台更改了推送规则，如果不想错过内容，记得读完点一下“在看”，加个“星标”，这样每次新文章推送才会第一时间出现在你的订阅列表里。 点“在看”支持小哈呀，谢谢啦