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