程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> MYSQL數據庫 >> 關於MYSQL數據庫 >> 並發環境下mysql插入檢查方案

並發環境下mysql插入檢查方案

編輯:關於MYSQL數據庫

業務背景:
基本業務場景是這樣的,請求數據(車輛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,導致庫中數據混亂,出現錯誤。

以上就是本文的全部內容,希望對大家的學習有所幫助。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved