使用@Transactional出現了長事務,導致生產事故
在Spring中進行事務管理非常簡單,只需要在方法上加上註解@Transactional
,Spring就可以自動幫我們進行事務的開啟、提交、回滾操作。甚至很多人心裡已經將Spring事務與@Transactional
劃上了等號,只要有資料庫相關操作就直接給方法加上@Transactional
註解。
不瞞你說,我之前也一直是這樣,直到使用@Transactional
導致了一次生產事故,而那次生產事故還導致我當月績效被打了D...
@Transactional
導致的生產事故
在公司做了一個內部報銷的專案,有這樣一個業務邏輯:
1、員工加班打車可以通過某出行軟體直接打車,第二天打車費用可以直接同步到我們的報銷平臺
2、員工可以在報銷平臺勾選自己打車費用並建立一張報銷單進行報銷,建立報銷單的同時會建立一條審批流(統一流程平臺)讓領導審批
當時建立報銷單的程式碼是這麼寫的:
/** * 儲存報銷單並建立工作流 */ @Transactional(rollbackFor = Exception.class) public void save(RequestBillDTO requestBillDTO){ //呼叫流程HTTP介面建立工作流 workflowUtil.createFlow("BILL",requestBillDTO); //轉換DTO物件 RequestBill requestBill = JkMappingUtils.convert(requestBillDTO, RequestBill.class); requestBillDao.save(requestBill); //儲存明細表 requestDetailDao.save(requestBill.getDetail()) }
程式碼非常簡單也很 “優雅 ”,先通過http介面呼叫工作流引擎建立審批流,然後儲存報銷單,而為了保證 操作的事務,在整個方法上加上了@Transactional
註解(仔細想想,這樣真的能保證事務嗎? )。
報銷專案屬於公司內部專案,本身是沒什麼高併發的,系統也一直穩定執行著。
在年末的一天下午(前幾天剛好下了大雪,打車的人特別多),公司發通知郵件說年度報銷視窗即將關閉,需要儘快將未報銷的費用報銷掉,而剛好那天工作流引擎在進行安全加固。
收到郵件後報銷的人開始逐漸增多,在接近下班的時候到達頂峰,此時報銷系統開始出現了故障:資料庫監控平臺一直收到告警簡訊,資料庫連線不足,出現大量死鎖;日誌顯示呼叫流程引擎接口出現大量超時;同時一直提示CannotGetJdbcConnectionException
,資料庫連線池連線佔滿。
在發生故障後,我們嘗試過殺掉死鎖程序,也進行過暴力重啟,只是不到10分鐘故障再次出現,收到大量電話投訴。最後沒辦法只能向全員傳送停機維護郵件併發送故障報告。
事故原因分析
通過對日誌的分析我們很容易就可以定位到故障原因就是儲存報銷單的save()方法,而罪魁禍首就是那個@Transactional
註解。
我們知道@Transactional
註解,是使用 AOP 實現的,本質就是在目標方法執行前後進行攔截。在目標方法執行前加入或建立一個事務,在執行方法執行後,根據實際情況選擇提交或是回滾事務。
當 Spring 遇到該註解時,會自動從資料庫連線池中獲取 connection,並開啟事務然後繫結到 ThreadLocal 上,對於@Transactional註解包裹的整個方法都是使用同一個connection連線 。如果我們出現了耗時的操作,比如第三方介面呼叫,業務邏輯複雜,大批量資料處理等就會導致我們我們佔用這個connection的時間會很長,資料庫連線一直被佔用不釋放。一旦類似操作過多,就會導致資料庫連線池耗盡。
在一個事務中執行RPC操作導致資料庫連線池撐爆屬於是典型的長事務問題 ,類似的操作還有在事務中進行大量資料查詢,業務規則處理等...
何為長事務?
顧名思義就是執行時間比較長,長時間未提交的事務,也可以稱之為大事務 。
長事務會引發哪些問題?
長事務引發的常見危害有:
- 資料庫連線池被佔滿,應用無法獲取連線資源;
- 容易引發資料庫死鎖;
- 資料庫回滾時間長;
- 在主從架構中會導致主從延時變大。
如何避免長事務?
既然知道了長事務的危害,那如何在開發中避免出現長事務問題呢?
很明顯,解決長事務的宗旨就是 對事務方法進行拆分,儘量讓事務變小,變快,減小事務的顆粒度。
既然提到了事務的顆粒度,我們就先回顧一下Spring進行事務管理的方式。
宣告式事務
首先我們要知道,通過在方法上使用@Transactional
註解進行事務管理的操作叫宣告式事務 。
使用宣告式事務的優點 很明顯,就是使用很簡單,可以自動幫我們進行事務的開啟、提交以及回滾等操作。使用這種方式,程式設計師只需要關注業務邏輯就可以了。
宣告式事務有一個最大的缺點 ,就是事務的顆粒度是整個方法,無法進行精細化控制。
與宣告式事務對應的就是程式設計式事務 。
基於底層的API,開發者在程式碼中手動的管理事務的開啟、提交、回滾等操作。在spring專案中可以使用TransactionTemplate
類的物件,手動控制事務。
@Autowired private TransactionTemplate transactionTemplate; ... public void save(RequestBill requestBill) { transactionTemplate.execute(transactionStatus -> { requestBillDao.save(requestBill); //儲存明細表 requestDetailDao.save(requestBill.getDetail()); return Boolean.TRUE; }); }
使用程式設計式事務最大的好處就是可以精細化控制事務範圍。
所以避免長事務最簡單的方法就是不要使用宣告式事務@Transactional
,而是使用程式設計式事務手動控制事務範圍。
有的同學會說,@Transactional
使用這麼簡單,有沒有辦法既可以使用@Transactional
,又能避免產生長事務?
那就需要對方法進行拆分,將不需要事務管理的邏輯與事務操作分開:
@Service public class OrderService{ public void createOrder(OrderCreateDTO createDTO){ query(); validate(); saveData(createDTO); } //事務操作 @Transactional(rollbackFor = Throwable.class) public void saveData(OrderCreateDTO createDTO){ orderDao.insert(createDTO); } }
query()
與validate()
不需要事務,我們將其與事務方法saveData()
拆開。
當然,這種拆分會命中使用@Transactional
註解時事務不生效的經典場景,很多新手非常容易犯這個錯誤。@Transactional
註解的宣告式事務是通過spring aop起作用的,而spring aop需要生成代理物件,直接在同一個類中方法呼叫使用的還是原始物件,事務不生效。其他幾個常見的事務不生效的場景為:
“
- @Transactional 應用在非 public 修飾的方法上
- @Transactional 註解屬性 propagation 設定錯誤
- @Transactional 註解屬性 rollbackFor 設定錯誤
- 同一個類中方法呼叫,導致@Transactional失效
- 異常被catch捕獲導致@Transactional失效
”
正確的拆分方法應該使用下面兩種:
- 可以將方法放入另一個類,如新增
manager層
,通過spring注入,這樣符合了在物件之間呼叫的條件。
@Service public class OrderService{ @Autowired private OrderManager orderManager; public void createOrder(OrderCreateDTO createDTO){ query(); validate(); orderManager.saveData(createDTO); } } @Service public class OrderManager{ @Autowired private OrderDao orderDao; @Transactional(rollbackFor = Throwable.class) public void saveData(OrderCreateDTO createDTO){ orderDao.saveData(createDTO); } }
- 啟動類新增
@EnableAspectJAutoProxy(exposeProxy = true)
,方法內使用AopContext.currentProxy()
獲得代理類,使用事務。
SpringBootApplication.java @EnableAspectJAutoProxy(exposeProxy = true) @SpringBootApplication public class SpringBootApplication {} OrderService.java public void createOrder(OrderCreateDTO createDTO){ OrderService orderService = (OrderService)AopContext.currentProxy(); orderService.saveData(createDTO); }
小結
使用@Transactional
註解在開發時確實很方便,但是稍微不注意就可能出現長事務問題。所以對於複雜業務邏輯,我這裡更建議你使用程式設計式事務來管理事務,當然,如果你非要使用@Transactional
,可以根據上文提到的兩種方案進行方法拆分。