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

Posted 2022-11-28 szs00szs

---

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;