更新于 2018-12-23 22:21:44
添加了多線程測試代碼
思路
| sCode | sName | sQz | sValue |
|---|---|---|---|
| order | 訂單 | DD | 18120100 |
- 首先每個業(yè)務(wù)的流水號對應(yīng)表中的一條數(shù)據(jù)
- 每個要獲取流水號的線程調(diào)用 一個用來生成流水號的 存儲過程
- 根據(jù)sCode 找到 sValue。
if (sValue == null)
初始化值
else
sValue ++
敲黑板！劃重點埠通！
- 分析：上述的思路看似沒什么問題逛犹，但是如果兩個線程并發(fā)的執(zhí)行會出現(xiàn)兩個事務(wù)讀取到相同的數(shù)據(jù)，同時都執(zhí)行初始化或者自增虽画。
- 方案：使用 MySQL 寫鎖（select...for update，也叫X鎖渗柿，排它鎖） 來解決這一問題
- 例如：事務(wù)A和事務(wù)B同時進行脖岛，事務(wù)A 拿到 當前這條數(shù)據(jù)的寫鎖，此時如果事務(wù)B 想訪問這條數(shù)據(jù)需要等待事務(wù)A結(jié)束陨溅。并發(fā)時讓兩個事務(wù)對同一條數(shù)據(jù)的操作變成了串行化绍在。
CREATE TABLE `sys_sno` (
`sCode` varchar(50) DEFAULT NULL COMMENT '編碼',
`sName` varchar(100) DEFAULT NULL COMMENT '名稱',
`sQz` varchar(50) DEFAULT NULL COMMENT '前綴',
`sValue` varchar(80) DEFAULT NULL COMMENT '值'
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
CREATE DEFINER=`root`@`localhost` PROCEDURE `GetSerialNo`(IN tsCode VARCHAR(50),OUT result VARCHAR(200) )
BEGIN
DECLARE tsValue VARCHAR(50);
DECLARE tdToday VARCHAR(20);
DECLARE nowdate VARCHAR(20);
DECLARE tsQZ VARCHAR(50);
DECLARE t_error INTEGER DEFAULT 0;
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;
START TRANSACTION;
/* UPDATE sys_sno SET sValue=sValue WHERE sCode=tsCode; */
SELECT sValue INTO tsValue FROM sys_sno WHERE sCode=tsCode for UPDATE;
SELECT sQz INTO tsQZ FROM sys_sno WHERE sCode=tsCode ;
-- 因子表中沒有記錄，插入初始值
IF tsValue IS NULL THEN
SELECT CONCAT(DATE_FORMAT(NOW(),'%y%m'),'0001') INTO tsValue;
UPDATE sys_sno SET sValue=tsValue WHERE sCode=tsCode ;
SELECT CONCAT(tsQZ,tsValue) INTO result;
ELSE
SELECT SUBSTRING(tsValue,1,4) INTO tdToday;
SELECT CONVERT(DATE_FORMAT(NOW(),'%y%m'),SIGNED) INTO nowdate;
-- 判斷年月是否需要更新
IF tdToday = nowdate THEN
SET tsValue=CONVERT(tsValue,SIGNED) + 1;
ELSE
SELECT CONCAT(DATE_FORMAT(NOW(),'%y%m') ,'0001') INTO tsValue ;
END IF;
UPDATE sys_sno SET sValue =tsValue WHERE sCode=tsCode;
SELECT CONCAT(tsQZ,tsValue) INTO result;
END IF;
IF t_error =1 THEN
ROLLBACK;
SET result = 'Error';
ELSE
COMMIT;
END IF;
SELECT result ;
END;
測試代碼
完整測試代碼：https://gitee.com/yintianwen7/taven-springboot-learning/tree/master/uni-number
import com.gitee.taven.uninumber.mapper.OrderMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@Service
public class OrderService {
private static OrderMapper orderMapper;
@Autowired
public void setOrderMapper(OrderMapper orderMapper) {
this.orderMapper = orderMapper;
}
private static final int TOTAL_THREADS = 100;
public void multiThread() {
// 創(chuàng)建固定長度線程池
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(50);
for (int i = 0; i < TOTAL_THREADS; i++) {
Thread thread = new OrderThread();
fixedThreadPool.execute(thread);
}
}
public static class OrderThread extends Thread {
@Override
public void run() {
try {
Map<String, String> parameterMap = initParameterMap();
orderMapper.createOrderNum(parameterMap);
String number = parameterMap.get("result");
System.out.println(Thread.currentThread().getName() + " : " +number);
} catch (Exception e) {
System.out.println(e);
}
}
public Map<String, String> initParameterMap() {
Map<String, String> parameterMap = new HashMap<>();
parameterMap.put("tsCode", "order");
parameterMap.put("result", "-1");
return parameterMap;
}
}
}
// mapper 接口
public interface OrderMapper {
int createOrderNum(Map<String, String> parameterMap);
}
// xml
<update id="createOrderNum" parameterMap="initMap" statementType="CALLABLE">
CALL GetSerialNo(?,?)
</update>
<parameterMap type="java.util.Map" id="initMap">
<parameter property="tsCode" mode="IN" jdbcType="VARCHAR"/>
<parameter property="result" mode="OUT" jdbcType="VARCHAR"/>
</parameterMap>
備注
- 執(zhí)行了一個百個線程之后 可以看一下數(shù)據(jù)溜宽，自增到了100 說明成功了
- 刪掉 存儲過程中的 for update，再執(zhí)行 可以看出鎖的作用
