if(end == sheet.getLastRowNum()){
    logger.info("插入最后一批數(shù)據(jù)，模擬異常");
    int a = 1/0;
}

@Transactional(rollbackFor = Exception.class)
public void readXls(String filePath, String filename) throws Exception{
 try {
  // 省略一些復(fù)雜操作...
   
   List<Future<Integer>> futureList = new ArrayList<>();
  for (int time = 0; time < times; time++) {
   Future<Integer> sumFuture = readExcelDataAsyncFutureService.readXlsCacheAsyncMybatis();
            futureList.add(sumFuture);
  }
  
  // 主線程獲取Future返回值
        boolean futureFlag = getFutureResult(futureList, excelRow);
        if (futureFlag) {
            logger.info("readXlsCacheAsync---插入數(shù)據(jù)成功，提交事務(wù)");
        } else {
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            logger.info("readXlsCacheAsync---插入數(shù)據(jù)失敗，回滾事務(wù)");
        }
 } catch (Exception e) {
  TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
  logger.error("readXlsCacheAsync---插入數(shù)據(jù)異常，回滾事務(wù)：", e);
    }
}

@Async("async-executor")//是否開(kāi)啟異步
@Override
public Integer readXlsCacheAsyncMybatis() {
    try {
     // 省略一些復(fù)雜操作...
    }catch (Exception e){
        throw new RuntimeException("插入數(shù)據(jù)庫(kù)異常", e);
    }
}

public void readXls(String filePath, String filename) throws Exception{
  // 手動(dòng)開(kāi)啟事務(wù),不自動(dòng)提交
    TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
 try {
  // 省略一些復(fù)雜操作...
   
   List<Future<Integer>> futureList = new ArrayList<>();
  for (int time = 0; time < times; time++) {
   Future<Integer> sumFuture = readExcelDataAsyncFutureService.readXlsCacheAsyncMybatis();
            futureList.add(sumFuture);
  }
  
  // 主線程獲取Future返回值
        boolean futureFlag = getFutureResult(futureList, excelRow);
        if (futureFlag) {
         dataSourceTransactionManager.commit(transactionStatus); // 提交
            logger.info("readXlsCacheAsync---插入數(shù)據(jù)成功，提交事務(wù)");
        } else {
            dataSourceTransactionManager.rollback(transactionStatus);// 回滾
            logger.info("readXlsCacheAsync---插入數(shù)據(jù)失敗，回滾事務(wù)");
        }
 } catch (Exception e) {
  dataSourceTransactionManager.rollback(transactionStatus);// 回滾
  logger.error("readXlsCacheAsync---插入數(shù)據(jù)異常，回滾事務(wù)：", e);
    }
}

@Async("async-executor")//是否開(kāi)啟異步
@Override
public Integer readXlsCacheAsyncMybatis() {
    try {
     // 省略一些復(fù)雜操作...
    }catch (Exception e){
        throw new RuntimeException("插入數(shù)據(jù)庫(kù)異常", e);
    }
}

/**
 * 數(shù)據(jù)源事務(wù)管理器
 */
private DataSourceTransactionManager dataSourceTransactionManager;

@Autowired
public void setUserService(DataSourceTransactionManager dataSourceTransactionManager) {
 this.dataSourceTransactionManager = dataSourceTransactionManager;
}

@Override
public void readXls(String filePath, String filename) {

 List<TransactionStatus> transactionStatusList = Collections.synchronizedList(new ArrayList<>());
 List<TransactionResource> transactionResourceList = Collections.synchronizedList(new ArrayList<>());

 try {
  List<Future<Integer>> futureList = new ArrayList<>();
        for (int time = 0; time < times; time++) {
   Future<Integer> sumFuture = readAsyncFutureTransactionDBService.readXlsCacheAsyncMybatis(sheet, row, start, end, insertBuilder,transactionStatusList,transactionResourceList);
            futureList.add(sumFuture);
  }
  
  // 主線程獲取Future返回值
        boolean futureFlag = getFutureResult(futureList, excelRow);
  if (futureFlag) {
   for (int i = 0; i < transactionStatusList.size(); i++) {
    TransactionStatus transactionStatus = transactionStatusList.get(i);
    dataSourceTransactionManager.commit(transactionStatus); // 提交
   }

   logger.info("readXlsCacheAsync---插入數(shù)據(jù)成功，提交事務(wù)");
  } else {
   for (int i = 0; i < transactionStatusList.size(); i++) {
    TransactionStatus transactionStatus = transactionStatusList.get(i);
    dataSourceTransactionManager.rollback(transactionStatus);// 回滾
   }

   logger.info("readXlsCacheAsync---插入數(shù)據(jù)失敗，事務(wù)回滾");
   throw new RuntimeException("readXlsCacheAsync---插入數(shù)據(jù)異常，異常事務(wù)回滾");
  }
 } catch (Exception e) {
  logger.error("readXlsCacheAsync---插入數(shù)據(jù)異常，事務(wù)回滾：", e);

  for (int i = 0; i < transactionStatusList.size(); i++) {
   TransactionStatus transactionStatus = transactionStatusList.get(i);
   dataSourceTransactionManager.rollback(transactionStatus);// 回滾
  }
  //connection.rollback();
  throw new RuntimeException("readXlsCacheAsync---插入數(shù)據(jù)異常，異常事務(wù)回滾");
 }
}

