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