并发insert情况下会发生重复的数据插入问题
2017-03-06 20:58
2011 查看
并发insert情况下会发生重复的数据插入问题
1.背景
用多线程接收推送的订单数据,把接收的订单数据存到一个表中,实现的需求是:如果接收的订单消息在数据库中已经存在,那么执行update操作;如果没有存在,那么执行insert操作
代码逻辑:
线程启动后,发现:数据库表中有两条oderid相同的记录
通过查看日志发现:
两个线程相差时间极端,各自收到了同一个订单的推送消息,在执行数据库insert或update时,都判断出该订单在数据库表中不存在,所以都执行insert操作,造成数据库表中有两条orderid相同的记录
2.解决方案
synchronized同步代码块即加同步锁,synchronized同步代码块的功能:
1)、当A线程访问对象的synchronized代码块的时候,B线程依然可以访问对象方法中其余非synchronized块的部分
2)、当A线程进入对象的synchronized代码块的时候,B线程如果要访问这段synchronized块,那么访问将会被阻塞
3.多台服务器相互之间的并发导致有重复的订单数据问题解决
解决方案:
在数据库层面,用unique唯一性约束来保证数据的数据库表orderid的唯一性.
添加了唯一性约束后,假设A机器insert成功了,那么B机器再insert的时候会违反唯一性约束,报InvocationTargetException这个异常,捕获该异常后,进行update操作
1.背景
用多线程接收推送的订单数据,把接收的订单数据存到一个表中,实现的需求是:如果接收的订单消息在数据库中已经存在,那么执行update操作;如果没有存在,那么执行insert操作
代码逻辑:
if(该订单在数据库表中存在){ update(); }else{ insert(); }
线程启动后,发现:数据库表中有两条oderid相同的记录
通过查看日志发现:
两个线程相差时间极端,各自收到了同一个订单的推送消息,在执行数据库insert或update时,都判断出该订单在数据库表中不存在,所以都执行insert操作,造成数据库表中有两条orderid相同的记录
2.解决方案
synchronized同步代码块即加同步锁,synchronized同步代码块的功能:
1)、当A线程访问对象的synchronized代码块的时候,B线程依然可以访问对象方法中其余非synchronized块的部分
2)、当A线程进入对象的synchronized代码块的时候,B线程如果要访问这段synchronized块,那么访问将会被阻塞
if(该订单在数据库表中存在){ update(); }else{ synchronized(this){ if(该订单在数据库表中存在){ update(); }else{ insert(); } } }上面用synchronized同步代码块解决了在单点服务器中涉及到的并发问题,但是synchronized同步代码块在部署到多台服务器会失效,因为假设A机器在在执行数据库insert,判断出数据库中没有某个订单的数据,同时此刻B机器也判断出没有该订单数据,两台机器都进行insert操作,造成数据库中有重复的订单数据
3.多台服务器相互之间的并发导致有重复的订单数据问题解决
解决方案:
在数据库层面,用unique唯一性约束来保证数据的数据库表orderid的唯一性.
添加了唯一性约束后,假设A机器insert成功了,那么B机器再insert的时候会违反唯一性约束,报InvocationTargetException这个异常,捕获该异常后,进行update操作
if (该订单在数据库表中存在) { update(); } else { synchronized (this) { if (该订单在数据库表中存在) { update(); } else { try { insert(); } catch (InvocationTargetException e) { update(); } } } }
相关文章推荐
- 并发insert情况下会发生重复的数据插入问题
- 并发insert情况下会发生重复的数据插入问题
- 并发insert情况下会发生重复的数据插入问题
- insert中加入where条件判断,解决插入重复数据的问题
- 并发下,使用redis防止数据重复插入(数据库未对表字段设置唯一情况下)
- insert中加入where条件判断,解决插入重复数据的问题
- java 解决分布式环境中 高并发环境下数据插入重复问题
- mysql并发插入重复数据问题的解决思路
- 并发插入insert,根据状态判断重复记录的问题
- 数据库并发插入避免重复数据的问题
- 大量数据情况下单线程插入和多线程(高并发)insert数据库的性能测试
- Java多线程:解决高并发环境下数据插入重复问题
- mysql中避免重复插入相同数据(insert if not exists)
- mysql 使用 insert ignore into和unique实现不插入重复数据功能
- 关于含有标识字段的数据表中记录的插入问题解决(IDENTITY_INSERT)
- 如何优化用SQL语句INSERT INTO … SELECT插入数据时锁全表的问题
- java后台并发插入数据问题
- Mysql实现数据的不重复写入(insert if not exists)以及新问题:ID自增不连续的解答
- 值班问题:insert语句插入了两条数据?
- 大量数据情况下单线程插入和多线程insert数据库的性能测试