Delay Job

延迟任务 / 关单

When to Invoke

下单 N 分钟未支付关单、核销码过期、延迟双删、预约提醒。

When NOT

立刻异步解耦 → mq-reliability。库存怎么扣 → concurrency-sell。关单时仍要幂等。日切对账、周期性补偿、@Scheduled / XXL-JOB → schedule-job。

风险（面试考点）

@Scheduled 每分钟 SELECT * FROM t_order WHERE status=0 AND created_at < now()-30min：数据一大就扫表、重复关、漏关。

RocketMQ 4.x 开源：18 个固定级别（1s … 2h），不是任意秒。内部 SCHEDULE_TOPIC_XXXX 一档一个队列，同档 FIFO，避免全局排序。5.x 才有时间轮任意延迟。没有 3 分钟档就选 2m 或 4m，或自己补级。

到期消息会重复投，关单必须 WHERE status=CREATED。已支付的到期消息应空操作。

方案选型（轻量优先）

默认方案

Message msg = new Message("order-cancel", orderNo.getBytes());
msg.setKeys(orderNo);
msg.setDelayTimeLevel(16); // 30min
producer.send(msg);

public void onCancel(String orderNo) {
    int n = orderMapper.update(null, Wrappers.<Order>lambdaUpdate()
        .set(Order::getStatus, "CLOSED")
        .eq(Order::getOrderNo, orderNo)
        .eq(Order::getStatus, "CREATED"));
    if (n == 1) {
        restoreStock(orderNo); // 条件加回，幂等
    }
}

关单与回库存同一本地事务，或事务消息。回库存仍 stock=stock+n 且防重复回。

反例

错误：定时扫全表未支付。 正确：下单时发延迟消息。

错误：到期不看状态直接关。 正确：只关 CREATED。

错误：用 Thread.sleep(30min) 在请求线程里等。 正确：立刻返回，到点再处理。

验证

• 未支付到期关单且库存加回一次。
• 到期前已支付，消息到达不关单、不加库存。
• 重复到期消息不双倍回库存。

评审清单

• 不是扫表关单
• 延迟档位与业务时长匹配
• 到期处理幂等 + 状态条件