延迟队列的业务场景和实现思路

延迟队列在订单超时、任务调度等场景中很实用。本文讲它的业务场景和实现思路。

先从业务问题出发

架构设计不要先问“用什么中间件”，而要先问业务目标：是要提升吞吐、解耦系统、保证最终一致，还是降低峰值压力？不同目标对应的方案完全不同。

一个典型流程

以订单创建后发送通知为例：

1. 订单服务先保存订单。
2. 写入消息或事件。
3. 通知服务异步消费。
4. 消费端做好幂等，避免重复通知。

伪代码可以这样理解：

orderService.create(order);
messageProducer.send("order.created", order.getId());

消费端必须能处理重复消息：

if (processed(messageId)) {
    return;
}
handleMessage(message);
markProcessed(messageId);

设计时要补的问题

• 消息发送失败怎么办？
• 消费失败是否重试？
• 重复消费如何保证幂等？
• 下游长时间不可用时如何降级？