zoukankan      html  css  js  c++  java
  • 关于Java并发insert情况下会发生重复的数据问题

    一、背景

    用多线程接收推送的订单数据,把接收的订单数据存到一个表中。

    实现的需求是:如果接收的订单消息在数据库中已经存在,那么执行update操作;

    如果没有存在,那么执行insert操作代码逻辑:

    if(oderid != null){
        //该记录已存在
        update();  
    }else{  
        //写入记录
        insert();  
    }

    线程启动后,发现:数据库表中有两条oderid相同的记录。

    通过查看日志发现:

    两个线程相差时间极端,各自收到了同一个订单的推送消息,在执行数据库insert或update时,都判断出该订单在数据库表中不存在,所以都执行insert操作,造成数据库表中有两条orderid相同的记录。

    二、解决方案

    1、在数据库表中添加了唯一索引,那么就不会出现重复数据了,如果连续推送客户会收到一条推送失败的提示信息。

    2、使用数据库的悲观锁和乐观锁;

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

    a)、当A线程访问对象的synchronized代码块的时候,B线程依然可以访问对象方法中其余非synchronized块的部分;

    b)、当A线程进入对象的synchronized代码块的时候,B线程如果要访问这段synchronized块,那么访问将会被阻塞;

    if(oderid != null){ 
       //该记录已存在
       update();  
    }else{
       synchronized(this){
          if(oderid != null){
            //该记录已存在
            update();
          }else{
            insert();
          }
       }  
    }

    上面用synchronized同步代码块解决了在单点服务器中涉及到的并发问题,但是synchronized同步代码块在部署到多台服务器会失效。

    因为假设A机器在在执行数据库insert,判断出数据库中没有某个订单的数据,同时此刻B机器也判断出没有该订单数据,两台机器都进行insert操作,造成数据库中有重复的订单数据。

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

    在数据库层面,用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();  
                }
            }  
        }  
    } 
  • 相关阅读:
    表设计二,联接查询
    表设计一,联接查询
    聚合函数,更新和删除
    Asp.Net MVC项目中如何调试ActiveX插件
    vs2019发布Web到云服务器(IIS)
    event.getRawX()和event.getX()的区别
    android 设备标识
    依赖注入那些事儿
    关于心跳包
    TCP的三次握手(建立连接)和四次挥手(关闭连接)
  • 原文地址:https://www.cnblogs.com/ZJOE80/p/14368284.html
Copyright © 2011-2022 走看看