并发insert情况下会发生重复的数据插入问题

1.背景
用多线程接收推送的订单数据,把接收的订单数据存到一个表中,实现的需求是:如果接收的订单消息在数据库中已经存在,那么执行update操作;
如果没有存在,那么执行insert操作代码逻辑:

if(oderid != null){
    //该记录已存在
    update();  
}else{  
    //写入记录
    insert();  
}

线程启动后,发现:数据库表中有两条oderid相同的记录

通过查看日志发现:
  两个线程相差时间极端,各自收到了同一个订单的推送消息,在执行数据库insert或update时,都判断出该订单在数据库表中不存在,所以都执行insert操作,造成数据库表中有两条orderid相同的记录
2.解决方案
synchronized同步代码块即加同步锁,synchronized同步代码块的功能:
1)、当A线程访问对象的synchronized代码块的时候,B线程依然可以访问对象方法中其余非synchronized块的部分
2)、当A线程进入对象的synchronized代码块的时候,B线程如果要访问这段synchronized块,那么访问将会被阻塞

if(oderid != null){ 
   //该记录已存在
   update();  
}else{
   synchronized(this){
      if(oderid != null){
        //该记录已存在
        update();
      }else{
        insert();
      }
   }  
}

上面用synchronized同步代码块解决了在单点服务器中涉及到的并发问题,但是synchronized同步代码块在部署到多台服务器会失效,因为假设A机器在在执行数据库insert,
判断出数据库中没有某个订单的数据,同时此刻B机器也判断出没有该订单数据,两台机器都进行insert操作,造成数据库中有重复的订单数据
3.多台服务器相互之间的并发导致有重复的订单数据问题解决
解决方案:
在数据库层面,用unique唯一性约束来保证数据的数据库表orderid的唯一性.
添加了唯一性约束后,假设A机器insert成功了,那么B机器再insert的时候会违反唯一性约束,报InvocationTargetException这个异常,捕获该异常后,进行update操作

if(oderid != null) {  
    update();  
} else {  
    synchronized (this) {  
        if(oderid != null) { 
            //该记录已存在
            update();  
        } else {  
            try {  
                insert();  
            } catch (Exception e) {  
                update();  
            }
        }  
    }  
} 

转载至 http://blog.csdn.net/lululove19870526/article/details/60592981

原文地址:https://www.cnblogs.com/rinack/p/7831080.html