秒杀场景下的消息队列
- 2020 年 1 月 26 日
- 筆記
削峰填谷
削峰填谷是消息队列最主要的作用,但会造成请求处理延迟。
具体步骤
- 将秒杀请求放入消息队列,业务服务器响应用户“秒杀结果计算中”从而释放资源处理用户其他请求。
- 后台启动若干队列处理任务,消费队列中的消息,执行校验入库、下单等逻辑。由于队列处理线程有限,从而落入后端数据库的并发请求有限,当库存处理完成,队列里堆积的的消息便可丢弃。
异步处理
异步处理是提升系统性能的神器,但需要分清同步流程和异步流程的边界,同时消息存在丢失的风险,我们需要考虑如何确保消息一定到达。
秒杀场景会有生成订单扣减库存等主要业务逻辑,也可能存在用户抢购成功后发优惠券、加积分等次要业务逻辑。可以考虑将这部分次要的异步处理。
解耦合
解耦合可以提升系统的鲁棒性。
鲁棒是Robust的音译,也就是健壮和强壮的意思。它也是在异常和危险情况下系统生存的能力。
若数据团队想要获取数据做相关统计分析,我们需要将大量数据发送给该团队。可以使用Http或者RPC的方式来同步调用,即技术团队提供接口我们实时传秒杀的数据,但该方式存在两个问题:
- 整体系统的耦合行较强,数据团队的接口发生故障时,会影响秒杀系统的可用性。
- 当数据系统需要新的字段,就要变更接口的参数,秒杀系统需要随着一起变更。
可以考虑使用消息队列降低业务系统和数据系统的直接耦合度:当秒杀系统产生一条记录时,把所有数据存到消息队列中,数据团队订阅该队列的话题,它们就能拿到数据做相应过滤和处理了。