秒杀场景下的消息队列

削峰填谷

削峰填谷是消息队列最主要的作用，但会造成请求处理延迟。

具体步骤

• 将秒杀请求放入消息队列，业务服务器响应用户“秒杀结果计算中”从而释放资源处理用户其他请求。
• 后台启动若干队列处理任务，消费队列中的消息，执行校验入库、下单等逻辑。由于队列处理线程有限，从而落入后端数据库的并发请求有限，当库存处理完成，队列里堆积的的消息便可丢弃。

异步处理

异步处理是提升系统性能的神器，但需要分清同步流程和异步流程的边界，同时消息存在丢失的风险，我们需要考虑如何确保消息一定到达。

秒杀场景会有生成订单扣减库存等主要业务逻辑，也可能存在用户抢购成功后发优惠券、加积分等次要业务逻辑。可以考虑将这部分次要的异步处理。

解耦合

解耦合可以提升系统的鲁棒性。

鲁棒是Robust的音译，也就是健壮和强壮的意思。它也是在异常和危险情况下系统生存的能力。

若数据团队想要获取数据做相关统计分析，我们需要将大量数据发送给该团队。可以使用Http或者RPC的方式来同步调用，即技术团队提供接口我们实时传秒杀的数据，但该方式存在两个问题：

• 整体系统的耦合行较强，数据团队的接口发生故障时，会影响秒杀系统的可用性。
• 当数据系统需要新的字段，就要变更接口的参数，秒杀系统需要随着一起变更。

可以考虑使用消息队列降低业务系统和数据系统的直接耦合度：当秒杀系统产生一条记录时，把所有数据存到消息队列中，数据团队订阅该队列的话题，它们就能拿到数据做相应过滤和处理了。