快捷導航

SpringBoot中實現(xiàn)訂單30分鐘自動取消的三種方案分享

更新時間：2023年10月06日 08:42:51 作者：一只愛擼貓的程序猿

在電商和其他涉及到在線支付的應(yīng)用中,通常需要實現(xiàn)一個功能：如果用戶在生成訂單后的一定時間內(nèi)未完成支付,系統(tǒng)將自動取消該訂單,本文將詳細介紹基于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());
            }
        });
    }
}

方案二：延遲隊列

使用消息隊列（如RabbitMQ）的延遲隊列功能，當訂單生成時將訂單ID推送到延遲隊列，設(shè)置30分鐘后過期，過期后消費該消息，取消訂單。

@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的鍵過期事件功能，當訂單生成時在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);
    }
    // 當鍵過期時，Redis會自動調(diào)用該方法（需要配置Redis的過期事件通知功能）
    public void onOrderKeyExpired(String orderId) {
        cancelOrder(orderId);
    }
}

補充一下配置Redis的過期事件通知功能如下： Redis的鍵過期通知是一種典型的發(fā)布-訂閱模式。在Redis中，我們可以訂閱到某些特定的事件。鍵過期事件就是其中之一。但需要注意，要使用這個功能，需要確保你的Redis服務(wù)器開啟了相關(guān)配置。

下面是具體的步驟和示例：

首先需要確保Redis的配置文件（通常是redis.conf）中開啟了鍵空間通知功能。你可以通過在配置文件中添加或修改如下配置實現(xiàn)：

notify-keyspace-events "Ex"

這里的"Ex"表示只監(jiān)聽鍵過期事件。如果需要監(jiān)聽其他類型的事件，可以參考Redis官方文檔進行配置。

然后在Spring Boot應(yīng)用中，可以使用RedisMessageListenerContainer來訂閱Redis的鍵過期事件，并指定回調(diào)方法進行處理。示例如下：

@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ù)庫的鍵過期事件。當一個鍵過期時，onMessage方法會被調(diào)用，你可以在這里加入你的邏輯來處理訂單的超時取消。

請注意，這里的代碼只是一個基本示例。在實際使用中，你可能需要根據(jù)自己的需要對代碼進行相應(yīng)的調(diào)整和優(yōu)化。