Spring Boot 事務同步機制：從原理到實戰
作者：一安
在分布式系統和復雜業務場景中，我們經常需要在事務完成后執行一些額外操作，比如發送消息通知、更新緩存、記錄審計日志等。
前言
在分布式系統和復雜業務場景中，我們經常需要在事務完成后執行一些額外操作，比如發送消息通知、更新緩存、記錄審計日志等。
事務同步機制概述
事務同步機制是Spring事務管理的重要擴展點，允許我們在事務的不同階段（如提交前、提交后、回滾后等）執行自定義邏輯。這種機制的核心價值在于：
- 保證操作的原子性：確保后續操作僅在事務成功提交后執行
- 維護數據一致性：避免事務未完成時外部系統感知到中間狀態
- 簡化業務代碼：將事務相關的輔助操作與核心業務邏輯解耦
Spring通過TransactionSynchronization接口定義了事務同步的標準，而TransactionSynchronizationAdapter作為其適配器實現，提供了默認空實現，讓開發者只需重寫需要的方法，簡化了使用成本。
核心方法解析
TransactionSynchronizationAdapter實現了TransactionSynchronization接口，核心方法對應事務生命周期的關鍵節點：
方法名 | 執行時機 | 典型用途 |
beforeCommit(boolean readOnly) | 事務提交前 | 最后一次數據校驗、設置提交標記 |
afterCommit() | 事務成功提交后 | 發送消息、更新緩存、調用外部系統 |
afterCompletion(int status) | 事務完成后（無論成功失敗） | 資源清理、記錄最終狀態 |
beforeCompletion() | 事務完成前（提交 / 回滾前） | 預清理資源、狀態記錄 |
afterRollback() | 事務回滾后 | 回滾補償操作、通知失敗 |
代碼實現
Repository 接口
@Repository
public interface UserRepository extends JpaRepository<User, Long> {
}消息服務（模擬外部系統調用）
@Service
public class MessageService {
/**
* 模擬發送歡迎消息
*/
public void sendWelcomeMessage(String email, String username) {
System.out.printf("【消息服務】向 %s(%s) 發送歡迎消息：歡迎注冊我們的平臺！%n", username, email);
}
/**
* 模擬發送注冊失敗通知
*/
public void sendRegistrationFailedMessage(String email) {
System.out.printf("【消息服務】向 %s 發送注冊失敗通知：很抱歉，注冊過程出現異常%n", email);
}
}業務邏輯
@Service
public class UserService {
@Autowired
private UserRepository userRepository;
@Autowired
private MessageService messageService;
/**
* 用戶注冊（帶事務同步操作）
*/
@Transactional
public User register(User user) {
// 1. 保存用戶（核心業務）
User savedUser = userRepository.save(user);
System.out.println("【用戶服務】用戶注冊成功，ID：" + savedUser.getId());
// 2. 注冊事務同步器
registerTransactionSynchronization(savedUser);
// 模擬業務異常（可注釋/打開測試事務回滾場景）
// if ("test@rollback.com".equals(user.getEmail())) {
// throw new RuntimeException("模擬注冊異常，觸發事務回滾");
// }
return savedUser;
}
/**
* 注冊事務同步器，定義事務不同階段的操作
*/
private void registerTransactionSynchronization(User user) {
// 檢查當前是否存在事務上下文
if (TransactionSynchronizationManager.isSynchronizationActive()) {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
// 事務提交后執行：發送歡迎消息
@Override
public void afterCommit() {
messageService.sendWelcomeMessage(user.getEmail(), user.getUsername());
}
// 事務回滾后執行：發送失敗通知
@Override
public void afterRollback() {
messageService.sendRegistrationFailedMessage(user.getEmail());
}
// 事務完成后（無論成敗）執行：記錄最終狀態
@Override
public void afterCompletion(int status) {
String statusDesc = switch (status) {
case STATUS_COMMITTED -> "已提交";
case STATUS_ROLLED_BACK -> "已回滾";
case STATUS_UNKNOWN -> "未知狀態";
default -> "異常狀態";
};
System.out.printf("【事務同步】用戶 %s 的注冊事務最終狀態：%s%n", user.getUsername(), statusDesc);
}
});
} else {
throw new RuntimeException("當前無活躍事務，無法注冊同步器");
}
}
}注意事項
- 事務上下文依賴：必須在活躍的事務上下文中注冊同步器（即@Transactional方法內部），否則TransactionSynchronizationManager.isSynchronizationActive()會返回false，導致注冊失敗。
- 執行順序：若注冊多個同步器，默認按注冊順序執行。可通過setOrder(int)方法指定執行優先級（值越小越先執行）。
- Spring4.2+提供的@TransactionalEventListener是更簡潔的替代方案，基于事件機制實現，但TransactionSynchronizationAdapter更靈活，支持更細粒度的事務階段控制。
@Autowired
private ApplicationEventPublisher publisher;
@Transactional(rollbackFor = Exception.class)
public void add(SomeEntity entity) {
// 業務操作
publisher.publishEvent(entity);
}
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void handleAfterCommit(SomeEntity entity) {
// 事務提交后執行的邏輯
}責任編輯：武曉燕
來源：
一安未來
