电商平台中，订单未支付过期，如何实现自动关单？

 （点个赞，算法会给你推荐更多类似干货 ~        持续更新中，点关注，看下篇文章）

一、口诀：

RocketMQ 延迟消，级别设定定时发；

消费检查支付态，未付关单不偏差；

解耦 高吞 还 可靠，最优方案就选它。

二、答案：

RocketMQ延迟消息是最优方案。

（1）具体实现：

1. 原理：

订单创建后，将订单信息作为消息投递到RocketMQ，并设置延迟时间（如30分钟）。消息写入Broker后不会立即被消费，需等待指定时长后才会被消费者获取。

2. 关键细节：

RocketMQ的延迟消息通过“延迟级别”实现（而非每条消息单独计时），预设了1s、5s、10s、30s、1min...2h等级别，30分钟可对应匹配的级别（如level=16）。

3. 消费逻辑：

消费者接收到延迟消息后，检查订单支付状态，若未支付则执行关单操作（更新订单状态、释放库存等）。

（2）为何是最佳方案：

- 解耦：订单系统与关单逻辑分离，不依赖其他组件；

- 高吞吐：支持百万级消息量，适合电商高并发场景；

- 可靠性：消息持久化，即使服务重启也不会丢失，避免漏关单。

（3）其他方案的不足：

- 定时任务：频繁扫描数据库，增加IO压力，且关单有延迟；

- Redis过期监听：key过期通知不及时，且消息无持久化，可能丢失；

- DelayQueue：基于JVM内存，数据易丢失，不适合分布式系统。

三、STAR法则回答：

情境（S）：

电商平台日均10万订单，需解决“订单30分钟未支付自动关单”问题，避免库存长期占用。

任务（T）：

设计高效、可靠的关单方案，确保不遗漏、不重复关单，且不影响主流程性能。

行动（A）：

1. 采用RocketMQ延迟消息，订单创建时发送延迟30分钟的消息，携带订单ID；
2. 消费者监听消息，接收后查询订单支付状态，未支付则调用关单接口（更新状态、释放库存）；
3. 对比定时任务、Redis方案，选择RocketMQ以减少数据库压力，保证消息不丢失。

结果（R）：

关单准确率100%，平均关单延迟<10秒，数据库压力降低60%，支持大促期间20万/天订单场景。

四、生活例子

好比餐厅“超时未取餐自动取消”：
- 顾客下单后（创建订单），服务员给一张30分钟后过期的取餐号（发送延迟消息）；
- 30分钟内未取餐，系统自动取消订单（延迟消息被消费，执行关单）；

- 相比“服务员每5分钟查一次订单”（定时任务），这种方式更高效，不会打扰服务员正常工作（解耦）。

 （点个赞，算法会给你推荐更多类似干货 ~）