@Async("async-executor")
@Override
public Future<Integer> readXlsCacheAsyncMybatis(XSSFSheet sheet, 
            XSSFRow row, 
            int start, 
            int end, 
            StringBuilder insertBuilder,
            List<TransactionStatus> transactionStatusList,
  List<ReadAsyncFutureTransactionServiceImpl.TransactionResource> transactionResourceList) throws Exception {
  
 DefaultTransactionDefinition defaultTransactionDefinition = new DefaultTransactionDefinition();
 TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(defaultTransactionDefinition);
 // 開(kāi)啟新事務(wù)
 transactionStatusList.add(transactionStatus);
 // copy事務(wù)資源
 transactionResourceList.add(ReadAsyncFutureTransactionServiceImpl.TransactionResource.copyTransactionResource());

 try {
  // 入庫(kù)操作
 }catch (Exception e){
  throw new RuntimeException("readXlsCacheAsyncMybatis分批異步讀取Excel，通過(guò)Mybatis插入數(shù)據(jù)庫(kù)異常");
 }
}

/**
 * 保存當(dāng)前事務(wù)資源,用于線程間的事務(wù)資源COPY操作
 * <p>
 * `@Builder`注解是Lombok庫(kù)提供的一個(gè)注解,它可以用于自動(dòng)生成Builder模式的代碼,使用@Builder注解可以簡(jiǎn)化創(chuàng)建對(duì)象實(shí)例的過(guò)程,并且可以使代碼更加清晰和易于維護(hù)
 */
static class TransactionResource {
    // TransactionSynchronizationManager類內(nèi)部默認(rèn)提供了下面六個(gè)ThreadLocal屬性,分別保存當(dāng)前線程對(duì)應(yīng)的不同事務(wù)資源
    // 保存當(dāng)前事務(wù)關(guān)聯(lián)的資源,默認(rèn)只會(huì)在新建事務(wù)的時(shí)候保存當(dāng)前獲取到的DataSource和當(dāng)前事務(wù)對(duì)應(yīng)Connection的映射關(guān)系
    // 當(dāng)然這里Connection被包裝為了ConnectionHolder
    // 事務(wù)結(jié)束后默認(rèn)會(huì)移除集合中的DataSource作為key關(guān)聯(lián)的資源記錄
    private Map<Object, Object> resources;
    //下面五個(gè)屬性會(huì)在事務(wù)結(jié)束后被自動(dòng)清理,無(wú)需我們手動(dòng)清理
    // 事務(wù)監(jiān)聽(tīng)者,在事務(wù)執(zhí)行到某個(gè)階段的過(guò)程中,會(huì)去回調(diào)監(jiān)聽(tīng)者對(duì)應(yīng)的回調(diào)接口(典型觀察者模式的應(yīng)用),默認(rèn)為空集合
    private Set<TransactionSynchronization> synchronizations;
    // 存放當(dāng)前事務(wù)名字
    private String currentTransactionName;
    // 存放當(dāng)前事務(wù)是否是只讀事務(wù)
    private Boolean currentTransactionReadOnly;
    // 存放當(dāng)前事務(wù)的隔離級(jí)別
    private Integer currentTransactionIsolationLevel;
    // 存放當(dāng)前事務(wù)是否處于激活狀態(tài)
    private Boolean actualTransactionActive;

    /**
     * 對(duì)事務(wù)資源進(jìn)行復(fù)制
     *
     * @return TransactionResource
     */
    public static TransactionResource copyTransactionResource() {
        return TransactionResource.builder()
                //返回的是不可變集合
                .resources(TransactionSynchronizationManager.getResourceMap())
                //如果需要注冊(cè)事務(wù)監(jiān)聽(tīng)者,這里記得修改,我們這里不需要,就采用默認(rèn)負(fù)責(zé),spring事務(wù)內(nèi)部默認(rèn)也是這個(gè)值
                .synchronizations(new LinkedHashSet<>()).currentTransactionName(TransactionSynchronizationManager.getCurrentTransactionName()).currentTransactionReadOnly(TransactionSynchronizationManager.isCurrentTransactionReadOnly()).currentTransactionIsolationLevel(TransactionSynchronizationManager.getCurrentTransactionIsolationLevel()).actualTransactionActive(TransactionSynchronizationManager.isActualTransactionActive()).build();
    }

    /**
     * 使用
     */
    public void autoWiredTransactionResource() {
        resources.forEach(TransactionSynchronizationManager::bindResource);
        //如果需要注冊(cè)事務(wù)監(jiān)聽(tīng)者,這里記得修改,我們這里不需要,就采用默認(rèn)負(fù)責(zé),spring事務(wù)內(nèi)部默認(rèn)也是這個(gè)值
        TransactionSynchronizationManager.initSynchronization();
        TransactionSynchronizationManager.setActualTransactionActive(actualTransactionActive);
        TransactionSynchronizationManager.setCurrentTransactionName(currentTransactionName);
        TransactionSynchronizationManager.setCurrentTransactionIsolationLevel(currentTransactionIsolationLevel);
        TransactionSynchronizationManager.setCurrentTransactionReadOnly(currentTransactionReadOnly);
    }

    /**
     * 移除
     */
    public void removeTransactionResource() {
        // 事務(wù)結(jié)束后默認(rèn)會(huì)移除集合中的DataSource作為key關(guān)聯(lián)的資源記錄
        // DataSource如果重復(fù)移除,unbindResource時(shí)會(huì)因?yàn)椴淮嬖诖薻ey關(guān)聯(lián)的事務(wù)資源而報(bào)錯(cuò)
        resources.keySet().forEach(key -> {
            if (!(key instanceof DataSource)) {
                TransactionSynchronizationManager.unbindResource(key);
            }
        });
    }
}