并发insert情况下会发生重复的数据插入问题
1.背景
? ?用多線程接收推送的訂單數(shù)據(jù)，把接收的訂單數(shù)據(jù)存到一個表中，實現(xiàn)的需求是：如果接收的訂單消息在數(shù)據(jù)庫中已經(jīng)存在，那么執(zhí)行update操作；如果沒有存在，那么執(zhí)行insert操作
?代碼邏輯：
? ?
if(該訂單在數(shù)據(jù)庫表中存在){
update();
}else{
insert();
}
?
?
? ?
? 線程啟動后，發(fā)現(xiàn)：數(shù)據(jù)庫表中有兩條oderid相同的記錄
? ?通過查看日志發(fā)現(xiàn)：
? ? ? ? ? ? ? ? 兩個線程相差時間極端，各自收到了同一個訂單的推送消息，在執(zhí)行數(shù)據(jù)庫insert或update時，都判斷出該訂單在數(shù)據(jù)庫表中不存在，所以都執(zhí)行insert操作，造成數(shù)據(jù)庫表中有兩條orderid相同的記錄
2.解決方案
synchronized同步代碼塊即加同步鎖,synchronized同步代碼塊的功能：
? ? ? ?1)、當A線程訪問對象的synchronized代碼塊的時候，B線程依然可以訪問對象方法中其余非synchronized塊的部分
? ? ? ?2)、當A線程進入對象的synchronized代碼塊的時候，B線程如果要訪問這段synchronized塊，那么訪問將會被阻塞
? ??
if(該訂單在數(shù)據(jù)庫表中存在){
update();
}else{
synchronized(this){
if(該訂單在數(shù)據(jù)庫表中存在){
update();
}else{
insert();
}
}
}
上面用synchronized同步代碼塊解決了在單點服務(wù)器中涉及到的并發(fā)問題，但是synchronized同步代碼塊在部署到多臺服務(wù)器會失效，因為假設(shè)A機器在在執(zhí)行數(shù)據(jù)庫insert，判斷出數(shù)據(jù)庫中沒有某個訂單的數(shù)據(jù)，同時此刻B機器也判斷出沒有該訂單數(shù)據(jù)，兩臺機器都進行insert操作，造成數(shù)據(jù)庫中有重復的訂單數(shù)據(jù)
?
3.多臺服務(wù)器相互之間的并發(fā)導致有重復的訂單數(shù)據(jù)問題解決
解決方案：
? ? ? ?在數(shù)據(jù)庫層面，用unique唯一性約束來保證數(shù)據(jù)的數(shù)據(jù)庫表orderid的唯一性.
? ? ? ?添加了唯一性約束后，假設(shè)A機器insert成功了，那么B機器再insert的時候會違反唯一性約束，報InvocationTargetException這個異常，捕獲該異常后，進行update操作
? ? ? ?
if (該訂單在數(shù)據(jù)庫表中存在) {
update();
} else {
synchronized (this) {
if (該訂單在數(shù)據(jù)庫表中存在) {
update();
} else {
try {
insert();
} catch (InvocationTargetException e) {
update();
}
}
}
}
來源:https://blog.csdn.net/lululove19870526/article/details/60592981
總結(jié)
以上是生活随笔為你收集整理的并发insert情况下会发生重复的数据插入问题的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 大数据量高并发访问的数据库优化方法
- 下一篇： ansible使用