建站
咨詢
售后
建站咨詢
新聞中心
環(huán)境：springboot2.3.9.RELEASE + JPA + MySQL
創(chuàng)新互聯(lián)是一家成都網(wǎng)站設(shè)計、成都網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)，提供網(wǎng)頁設(shè)計，網(wǎng)站設(shè)計，網(wǎng)站制作，建網(wǎng)站，按需搭建網(wǎng)站，網(wǎng)站開發(fā)公司，2013年開創(chuàng)至今是互聯(lián)行業(yè)建設(shè)者，服務(wù)者。以提升客戶品牌價值為核心業(yè)務(wù)，全程參與項(xiàng)目的網(wǎng)站策劃設(shè)計制作，前端開發(fā)，后臺程序制作以及后期項(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ù)的姿勢了。這里是方法級別的事務(wù)，當(dāng)方法執(zhí)行的時候通過動態(tài)代理打開事務(wù)，執(zhí)行代碼，提交事務(wù)/回滾事務(wù)，執(zhí)行的邏輯大體如下：
transaction.begin();
method.invoke(xxxx);
transaction.commit(); / transaction.rollback();在上面舉的示例比較簡單，整個操作就是計算扣減金額，然后更新數(shù)據(jù)。這個業(yè)務(wù)也就是在保存數(shù)據(jù)的時候需要使用到事務(wù)，其它的一些計算是不需要在一個事務(wù)中的。想象下如果我們這里保存操作之上的代碼，計算邏輯是個非常復(fù)雜的邏輯可能需要消耗好幾秒甚至是十幾秒而實(shí)際保存操作可能就幾毫秒就完成了。我們又知道這方法級的事務(wù)在執(zhí)行的時候是要先獲取一個Connection對象（數(shù)據(jù)庫連接對象的）然后打開事務(wù)（設(shè)置自動提交為false，connection.setAutoCommit(false)）；說到這你應(yīng)該能想到，從獲取一個Connection對象到釋放需要幾秒甚至是十幾秒的時間，而占用的這些時間中大部分的時間都是與事務(wù)無關(guān)的操作也就是說是不需要事務(wù)的，而我們的數(shù)據(jù)庫連接對象本身就是很寶貴及有限的，這就造成了我們系統(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個。
Service中模擬耗時的操作
@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) ;
}啟動兩個瀏覽器測試，觀察控制臺的輸出
圖片
兩個瀏覽器都還在轉(zhuǎn)圈，沒有響應(yīng)。
圖片
控制臺展示Controller方法都進(jìn)入了，但是Service方法只進(jìn)入了一個，因?yàn)槲覀兊倪B接池只配置了一個，另外一個在等待可用的連接對象。而上面我也說了，其實(shí)Service中很長的一個計算耗時是不需要事務(wù)的，即便沒有連接對象可用，我們也應(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í)行可能是個很耗時的操作。
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ā)生錯誤：{}", e) ;
status.setRollbackOnly() ;
}
return null ;
}
}) ;
} 這里把方法上的事務(wù)注解刪了，把需要事務(wù)的操作通過編程的方式包裝，在Service中注入
TransactionTemplate對象，SpringBoot項(xiàng)目已經(jīng)自動為我們配置好了，自動裝配類：
TransactionAutoConfiguration.java
測試：
圖片
瀏覽器都還在轉(zhuǎn)圈中，查看控制臺：
圖片
2個Service方法都進(jìn)去了，基本連接池只有一個連接對象，但是也不妨礙我非事務(wù)的代碼執(zhí)行，通過這樣的改造，我們的系統(tǒng)吞吐量是不是提升了N呢？
當(dāng)前名稱：Spring合理使用編程事務(wù)提升N倍性能的操作
瀏覽地址：http://m.5511xx.com/article/djjshoe.html
