知識星球（點選上方公眾號，可快速關註）
來源：等你歸去來 ，
www.cnblogs.com/yougewe/p/7782175.html
前話： 不要迷戀事務，大事務會拖垮你的使用者！
相信很多應用都需要進行一些後臺任務的處理，這時候應對的，往往是大批次的資料。比如：對資料進行彙總結算,需要全表掃描,更新; 對使用者訂單狀態進行更新,需要全表掃描,進行更新; 對使用者的會員有效期處理,也需要全表掃描,更新！
應對這樣的場景，就是定時任務job的職責範疇了。
那麼問題來了，這樣的場景需要進行事務控制嗎？ 我覺得這個得看業務需求，比如這個狀態不是很重要，那麼可以不用進行事務控制。但是更多時候，我們希望是有事務的，因為往往更新不會是單表的。
在spring中，有一個簡單的註解，即可以幫忙實現事務的控制。
@Transactional(readOnly = false, rollbackFor = Throwable.class, isolation = Isolation.REPEATABLE_READ)
一個事務搞定！但是問題來了，這裡報錯了。
java.lang.Exception:
### Error updating database. Cause: java.sql.SQLException: Lock wait timeout exceeded; try restarting transaction
### The error may involve defaultParameterMap
### The error occurred while setting parameters
### Cause: java.sql.SQLException: Lock wait timeout exceeded; try restarting transaction
; SQL []; Lock wait timeout exceeded; try restarting transaction; nested exception is java.sql.SQLException: Lock wait timeout exceeded; try restarting transaction
究其原因，就是mysql 鎖等待超時。這裡的等待超時有兩種情況，
-
是該定時任務後執行，是在等待別的客戶端釋放鎖，而遲遲未得到從而超時。
-
是其他客戶端在操作時，由於被該定時任務長時間的佔有鎖，從而導致其等待超時。
當然，更多的可能是第二種。為什麼呢？ 因為定時任務往往需要處理大量的資料，這時，如果使用了一個最外圍的事務，那麼相當於整個指令碼都是執行在該事務中，只要該指令碼還未執行完成，那麼事務就不會提交，也就不會釋放他佔有的鎖資源。所以，問題就在這裡了。所以，我們得避免進行大事務的形成就很有必要了。
事實上，事務的目的是為了保證資料的原子性，準確性，那麼也就是說，只要你需要保證的資料做到了，就可以進行事務提交了。所以，可以將大事務拆小，即保證最小事務的執行即可。如：更新一個使用者的會員狀態，那麼只需要查出相關資訊，更改狀態，寫入相應記錄，該事務即可提交。
將大事務拆小後，就可以做到快速釋放鎖的作用，從而避免了其他客戶端的鎖等待超時問題了。
樣例： 更新使用者的賬單狀態，步驟為： 查詢出所有需要更新的賬單數量 >> 定稿job執行開始記錄 >> 更新每個訂單狀態 >> 寫入job執行結束標識 >> 完成！
該過程，主要耗時是在對每個使用者的賬單更新，因此，可以將該處作為事務拆小的依據，具體程式碼如下：
主事務進行總體控制
// 使用新執行緒進行具體執行功能，需另起事務控制或接收原有事務
@Override
public Integer updateBorrowStatus(JobParamBean jobParamBean) {
String method = “updateBorrowStatus”;
logger.info(“enter {} method, jobParamBean:{}”, method, jobParamBean);
// 更新資料庫
Integer result = null;
Map
cond = new HashMap<>(); //borrowApplyTimeStart, borrowApplyTimeEnd, borrowStatusList, pageStart, perPageNum
// cond.put(“borrowApplyTimeStart”, jobParamBean.getStartTime());
// cond.put(“borrowApplyTimeEnd”, jobParamBean.getEndTime());
cond.put(“shouldRepayTimeStart”, jobParamBean.getStartTime());
cond.put(“shouldRepayTimeEnd”, jobParamBean.getEndTime());
List
borrowStatusList = new ArrayList<>(); borrowStatusList.add(“3”);
cond.put(“borrowStatusList”, borrowStatusList);
Integer totalUpdate = borrowMapper.countUsersBorrowListByMap(cond);
String dubboConsumerIp = jobParamBean.getDubboConsumerIp();
String myServerIp = “127.0.0.1”;
try {
myServerIp = InetAddress.getLocalHost().getHostAddress();
} catch (UnknownHostException e) {
logger.error(“get local server ip error:{}”, e);
}
Date now = new Date();
JobExecRecordEntity recordEntity = new JobExecRecordEntity();
BeanUtils.copyProperties(jobParamBean, recordEntity);
recordEntity.setJobName(“autoUpdateBorrowStatus”);
recordEntity.setExecDateStart(jobParamBean.getEndTime()); // 結束時間為最近時間
recordEntity.setExecDateEnd(jobParamBean.getStartTime());
recordEntity.setTotalAffectNum(totalUpdate);
recordEntity.setReqParams(JSONObject.toJSONString(jobParamBean));
recordEntity.setJobParams(JSONObject.toJSONString(cond));
recordEntity.setExecServerIp(myServerIp);
recordEntity.setReqServerIp(dubboConsumerIp);
recordEntity.setJobEndTime(DateUtils.convert(now, “yyyy-MM-dd HH:mm:ss.S”));
Integer recordAffectNum = jobExecRecordMapper.addJobExecRecord(recordEntity);
Long recordId = recordEntity.getId();
Integer realUpdateNum = 0;
if(totalUpdate != null && totalUpdate > 0) {
Integer pageStart = 0;
Integer perPageNum = 10;
String nowDateStr = DateUtils.convert(now, “yyyy-MM-dd”); //當前時間
for(int i = 0; i < totalUpdate; i += perPageNum) {
pageStart = i;
cond.put(“pageStart”, pageStart);
cond.put(“perPageNum”, perPageNum);
Integer thisAffectNum = platformAssistantBusiness.pieceUpdateBorrowStatus(cond, nowDateStr); // 使用輔助類進行小事務的拆分
realUpdateNum += thisAffectNum;
recordEntity.setCurrentAffectNum(perPageNum);
recordEntity.setRealAffectNum(thisAffectNum);
recordEntity.setStatus(“1”);
jobExecRecordMapper.updateJobExecRecord(recordEntity);
}
}
recordEntity.setStatus(“5”);
recordEntity.setCurrentAffectNum(0);
recordEntity.setRealAffectNum(0);
String jobEndTime = DateUtils.convert(new Date(), “yyyy-MM-dd HH:mm:ss.S”);
recordEntity.setJobEndTime(jobEndTime);
jobExecRecordMapper.updateJobExecRecord(recordEntity);
result = totalUpdate;
logger.info(“exit {} method, result:{}”, method, result);
return result;
}
小事務放在另一方法中，以確保事務生效！
@Override
@Transactional(readOnly = false, rollbackFor = Throwable.class, isolation = Isolation.REPEATABLE_READ, propagation = Propagation.REQUIRES_NEW)
public Integer pieceUpdateBorrowStatus(Map
cond, String nowDateStr) { String shouldRepayDate = “”;
Long lateDays = 0L;
String borrowStatus;
Integer thisAffectNum = 0;
List
pageList1 = borrowMapper.getUsersBorrowListByMap(cond); for(UsersBorrowEntity borrowEntity1 : pageList1) {
UsersBorrowEntity updateBorrowEntity = new UsersBorrowEntity();
updateBorrowEntity.setId(borrowEntity1.getId());
updateBorrowEntity.setUserId(borrowEntity1.getUserId());
shouldRepayDate = borrowEntity1.getShouldRepayTime();
lateDays = DateUtils.getDayDiff(shouldRepayDate, nowDateStr);
if(lateDays != null && lateDays >= 0 && !”8″.equals(borrowEntity1.getBorrowStatus())) {
if(lateDays == 0) {
borrowStatus = “5”;
} else {
borrowStatus = “6”;
}
updateBorrowEntity.setBorrowStatus(borrowStatus);
updateBorrowEntity.setRepayStatus(CommonUtil.getRepayStatusByBorrowStatus(borrowStatus));
updateBorrowEntity.setLateDays(lateDays.intValue());
Integer affectNum = usersBorrowMapper.updateUsersBorrow(updateBorrowEntity);
thisAffectNum += affectNum;
}
}
return thisAffectNum;
}
這樣就保證了，執行的完整性，然後，每10個小事務就進行提交一次。從而解決鎖超時問題了。
看完本文有收穫？請轉發分享給更多人
關註「ImportNew」，看技術乾貨
