日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
Spring合理使用編程事務(wù)提升N倍性能的操作

環(huán)境:springboot2.3.9.RELEASE + JPA + MySQL

創(chuàng)新互聯(lián)是一家成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè),提供網(wǎng)頁設(shè)計(jì),網(wǎng)站設(shè)計(jì),網(wǎng)站制作,建網(wǎng)站,按需搭建網(wǎng)站,網(wǎng)站開發(fā)公司,2013年開創(chuàng)至今是互聯(lián)行業(yè)建設(shè)者,服務(wù)者。以提升客戶品牌價(jià)值為核心業(yè)務(wù),全程參與項(xiàng)目的網(wǎng)站策劃設(shè)計(jì)制作,前端開發(fā),后臺(tái)程序制作以及后期項(xiàng)目運(yùn)營并提出專業(yè)建議和思路。

一般我們在spring項(xiàng)目中都是在方法或者是類上添加事務(wù)支持,如下使用方式:

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

以上應(yīng)該是我們在項(xiàng)目中使用事務(wù)的姿勢了。這里是方法級(jí)別的事務(wù),當(dāng)方法執(zhí)行的時(shí)候通過動(dòng)態(tài)代理打開事務(wù),執(zhí)行代碼,提交事務(wù)/回滾事務(wù),執(zhí)行的邏輯大體如下:

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

在上面舉的示例比較簡單,整個(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è)瀏覽器測試,觀察控制臺(tái)的輸出

圖片

兩個(gè)瀏覽器都還在轉(zhuǎn)圈,沒有響應(yīng)。

圖片

控制臺(tái)展示Controller方法都進(jìn)入了,但是Service方法只進(jìn)入了一個(gè),因?yàn)槲覀兊倪B接池只配置了一個(gè),另外一個(gè)在等待可用的連接對(duì)象。而上面我也說了,其實(shí)Service中很長的一個(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() {
    @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

測試:

圖片

瀏覽器都還在轉(zhuǎn)圈中,查看控制臺(tái):

圖片

2個(gè)Service方法都進(jìn)去了,基本連接池只有一個(gè)連接對(duì)象,但是也不妨礙我非事務(wù)的代碼執(zhí)行,通過這樣的改造,我們的系統(tǒng)吞吐量是不是提升了N呢?


文章名稱:Spring合理使用編程事務(wù)提升N倍性能的操作
轉(zhuǎn)載源于:http://www.dlmjj.cn/article/djjshoe.html