《大营销平台系统设计实现》 - 营销服务 第16节：引入MQ处理活动SKU库存一致性

作者：小傅哥
博客：https://bugstack.cn (opens new window)

沉淀、分享、成长，让自己和他人都能有所收获！😄

• 本章难度：★★★☆☆
• 本章重点：引入 RabbitMQ 消息组件，在活动SKU库存消耗完毕后，触发消息推送更新库存为最终一致。
• 课程视频：https://t.zsxq.com/18UKKWY9x (opens new window)

版权说明：©本项目与星球签约合作，受《中华人民共和国著作权法实施条例》 (opens new window) 版权法保护，禁止任何理由和任何方式公开(public)源码、资料、视频等内容到Github、Gitee等，违反可追究进一步的法律行动。

一、本章诉求

完成活动责任链判断，包括；活动的校验【日期、状态、sku库存】，之后是sku 库存的扣减操作。 之后这里会涉及一个缓存库存和数据库库存一致性问题，是本节要处理的重点。一个手段是之前在策略实现阶段采用的延迟队列做趋势更新，另外一个是本节要引入 RabbitMQ 在库存消耗空以后发送 MQ 消息，直接更新清空最终库存，保持缓存与数据库的一致性。

注意，可能此时缓存消耗库存阶段有失败丢失，不完全等于数据库真实库存。不过没关系，先保证一个统一库存即可。后续可以扫描统计订单数量，来校准库存。

二、功能流程

完善责任链功能，和库存数据一致性的处理；

• 第一步；完成责任链的活动校验，时间、状态、库存。
• 第二步；对库存的扣减，使用 decr + lock 锁的方式（兜底）进行处理。
• 第三步；做完库存扣减后，发送延迟队列，由任务调度更新趋势库存，满足最终一致。
• 第四步；库存消耗为0后，发送MQ消息，驱动变更数据库库存为0