[[388035]]

 環境：springboot2.3.9.RELEASE + JPA + MySQL

一般我們在spring項目中都是在方法或者是類上添加事務支持，如下使用方式：

@Transactional 
public Account deduction(Long id, BigDecimal money) { 
        Optional<Account> op = accountDAO.findById(id); 
      if (!op.isPresent()) { 
          throw new RuntimeException("不存在"); 
      } 
      account.setMoney(account.getMoney().subtract(money)) ; 
          return accountDAO.saveAndFlush(account) ; 
} 

 以上應該是我們在項目中使用事務的姿勢了。這里是方法級別的事務，當方法執行的時候通過動態代理打開事務，執行代碼，提交事務/回滾事務，執行的邏輯大體如下：

transaction.begin(); 
method.invoke(xxxx); 
transaction.commit(); / transaction.rollback(); 

 在上面舉的示例比較簡單，整個操作就是計算扣減金額，然后更新數據。這個業務也就是在保存數據的時候需要使用到事務，其它的一些計算是不需要在一個事務中的。想象下如果我們這里保存操作之上的代碼，計算邏輯是個非常復雜的邏輯可能需要消耗好幾秒甚至是十幾秒而實際保存操作可能就幾毫秒就完成了。我們又知道這方法級的事務在執行的時候是要先獲取一個Connection對象(數據庫連接對象的)然后打開事務(設置自動提交為false，connection.setAutoCommit(false));說到這你應該能想到，從獲取一個Connection對象到釋放需要幾秒甚至是十幾秒的時間，而占用的這些時間中大部分的時間都是與事務無關的操作也就是說是不需要事務的，而我們的數據庫連接對象本身就是很寶貴及有限的，這就造成了我們系統的資源浪費，系統的吞吐量非常的低。接下來我們就來通過編程的方式控制事務提供系統的吞吐量。

模擬常規的事務，展現低吞吐量操作

數據庫連接配置：

spring: 
  datasource: 
    driverClassName: com.mysql.cj.jdbc.Driver 
    url: jdbc:mysql://localhost:3306/x?serverTimezone=GMT%2B8 
    username: root 
    password: xxxx 
    type: com.zaxxer.hikari.HikariDataSource 
    hikari: 
      minimumIdle: 1 
      maximumPoolSize: 1 
      autoCommit: true 
      idleTimeout: 30000 
      poolName: MasterDatabookHikariCP 
      maxLifetime: 1800000 
      connectionTimeout: 30000 
      connectionTestQuery: SELECT 1 

 這里把數據庫連接池配置為1個。

Service中模擬耗時的操作

@Transactional 
public Account deduction(Long id, BigDecimal money) { 
        System.out.println("Service 當前執行線程：" + Thread.currentThread().getName() + ", id = " + id + ", money = " + money) ; 
        Account account = accountDAO.findById(id).orElse(null) ; 
        if (account == null) { 
            return null ; 
        } 
        try { 
            TimeUnit.SECONDS.sleep(10) ; 
        } catch (InterruptedException e) { 
            e.printStackTrace(); 
        } 
        account.setMoney(account.getMoney().subtract(money)) ; 
        return accountDAO.saveAndFlush(account) ; 
} 

 Controller接口

@GetMapping("/deduction") 
    public Object deductionAction(Long id, BigDecimal money) { 
        System.out.println("Controller 當前線程：" + Thread.currentThread().getName()) ; 
        return accountService.deduction(id, money) ; 
    } 

 啟動兩個瀏覽器測試，觀察控制臺的輸出

兩個瀏覽器都還在轉圈，沒有響應。

 控制臺展示Controller方法都進入了，但是Service方法只進入了一個，因為我們的連接池只配置了一個，另外一個在等待可用的連接對象。而上面我也說了，其實Service中很長的一個計算耗時是不需要事務的，即便沒有連接對象可用，我們也應該讓這些不需要事務的操作也進行執行。接下來修改代碼。

編程事務，提高系統吞吐量

@Resource 
    private TransactionTemplate transactionTemplate ; 
     
    public Account deduction(Long id, BigDecimal money) { 
        System.out.println("Service 當前執行線程：" + Thread.currentThread().getName() + ", id = " + id + ", money = " + money) ; 
        Account account = accountDAO.findById(id).orElse(null) ; 
        if (account == null) { 
            return null ; 
        } 
        try { 
            TimeUnit.SECONDS.sleep(10) ; 
        } catch (InterruptedException e) { 
            e.printStackTrace(); 
        } 
        // 以上業務代碼執行可能是個很耗時的操作。 
        return transactionTemplate.execute(new TransactionCallback<Account>() { 
            @Override 
            public Account doInTransaction(TransactionStatus status) { 
                try { 
                    account.setMoney(account.getMoney().subtract(money)) ; 
                    return accountDAO.saveAndFlush(account) ; 
                } catch (Exception e) { 
                    logger.error("發生錯誤：{}", e) ; 
                    status.setRollbackOnly() ; 
                } 
                return null ; 
            } 
        }) ; 
    } 

 這里把方法上的事務注解刪了，把需要事務的操作通過編程的方式包裝，在Service中注入

TransactionTemplate對象，SpringBoot項目已經自動為我們配置好了，自動裝配類：

TransactionAutoConfiguration.java

測試：

瀏覽器都還在轉圈中，查看控制臺：

2個Service方法都進去了，基本連接池只有一個連接對象，但是也不妨礙我非事務的代碼執行，通過這樣的改造，我們的系統吞吐量是不是提升了N呢?