一个简单的分布式事务系统的实现（订单系统）

xkl135 2018-10-11

展开全文

技术文章第一时间送达！

源码精品专栏

来源：http:///EhKG87r

背景：公司最早的一个版本的订单管理，是通过PHP mysql的方案去实现的，这样会有什么问题呢，假设如果放到一个实例里面，全部用一个单机事务去解决，这样是能比较方便的解决数据一致性问题。但是存在两个问题，一是无法进行多实例部署，用户量增长以后，无法快速应对。二是，PHP中做事务，如果PHP遇到异常，有时并不会自动终止事务，导致DB被锁住，这是第一个版本。之后，我们推出了第二个版本V2，这个版本的时候，我们已经开发好了，库存管理系统，优惠券管理系统，PHP中，已经不直接通过DB去修改库存和优惠券，而是通过接口访问的方式去请求SERVER进行修改。这个版本，实际上已经从逻辑上，把订单系统和库存管理，优惠券管理系统已经独立出来了。数据层面已经可以独立部署，不再依赖一个单机事务去实现数据一致性功能了。但这个版本虽然解决了数据分布的问题，但同时引入了一个新的问题，就是数据在订单，库存，优惠券之间无法保证一致性。举个例子：下个订单，调用库存成功，锁定优惠券失败，生成订单失败。这时候就会导致优惠券数据不一致性情况出来，未下单的优惠券也被锁住了。有同事可能会问：订单如果创建失败，那直接回滚优惠券操作，即去解锁优惠券系统即可实现数据一致性。不错，很多时候，是可以这么操作，但如果你回滚的时候，失败了呢？你是继续在这等着直到成功，还是继续等着？呵呵。。

正是因为这样，我们开发了V3版本，去解决这个问题。

V3版本，我们把订单系统的逻辑从PHP中抽离出来，为什么尽量不在PHP里面做这块逻辑呢？主要有两个考虑点：1、因为订单服务这块逻辑特别重要，是影响用户操作的重要逻辑，且变动少，写成一个SERVER相对容易保持稳定。2、PHP使用CI框架做事务的时候，如果事务中出现异常，可能导致事务不结束，一直死锁的问题。

订单系统的逻辑架构大致如下：

订单系统中，统一通过接口调用，去访问库存管理，优惠券系统，通过mysql提供的事务机制去操作数据库部分。这里有一个前提条件，即是库存管理与优惠券系统的接口均要实现可重入的特性（可参考上一篇文章“如何实现可重入接口”）。另外，还要引入一个差错控制服务，用于做一些数据不一致的事后补尝机制。差错控制可以理解为一个消息队列机制，还有一个消费者服务从队列中取出消息进行消费。我们这里采用阿里云的ONS服务做为消息队列，通过一个消费者去订单消息进行消费。

生成订单的逻辑如下：

1、先把生成的订单号发到差错控制服务中。（这里必须要有个延时处理的机制，延时给消费者消费消息，因为要确保后面的流程有个结果，可以延时5分钟以上）

2、使用订单号作为库存单号去操作库存管理系统。

A）如果失败，则使用相同订单号去进行回滚请求操作。（这里不论成功失败，均返回失败，结束流程）

B）如果成功，继续往下执行。

3、使用订单号去锁定优惠券系统。

A）如果失败，尝试库存回滚操作，尝试执行解锁操作。（这里不论解锁成功失败，均返回失败，结束流程）

B）如果成功，继续往下执行。

4、开启事务，创建订单相关数据。

A）如果创建失败，回滚事务，调用库存回滚操作，调用优惠券解锁操作。（不论调用成功与否，均返回失败，结束流程）

B）如果创建成功，提交事务，返回成功。

大概流程如上所述。