Spring Boot中實現訂單30分鐘自動取消的策略
簡介
在電商和其他涉及到在線支付的應用中，通常需要實現一個功能：如果用戶在生成訂單后的一定時間內未完成支付，系統將自動取消該訂單。本文將詳細介紹基于Spring Boot框架實現訂單30分鐘內未支付自動取消的幾種方案，并提供實例代碼。
方案一：定時任務
利用Spring Boot中的@Scheduled注解，我們可以輕松地實現定時任務。該任務將周期性地掃描數據庫，檢查未支付的訂單，如果訂單生成30分鐘未支付，則自動取消。
@Component
public class OrderCancelSchedule {
@Autowired
private OrderService orderService;
@Scheduled(cron = "0 0/1 * * * ?")
public void cancelUnpaidOrders() {
List<Order> unpaidOrders = orderService.getUnpaidOrders();
unpaidOrders.forEach(order -> {
if (order.getCreationTime().plusMinutes(30).isBefore(LocalDateTime.now())) {
orderService.cancelOrder(order.getId());
}
});
}
}1.1 Schedule注解
基于注解@Scheduled默認為單線程，開啟多個任務時，任務的執行時機會受上一個任務執行時間的影響。
@EnableScheduling注解： 在配置類上使用，開啟計劃任務的支持（類上）。
@SpringBootApplication
@EnableScheduling
public class SpringBootWebApplication { //開啟定時任務
}@Scheduled注解：來聲明這是一個任務，包括 cron，fixDelay，fixRate 等類型（方法上，需先開啟計劃任務的支持）。配合@EnableScheduling使用
package com.pjb.Schedule;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 定時任務的使用
**/
@Component
public class Task
{
@Scheduled(cron="0/5 * * * * ? ") //每5秒執行一次
public void execute(){
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //設置日期格式
System.out.println("歡迎訪問Java小陳的博客 " + df.format(new Date()));
}
}1.2 cron表達式
cron表達式是一個字符串，字符串以5或6個空格隔開，分開共6或7個域，每一個域代表一個含義。
cron 表達式格式：[秒] [分] [小時] [日] [月] [周] [年]
說明 | 是否必填 | 允許填寫的值 | 允許的通配符 |
秒 | 是 | 0-59 | , - * / |
分 | 是 | 0-59 | , - * / |
小時 | 是 | 0-23 | , - * / |
日 | 是 | 1-31 | , - * ? / L W |
月 | 是 | 1-12 or JAN-DEC | , - * / |
周 | 是 | 1-7 or SUN-SAT | , - * ? / L # |
年 | 否 | empty 或 1970-2099 | , - * / |
通配符說明:
- * 表示所有值. 例如:在分的字段上設置 "*",表示每一分鐘都會觸發。
- ? 表示不指定值。使用的場景為不需要關心當前設置這個字段的值。例如:要在每月的10號觸發一個操作，但不關心是周幾，所以需要周位置的那個字段設置為"?" 具體設置為 0 0 0 10 * ?
- - 表示區間。例如 在小時上設置 "10-12",表示 10,11,12點都會觸發。
- , 表示指定多個值，例如在周字段上設置 "MON,WED,FRI" 表示周一，周三和周五觸發
- / 用于遞增觸發。如在秒上面設置"5/15" 表示從5秒開始，每增15秒觸發(5,20,35,50)。在月字段上設置'1/3'所示每月1號開始，每隔三天觸發一次。
- L 表示最后的意思。在日字段設置上，表示當月的最后一天(依據當前月份，如果是二月還會依據是否是潤年[leap]), 在周字段上表示星期六，相當于"7"或"SAT"。如果在"L"前加上數字，則表示該數據的最后一個。例如在周字段上設置"6L"這樣的格式,則表示“本月最后一個星期五"
- W 表示離指定日期的最近那個工作日(周一至周五). 例如在日字段上設置"15W"，表示離每月15號最近的那個工作日觸發。如果15號正好是周六，則找最近的周五(14號)觸發, 如果15號是周未，則找最近的下周一(16號)觸發.如果15號正好在工作日(周一至周五)，則就在該天觸發。如果指定格式為 "1W",它則表示每月1號往后最近的工作日觸發。如果1號正是周六，則將在3號下周一觸發。(注，"W"前只能設置具體的數字,不允許區間"-").
- # 序號(表示每月的第幾個周幾)，例如在周字段上設置"6#3"表示在每月的第三個周六.注意如果指定"#5",正好第五周沒有周六，則不會觸發該配置(用在母親節和父親節再合適不過了)
記住就可以了，需要運用可以直接上網查cron表達式?；蛘哂迷诰€cron工具來生成自己想要的表達式。符號的意思需要理解
方案二：延遲隊列
使用消息隊列（如RabbitMQ）的延遲隊列功能，當訂單生成時將訂單ID推送到延遲隊列，設置30分鐘后過期，過期后消費該消息，取消訂單。
@Service
public class OrderService {
@Autowired
private RabbitTemplate rabbitTemplate;
public void createOrder(Order order) {
// 保存訂單至數據庫
saveOrderToDB(order);
// 將訂單ID推送至延遲隊列
rabbitTemplate.convertAndSend("orderDelayExchange", "orderDelayKey", order.getId(), message -> {
message.getMessageProperties().setDelay(30 * 60 * 1000); // 設置延遲時間
return message;
});
}
}
@Component
@RabbitListener(queues = "orderDelayQueue")
public class OrderDelayConsumer {
@Autowired
private OrderService orderService;
@RabbitHandler
public void process(String orderId) {
// 取消訂單
orderService.cancelOrder(orderId);
}
}方案三：Redis過期事件
利用Redis的鍵過期事件功能，當訂單生成時在Redis中存儲一個鍵，設置30分鐘過期，鍵過期時通過Redis的過期事件通知功能觸發訂單取消操作。
@Service
public class OrderService {
@Autowired
private StringRedisTemplate redisTemplate;
public void createOrder(Order order) {
// 保存訂單至數據庫
saveOrderToDB(order);
// 在Redis中存儲一個鍵，設置30分鐘過期
redisTemplate.opsForValue().set("order:" + order.getId(), order.getId(), 30, TimeUnit.MINUTES);
}
// 當鍵過期時，Redis會自動調用該方法（需要配置Redis的過期事件通知功能）
public void onOrderKeyExpired(String orderId) {
cancelOrder(orderId);
}
}補充一下配置Redis的過期事件通知功能如下： Redis的鍵過期通知是一種典型的發布-訂閱模式。在Redis中，我們可以訂閱到某些特定的事件。鍵過期事件就是其中之一。但需要注意，要使用這個功能，需要確保你的Redis服務器開啟了相關配置。
下面是具體的步驟和示例：
- 首先需要確保Redis的配置文件（通常是redis.conf）中開啟了鍵空間通知功能。你可以通過在配置文件中添加或修改如下配置實現：
notify-keyspace-events "Ex"這里的"Ex"表示只監聽鍵過期事件。如果需要監聽其他類型的事件，可以參考Redis官方文檔進行配置。
- 然后在Spring Boot應用中，可以使用RedisMessageListenerContainer來訂閱Redis的鍵過期事件，并指定回調方法進行處理。示例如下：
@Configuration
public class RedisConfig {
@Autowired
private RedisConnectionFactory redisConnectionFactory;
@Bean
RedisMessageListenerContainer container() {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(redisConnectionFactory);
// 訂閱所有db的過期事件
container.addMessageListener(new MessageListener() {
@Override
public void onMessage(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分鐘內未支付則自動取消的需求。根據實際業務需求、系統負載和其他因素，可以選擇最適合自己系統的實現方案。每種方案都有其優缺點，需要根據具體情況權衡。
