群里說過幾百遍的長事務死鎖問題還是被人遇到了~別再這樣做了！

作者：飄渺Jam 2024-12-17 10:07:13

近期測試中，發現幾年前開發的業務流程申請模塊在頻繁操作時會出現異常提示，導致審批流程失敗。最初以為是代碼邏輯不周或異常處理不足等常見錯誤，但通過日志排查后發現，問題源自數據庫的死鎖。

問題背景

近期測試中，發現幾年前開發的業務流程申請模塊在頻繁操作時會出現異常提示，導致審批流程失敗。最初以為是代碼邏輯不周或異常處理不足等常見錯誤，但通過日志排查后發現，問題源自數據庫的死鎖。以下是日志信息：

SQL: UPDATE record_process_audit_apply_main_data  SET update_account=?, update_name=?, update_time=?,  task_node=?,apply_time=?      WHERE (task_id = ?)
### Cause: com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Deadlock found when trying to get lock; try restarting transaction
; Deadlock found when trying to get lock; try restarting transaction; nested exception is com.mysql.cj.jdbc.exceptions.MySQLTransactionRollbackException: Deadlock found when trying to get lock; try restarting transaction
 at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:271)
 at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:70)
 at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:91)
 at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:441)
 at com.sun.proxy.$Proxy174.update(Unknown Source)
 at org.mybatis.spring.SqlSessionTemplate.update(SqlSessionTemplate.java:288)
 at com.baomidou.mybatisplus.core.override.MybatisMapperMethod.execute(MybatisMapperMethod.java:64)
 at com.baomidou.mybatisplus.core.override.MybatisMapperProxy$PlainMethodInvoker.invoke(MybatisMapperProxy.java:148)
 at com.baomidou.mybatisplus.core.override.MybatisMapperProxy.invoke(MybatisMapperProxy.java:89)
 at com.sun.proxy.$Proxy603.update(Unknown Source)
 at sun.reflect.GeneratedMethodAccessor723.invoke(Unknown Source)
 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
 at java.lang.reflect.Method.invoke(Method.java:498)
 at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:344)
 at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:198)
 at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
 at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:137)
 at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
 at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:215)
 at com.sun.proxy.$Proxy604.update(Unknown Source)
 at com.ifly.pdm.impl.recordaudittask.RecordProcessAuditTaskServiceImpl.handleCreateAuditTableData(RecordProcessAuditTaskServiceImpl.java:186)

根據日志可以清晰的看到一個事務在獲取鎖時發生了死鎖。

分析 MySQL 錯誤日志

進一步分析 MySQL 錯誤日志，發現以下死鎖情況：

圖片

事務一：

事務 ID: 6536211
狀態: 活躍 10 秒，正在獲取行鎖
操作: 更新 record_process_audit_apply_main_data 表
等待的鎖: 等待主鍵索引上的記錄鎖
sql: UPDATE record_process_audit_apply_main_data SET update_account='dxwang', update_name='汪冬雪', update_time='2024-11-15 15:17:34.216', task_node='16' WHERE (task_id = '1857321847525548034')

事務二：

事務 ID: 6536206
狀態: 活躍 5 秒，正在開始索引讀取
持有的鎖: 表 pdm.record_process_audit_apply_main_data 的主鍵索引上的記錄鎖。
等待的鎖: 正在等待在表 pdm.record_process_audit_apply_main_data 的主鍵索引上的記錄鎖
sql: UPDATE record_process_audit_apply_main_data SET update_account='dywang3', update_name='王冬艷', update_time='2024-11-15 15:17:38.009', task_node='15', apply_time='2024-11-15 15:17:33.085' WHERE (task_id = '1857322026072875010')

MySQL 最終決定回滾事務 2（事務 ID: 6536206）以解決死鎖問題。

死鎖原因

死鎖發生的原因在于：

事務 1 和事務 2 都在嘗試更新 record_process_audit_apply_main_data 表中的記錄。
事務 1 正在等待事務 2 持有的鎖，事務 2 也在等待事務 1 持有的鎖，導致了死鎖。

定位代碼

通過進一步分析代碼，發現以下關鍵方法：submitApplication。該方法及其調用的其他方法都在同一個事務中執行，可能導致事務時間過長，增加了鎖競爭和死鎖的風險。核心代碼如下所示：

圖片

優化思路：

拆分事務：將大事務拆分成多個小事務，每個事務只處理一部分邏輯。確保每個事務盡可能短，減少鎖持有時間。
異步處理：使用異步任務處理耗時操作，如調用第三方接口。使用消息隊列將部分操作異步化。
優化數據庫操作：確保所有涉及的表都有適當的索引，減少查詢和更新的時間。使用批量操作，減少與數據庫的交互次數。
事務隔離級別：根據業務需求選擇合適的事務隔離級別，減少鎖的競爭。
日志記錄：記錄事務的開始和結束時間，以及關鍵操作的執行情況，便于問題排查。

優化后的偽代碼：

@Transactional
public void submitApplication(Application application) {
    // 拆分事務，確保每個事務盡量短
    try {
        processApplicationDetails(application); // 處理申請細節
        updateTaskStatus(application); // 更新任務狀態
        notifyUser(application); // 通知用戶
    } catch (Exception e) {
        log.error("Error in submitApplication", e);
        throw new RuntimeException("Application submission failed");
    }
}

// 異步處理耗時任務
@Async
public void notifyUser(Application application) {
    // 異步通知用戶
    notificationService.sendNotification(application.getUserId(), "Your application is processed.");
}

責任編輯：武曉燕來源： JAVA日知錄

死鎖數據庫日志