SpringBoot一個(gè)提升N倍性能的操作
環(huán)境：springboot2.3.9.RELEASE + JPA + MySQL
一般我們?cè)趕pring項(xiàng)目中都是在方法或者是類上添加事務(wù)支持，如下使用方式：
- @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) ;
- }
以上應(yīng)該是我們?cè)陧?xiàng)目中使用事務(wù)的姿勢(shì)了。這里是方法級(jí)別的事務(wù)，當(dāng)方法執(zhí)行的時(shí)候通過動(dòng)態(tài)代理打開事務(wù)，執(zhí)行代碼，提交事務(wù)/回滾事務(wù)，執(zhí)行的邏輯大體如下：
- transaction.begin();
- method.invoke(xxxx);
- transaction.commit(); / transaction.rollback();
在上面舉的示例比較簡(jiǎn)單，整個(gè)操作就是計(jì)算扣減金額，然后更新數(shù)據(jù)。這個(gè)業(yè)務(wù)也就是在保存數(shù)據(jù)的時(shí)候需要使用到事務(wù)，其它的一些計(jì)算是不需要在一個(gè)事務(wù)中的。想象下如果我們這里保存操作之上的代碼，計(jì)算邏輯是個(gè)非常復(fù)雜的邏輯可能需要消耗好幾秒甚至是十幾秒而實(shí)際保存操作可能就幾毫秒就完成了。我們又知道這方法級(jí)的事務(wù)在執(zhí)行的時(shí)候是要先獲取一個(gè)Connection對(duì)象(數(shù)據(jù)庫連接對(duì)象的)然后打開事務(wù)(設(shè)置自動(dòng)提交為false，connection.setAutoCommit(false));說到這你應(yīng)該能想到，從獲取一個(gè)Connection對(duì)象到釋放需要幾秒甚至是十幾秒的時(shí)間，而占用的這些時(shí)間中大部分的時(shí)間都是與事務(wù)無關(guān)的操作也就是說是不需要事務(wù)的，而我們的數(shù)據(jù)庫連接對(duì)象本身就是很寶貴及有限的，這就造成了我們系統(tǒng)的資源浪費(fèi)，系統(tǒng)的吞吐量非常的低。接下來我們就來通過編程的方式控制事務(wù)提供系統(tǒng)的吞吐量。
模擬常規(guī)的事務(wù)，展現(xiàn)低吞吐量操作
數(shù)據(jù)庫連接配置：
- 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
這里把數(shù)據(jù)庫連接池配置為1個(gè)。
Service中模擬耗時(shí)的操作
- @Transactional
- public Account deduction(Long id, BigDecimal money) {
- System.out.println("Service 當(dāng)前執(zhí)行線程：" + 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 當(dāng)前線程：" + Thread.currentThread().getName()) ;
- return accountService.deduction(id, money) ;
- }
啟動(dòng)兩個(gè)瀏覽器測(cè)試，觀察控制臺(tái)的輸出
兩個(gè)瀏覽器都還在轉(zhuǎn)圈，沒有響應(yīng)。
控制臺(tái)展示Controller方法都進(jìn)入了，但是Service方法只進(jìn)入了一個(gè)，因?yàn)槲覀兊倪B接池只配置了一個(gè)，另外一個(gè)在等待可用的連接對(duì)象。而上面我也說了，其實(shí)Service中很長(zhǎng)的一個(gè)計(jì)算耗時(shí)是不需要事務(wù)的，即便沒有連接對(duì)象可用，我們也應(yīng)該讓這些不需要事務(wù)的操作也進(jìn)行執(zhí)行。接下來修改代碼。
編程事務(wù)，提高系統(tǒng)吞吐量
- @Resource
- private TransactionTemplate transactionTemplate ;
- public Account deduction(Long id, BigDecimal money) {
- System.out.println("Service 當(dāng)前執(zhí)行線程：" + 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();
- }
- // 以上業(yè)務(wù)代碼執(zhí)行可能是個(gè)很耗時(shí)的操作。
- 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("發(fā)生錯(cuò)誤：{}", e) ;
- status.setRollbackOnly() ;
- }
- return null ;
- }
- }) ;
- }
這里把方法上的事務(wù)注解刪了，把需要事務(wù)的操作通過編程的方式包裝，在Service中注入
TransactionTemplate對(duì)象，SpringBoot項(xiàng)目已經(jīng)自動(dòng)為我們配置好了，自動(dòng)裝配類：
TransactionAutoConfiguration.java
測(cè)試：
瀏覽器都還在轉(zhuǎn)圈中，查看控制臺(tái)：
2個(gè)Service方法都進(jìn)去了，基本連接池只有一個(gè)連接對(duì)象，但是也不妨礙我非事務(wù)的代碼執(zhí)行，通過這樣的改造，我們的系統(tǒng)吞吐量是不是提升了N呢?
