欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

并发环境下mysql插入检查方案

程序员文章站 2024-02-21 10:37:13
业务背景: 基本业务场景是这样的,请求数据(车辆vin信息)进入到接口中,需要先判断其在数据库中的状态,如果库中不存在该vin,或者该vin状态位为“1(已完成)”,则...

业务背景:
基本业务场景是这样的,请求数据(车辆vin信息)进入到接口中,需要先判断其在数据库中的状态,如果库中不存在该vin,或者该vin状态位为“1(已完成)”,则执行一些检查操作后,将数据插入到数据库中,此时新增vin状态为0,调用人工处理接口,十分钟后返回结果,将状态置为1。如果其状态位为“0(正在处理)”则驳回操作,返回提示信息。
在单线程环境下,这样的业务没有问题,然而当并发访问接口时,会出现同时进入两条vin相同的请求ab,正常情况应该插入一条a,驳回一条b。然而并发环境下,b执行检查状态时a还没有插入,因此ab都进入到了数据库中,数据就错误了。

解决方案一:
首先想到的是使用sql处理,对数据库对应字段加唯一索引,保证一致性。如果插入重复的数据,则catch该异常,做出提示。

alter tablename add unique [indexname] on (tablecolumns(length))

但是由于业务限制,vin在库中是可以重复的,多条重复数据查询最新,所以不能再vin上添加唯一索引。

解决方案二:
使用mysql事务操作,将检查是否存在和插入作为一个事务进行处理,当检查失败的时候,不进行插入。从网上搜索了一下,大致思路如下:

public static void starttransaction(connection con, string[] sqls) throws exception { 
    try { 
      // 事务开始 
      con.setautocommit(false);  // 设置连接不自动提交,即用该连接进行的操作都不更新到数据库 
      sm = con.createstatement(); // 创建statement对象 

      //依次执行传入的sql语句 
      for (int i = 0; i < sqls.length; i++) { 
        sm.execute(sqls[i]);// 执行添加事物的语句 
      } 
      con.commit();  // 提交给数据库处理 
      // 事务结束 

    //捕获执行sql语句组中的异常   
    } catch (sqlexception e) { 
      try { 
        system.out.println("事务执行失败,进行回滚!\n"); 
        con.rollback(); // 若前面某条语句出现异常时,进行回滚,取消前面执行的所有操作 
      } catch (sqlexception e1) { 
        e1.printstacktrace(); 
      } 
    } finally { 
      sm.close(); 
    } 
  }

但是这样实际上还是没有解决并发的问题,这样只是把两个操作变成了一个原子的sql操作,可以用于同时插入两条数据一致性的情况,但并不适合需求。

既然sql层面没有解决问题,就考虑从java的并发编程方向解决。
解决方案三:
java解决并发问题,首先想到的是使用内置锁或者可重入锁,基本语法如下:
·内置锁:
由于是在servlet中进行的处理,因此使用synchronized(this)直接处理业务代码,使得并发情况下,只能有一个线程访问到该段业务代码:

synchronized(this){
  //todo1:检查vin是否存在
  //todo2:如果不存在插入vin
}

·可重入锁:
相当于更灵活的内置锁,在这里与内置锁基本相同

public class dashengcallback extends httpservlet {
  private static reentrantlock lock= new reentrantlock();
  protected void doget(httpservletrequest request, httpservletresponse response){
    lock.lock();
    try{
      //todo1:检查vin是否存在
      //todo2:如果不存在插入vin
    }finally{
      lock.unlock();
    }
  }
}

经过测试,这个方案是可行的,最终没有采用的原因是因为直接使用这种方式加锁,加锁的代码太多,影响效率。

解决方案四:
设置一个查询map,插入前存储数据,插入后删除数据,代码如下:

    concurrenthashmap<string, string> vinmap=new concurrenthashmap<string,string>();
    if(vinmap.containskey(vin)){
      // todo1: vin 请求完毕后, 从vininrequestmap里删掉这个vinno
      // todo2: 返回正在查询
    }
    vinmap.put(vin, "");
    //todo3:插入vin到数据库
    vinmap.remove(vin);
  }

这个方案基本满足了业务需求,唯一的问题是要求接口的更新时间要与业务时间错开,否则更新接口会清空vinmap,导致库中数据混乱,出现错误。

以上就是本文的全部内容,希望对大家的学习有所帮助。