關於Java並發insert情況下會發生重復的數據問題

一、背景

用多線程接收推送的訂單數據，把接收的訂單數據存到一個表中。

實現的需求是：如果接收的訂單消息在數據庫中已經存在，那么執行update操作；

如果沒有存在，那么執行insert操作代碼邏輯：

if(oderid != null){
    //該記錄已存在
    update();  
}else{  
    //寫入記錄
    insert();  
}

線程啟動后，發現：數據庫表中有兩條oderid相同的記錄。

通過查看日志發現：

兩個線程相差時間極端，各自收到了同一個訂單的推送消息，在執行數據庫insert或update時，都判斷出該訂單在數據庫表中不存在，所以都執行insert操作，造成數據庫表中有兩條orderid相同的記錄。

 

二、解決方案

1、在數據庫表中添加了唯一索引，那么就不會出現重復數據了，如果連續推送客戶會收到一條推送失敗的提示信息。

2、使用數據庫的悲觀鎖和樂觀鎖；

 

3、synchronized同步代碼塊即加同步鎖,synchronized同步代碼塊的功能：

a)、當A線程訪問對象的synchronized代碼塊的時候，B線程依然可以訪問對象方法中其余非synchronized塊的部分；

b)、當A線程進入對象的synchronized代碼塊的時候，B線程如果要訪問這段synchronized塊，那么訪問將會被阻塞；

if(oderid != null){ 
   //該記錄已存在
   update();  
}else{
   synchronized(this){
      if(oderid != null){
        //該記錄已存在
        update();
      }else{
        insert();
      }
   }  
}

上面用synchronized同步代碼塊解決了在單點服務器中涉及到的並發問題，但是synchronized同步代碼塊在部署到多台服務器會失效。

因為假設A機器在在執行數據庫insert，判斷出數據庫中沒有某個訂單的數據，同時此刻B機器也判斷出沒有該訂單數據，兩台機器都進行insert操作，造成數據庫中有重復的訂單數據。

 

4、多台服務器相互之間的並發導致有重復的訂單數據問題解決

在數據庫層面，用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();  
            }
        }  
    }  
}