商城项目扣减库存分布式事务实现

谷粒商城原版的提交订单,扣减库存,支付业务,仍然是单体事务,且没有分库分表,也没有用到redis,性能是低的,本文基于消息队列和mysql,redis数据一致性两方面知识,将单体事务变成分布式事务,提高性能:

mysql,redis设计:

mysql, redis将会按照一级分类的进行分库,比如电子设备相关的sku会分在一个mysql,redis节点.服饰类会分在另一个mysql,redis节点里.每个redis,mysql节点都有自己的唯一id;

本身思考过同一个一级分类再次划分为多个库(不同的仓库Id分到不同的数据库,redis中),提升高可用性, 但这样会带来订单项的分布式扣减.其实也可以实现.这种情况下,每个订单项都会再次被划分,此次划分后,理论上单个节点的崩溃基本不会造成整体崩溃,可用性大大提高

1.扣减库存:

库存扣减将放在redis里进行,redis扣减库存前记录redo_log,用于redis内部延时关单,若redis节点崩溃,使用mysql重新构建redis数据,而不是使用将子库扶正为主库的策略(该策略不可避免超卖),由于节点崩溃,因此会对sku数据将会分散到不同的redis节点上(按照一级分类的标签进行路由),

redis库存扣减成功后,提交订单方法写两个消息队列, 一个是库存扣减消息队列(数据库扣减库存),一个是延时关单消息队列(用于延时关单),任何一个失败都表示该次提交订单失败.

2.延时关单

由于使用mq操作redis恢复库存无法保证幂等性,因此mysql,redis的延时关单业务有各自实现,mysql方面依靠唯一消息状态表实现幂等性,redis基于节点内部的redis_redo_log_queue(数据结构为zset)实现, 倘若redis节点崩溃,该节点将暂停10Min以上,直到所有订单都完成收单,然后基于该库对应的mysql数据恢复.

以上的业务都依赖于unique id;本项目参考美团的snowFlakeId实现唯一id,每一个订单项,订单都会有自己的唯一Id.来保证消息消费的幂等性;

各消息队列职责如下:

订单扣减分布式事务:

        1.提交订单时发送两个消息队列:        

                        1.扣减消息队列:扣减数据库库存:                          tbmall-order

                        2.延时消息队列,关单:                                           tbmall-order-delay-check

        2.扣减订单成功后,再发消息队列,用于更新订单状态:              tbmall-order-orderitem-deduct-status

        3.延时关单时发送回退库存消息队列:                                    tbmall-ware-restock

        4.回退库寸成功后,更新回退成功消息队列:                            tbmall-ware-restock-status

        5.支付成功,回调地址写支付成功消息队列:                            tbmall-order-payment

mysql,redis相关技术:

mysql方面使用了shardingJDBC实现分库分表情景下的路由

redis方面基于Dubbo和RedisConnectionFactory实现了多源的redis客户端