JAVA高级面试进阶训练营视频教程

admin

Java生鲜电商平台-OMS订单系统中并发问题和锁机制的探讨与解决方案

 

说明：Java开源生鲜电商中OMS订单系统中并发问题和锁机制的探讨与解决方案:

 

问题由来

    假设在一个订单系统中（以火车票订单系统为例），用户A，用户B都要预定从成都到北京的火车票，A、B在不同的售票窗口均同时查询到了某车厢卧铺中、下铺位有空位。用户A正在犹豫订中铺还是下铺，这时用户B果断订购了下铺。当用户A决定订下铺时，系统提示下铺已经被预订，请重新选择铺位。在这个系统场景中，我们来探讨一下，火车票系统是怎样处理并发事件以及怎么利用锁机制来避免重复订票的。

 

设想的方案

方案1：

    为了避免重复订票，大部分人会想到在做订票操作前，去数据库查询该铺位是否已经被预订，假设“铺位”数据库表增加标记字段FLAG（空闲：0；已预订：1），如果查询到铺位的FLAG字段值为1,那么预订就不成功，如果为0就成功预订，并把FLAG置为1。这种方案如果在业务量很少的系统中，或许可行。但业务量较大时，特别是火车票这样的业务量，就会出现问题。问题在，当用户A、用户B同时对同一铺位预订时，虽说是“同时”，但对于数据库操作来说一定是有先后顺序的，假设A在查询该铺位的FLAG时，值为0，准备预订并将值设为1，而与此同时B已经预订成功，并已将FLAG设为1。而A因为没有即时查询到FLAG=1，因此也预订成功，又将FLAG设为1。

A      FLAG=0      时刻=T1   （查询）

B      FLAG=0      时刻=T2   （查询）

B      FLAG=1      时刻=T3   （更新）

A      FLAG=1      时刻=T4   （更新）

这样就造成了重复订票，在购票高峰期，使用这样的方案，重复订票不可避免。

 

方案2：

    我们想到了利用数据库的悲观锁来解决这个问题，设想假如用户A查询到想预订的票，用户B根本都查询不到，只有A一个人能看到，那是不是没有重复订票的可能了，因为压根没人跟他抢。可以这样实现这个方案：

select * from table where …… for update skip locked，该语句是查询用户指定条件的票信息，并加锁（for update），如果有记录已经被锁则自动跳到下一条记录（skip locked），这样谁先查询谁就可以慢慢的考虑要上铺还是下铺。但火车票系统是这样做的吗？显然不是，因为这样用户体验太不好，票实际还很多，但确看不到买不到，这显然不合理。

 

方案3：

    我们又想到了从程序层面来解决并发问题，最简便的方式是利用synchronized来处理，但我们要知道一个大型系统必然是集群方式部署的，synchronized只能解决单节点环境的并发问题，要解决此问题还是必须依赖全局性的锁机制。

 

方案4：

    既然又回到了在数据库上加锁，我们又想一下如果我们在查询时，使用乐观锁，但在预订之前使用悲观锁会怎样呢？例如我们查询时：

select * from table where ……

用户A、用户B都查询到了相同的票信息（中铺和下铺），用户A或用户B在预订时做一次悲观锁：

select * from table where …… for update（只对预订的票做悲观锁）

此时后者在预订时，无法获取该记录的锁，自然就无法预订，避免了重复预订的问题。