您的位置:首页 > 其它

高并发时,进行insert操作出现重复记录问题分析

2017-03-21 17:46 274 查看
1.背景

在进行insert时,先query一下数据库,判断记录是否存在,如果存在,不执行插入操作。但是在数据量较大的时候,就会出现重复记录的问题。

if (bean != null) {
map.put("msg", "failed");
return map;
}
repaymentDao.insert(repaymentBean);
map.put("msg", "success");
//扣除冻结账户
//updateUserAmount(repaymentBean);
return map;
}


2.解决方案

synchronized同步代码块即加同步锁,synchronized同步代码块的功能:

1)、当A线程访问对象的synchronized代码块的时候,B线程依然可以访问对象方法中其余非synchronized块的部分
2)、当A线程进入对象的synchronized代码块的时候,B线程如果要访问这段synchronized块,那么访问将会被阻塞


if (bean != null) {
map.put("msg", "failed");
return map;
}else {
synchronized (this) {
repaymentDao.insert(repaymentBean);
map.put("msg", "success");
//扣除冻结账户
//updateUserAmount(repaymentBean);
return map;
}


上面用synchronized同步代码块解决了在单点服务器中涉及到的并发问题,但是synchronized同步代码块在部署到多台服务器会失效,因为假设A机器在在执行数据库insert,判断出数据库中没有该条记录,同时此刻B机器也判断出没有没有该条记录,两台机器都进行insert操作,造成数据库中有重复的记录 。

3.多台服务器相互之间的并发导致有重复的订单数据问题解决

在数据库层面,用unique唯一性约束来保证数据的数据库表orderid的唯一性.

添加了唯一性约束后,假设A机器insert成功了,那么B机器再insert的时候会违反唯一性约束,报InvocationTargetException这个异常,捕获该异常后,return。


if (bean != null) {
map.put("msg", "failed");
return map;
}else {
synchronized (this) {
try {
repaymentDao.insert(repaymentBean);
map.put("msg", "success");
//扣除冻结账户
//updateUserAmount(repaymentBean);
return map;
} catch (Exception e) {
map.put("msg", "failed");
return map;
}
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