在電商和其他涉及到在線支付的應用中,通常需要實現一個功能:如果用戶在生成訂單后的一定時間內未完成支付,系統將自動取消該訂單。本文將詳細介紹基于Spring Boot框架實現訂單30分鐘內未支付自動取消的幾種方案,并提供實例代碼。
利用Spring Boot中的@Scheduled注解,我們可以輕松地實現定時任務。該任務將周期性地掃描數據庫,檢查未支付的訂單,如果訂單生成30分鐘未支付,則自動取消。
@Componentpublic 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()); } }); }}
基于注解@Scheduled默認為單線程,開啟多個任務時,任務的執行時機會受上一個任務執行時間的影響。
@EnableScheduling注解: 在配置類上使用,開啟計劃任務的支持(類上)。
@SpringBootApplication@EnableSchedulingpublic 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; /** * 定時任務的使用 **/@Componentpublic 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())); }}
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 | , - * / |
通配符說明:
記住就可以了,需要運用可以直接上網查cron表達式。或者用在線cron工具來生成自己想要的表達式。符號的意思需要理解
使用消息隊列(如RabbitMQ)的延遲隊列功能,當訂單生成時將訂單ID推送到延遲隊列,設置30分鐘后過期,過期后消費該消息,取消訂單。
@Servicepublic 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中存儲一個鍵,設置30分鐘過期,鍵過期時通過Redis的過期事件通知功能觸發訂單取消操作。
@Servicepublic 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服務器開啟了相關配置。
下面是具體的步驟和示例:
notify-keyspace-events "Ex"
這里的"Ex"表示只監聽鍵過期事件。如果需要監聽其他類型的事件,可以參考Redis官方文檔進行配置。
@Configurationpublic 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分鐘內未支付則自動取消的需求。根據實際業務需求、系統負載和其他因素,可以選擇最適合自己系統的實現方案。每種方案都有其優缺點,需要根據具體情況權衡。
本文鏈接:http://www.tebozhan.com/showinfo-26-12725-0.htmlSpring Boot中實現訂單30分鐘自動取消的策略
聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com
上一篇: 深挖 Python 元組 pt.2