插入資料庫，在大家開發過程中是很經常的事情，假設我們有這麼一個需求：

1、我們需要接收一個外部的訂單，而這個訂單號是不允許重複的

2、資料庫對外部訂單號沒有做唯一性約束

3、外部經常插入相同的訂單，對於已經存在的訂單則拒絕處理

對於這個需求，很簡單我們會用下面的程式碼進行處理（思路：先查詢資料庫，如果資料庫存在則直接退出，否則插入）

package com.yhj.test;

import com.yhj.dao.OrderDao;

import com.yhj.pojo.Order;

/**

 * @Description:併發測試用例

 * @Author YHJ  create at 2011

-7-7 上午08:41:44

 * @FileName com.yhj.test.TestCase.java

 */

publicclass TestCase {

/**

     * data access object class for deal order

     */

private OrderDao orderDao;

/**

     * @Description:插入測試

     * @param object 要插入的object例項

     * @author YHJ create at 2011-7-7 上午08:43:15

     * @throws

 Exception

     */

publicvoid doTestForInsert(Order order) throws Exception {

       Order orderInDB = orderDao.findByName(order.getOrderNo());

if(null != orderInDB)

thrownew Exception("the order has been exist!");

orderDao.save(order);

    }

}

這樣很顯然，在單執行緒下是沒問題的，但是多執行緒情況下就會出現一個問題，執行緒1

先去訪問DB，查詢沒有，開始插入，這時候執行緒2又來查詢DB，而此時執行緒1插入的事務還沒有提交，執行緒2沒有查到該資料，也進行插入，於是，問題出現了，插入了2條一樣訂單。

對於這種情況，好像如果不用資料庫做唯一性約束又不借助外部其他的一些工具，是沒有辦法實現的。那怎麼做呢？

引入快取，我們看下面的程式碼

package com.yhj.test;

import com.yhj.dao.OrderDao;

import com.yhj.pojo.Order;

import com.yhj.util.MemcacheUtil;

import com.yhj.util.MemcacheUtil.UNIT;

/**

 * @Description:併發測試用例

 * @Author YHJ  create at 2011-7-7 上午08:41:44

 * @FileName com.yhj.test.TestCase.java

 */

publicclass TestCase {

/**

     * data access object class for deal order

     */

private OrderDao orderDao;

/**

     * @Description:插入測試

     * @param object 要插入的object例項

     * @author YHJ create at 2011-7-7 上午08:43:15

     * @throws Exception

     */

publicvoid doTestForInsert(Order order){

       String key=null;

try{

           Order orderInDB = orderDao.findByName(order.getOrderNo());

//查DB，如果資料庫已經有則丟擲異常

if(null != orderInDB)

thrownew Exception("the order has been exist!");

           key=order.getOrderNo();

//插快取，原子性操作，插入失敗表明已經存在

if(!MemcacheUtil.add(key, order, MemcacheUtil.getExpiry(UNIT.MINUTE, 1)))

thrownew Exception("the order has been exist!");

//插DB

orderDao.save(order);

       }catch (Exception e) {

           e.printStackTrace();

       }finally{

           MemcacheUtil.del(key);

       }

    }

}

執行步驟如下：

1、查詢資料庫，如果資料庫已經存在則丟擲異常

2、插入快取，如果插入失敗則表明快取中已經存在，丟擲異常

3、如果上述2步都沒有丟擲異常，則執行插入資料庫的操作

4、刪除快取

在併發的情況下，執行緒1先查詢資料庫，發現沒有，繼續執行，寫快取，這時候執行緒2開始查詢資料庫，發現沒有，則寫快取，結果快取中已經存在，寫快取失敗，丟擲異常，返回已存在。執行緒1執行插入資料庫成功，刪除快取。以後再來的執行緒發現數據庫已經存在了，則不在向下執行，直接返回.。

機器異常情況下，不能執行finally語句，但是放在memcache中的資料會在1分鐘後超時。

貌似沒有問題。使用LodeRunner測試100個併發的操作，發現仍然有重複的訂單插入，這個是為什麼呢？我們再來看這段程式碼！

publicvoid doTestForInsert(Order order){

       String key=null;

try{

           Order orderInDB = orderDao.findByName(order.getOrderNo());

//查DB，如果資料庫已經有則丟擲異常

if(null != orderInDB)

thrownew Exception("the order has been exist!");

           key=order.getOrderNo();

//插快取，原子性操作，插入失敗表明已經存在

if(!MemcacheUtil.add(key, order, MemcacheUtil.getExpiry(UNIT.MINUTE, 1)))

thrownew Exception("the order has been exist!");

//插DB

orderDao.save(order);

       }catch (Exception e) {

           e.printStackTrace();

       }finally{

           MemcacheUtil.del(key);

       }

    }

我們所預料的是2個執行緒同時操作，假設有更多的併發執行緒呢？

時刻1：

執行緒1到達，查資料庫，發現沒有

時刻2

執行緒1寫快取

執行緒

相關推薦