如何使用Spring boot的@Transactional進行事務管理
更新時間：2025年02月11日 15:25:52 作者：TracyCoder123
這篇文章介紹了SpringBoot中使用@Transactional注解進行聲明式事務管理的詳細信息,包括基本用法、核心配置參數、關鍵注意事項、調試技巧、最佳實踐以及完整示例,感興趣的朋友一起看看吧
在 Spring Boot 中，@Transactional 是用于聲明式事務管理的關鍵注解。它基于 Spring 的 AOP（面向切面編程）實現，可以簡化數據庫事務的管理。
一、前置條件
- 依賴引入：確保項目中包含
spring-boot-starter-data-jpa或spring-boot-starter-jdbc - 啟用事務管理：Spring Boot 默認自動配置事務管理器（如
DataSourceTransactionManager），無需手動啟用。
二、基本用法
1. 在方法上添加注解
@Service
public class UserService {
@Autowired
private UserRepository userRepository;
@Transactional
public void createUser(User user) {
userRepository.save(user);
// 其他數據庫操作
}
}2. 在類上添加注解
@Service
@Transactional
public class UserService {
// 類中所有 public 方法都會應用事務
}三、核心配置參數
1. 傳播行為（Propagation）
控制事務的邊界，默認為 Propagation.REQUIRED。
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void updateUser(User user) {
// 始終開啟新事務
}常見選項：
REQUIRED（默認）：如果當前存在事務，則加入；否則新建REQUIRES_NEW：始終新建事務，掛起當前事務（如有）SUPPORTS：如果當前存在事務，則加入；否則非事務運行NOT_SUPPORTED：非事務運行，掛起當前事務（如有）MANDATORY：必須在事務中調用，否則拋出異常NEVER：必須在非事務中調用，否則拋出異常
2. 隔離級別（Isolation）
控制事務的隔離性，默認為 Isolation.DEFAULT（使用數據庫默認）。
@Transactional(isolation = Isolation.SERIALIZABLE)
public void sensitiveOperation() {
// 最高隔離級別
}3. 超時時間（Timeout）
事務超時時間（秒），默認-1（使用數據庫默認）。
@Transactional(timeout = 30)
public void longRunningProcess() {
// 超過30秒將回滾
}4. 只讀模式（readOnly）
優(yōu)化只讀操作，默認為 false。
@Transactional(readOnly = true)
public List<User> findAllUsers() {
return userRepository.findAll();
}5. 回滾規(guī)則（rollbackFor/noRollbackFor）
指定觸發(fā)回滾的異常類型：
@Transactional(rollbackFor = CustomException.class)
public void process() throws CustomException {
// 拋出 CustomException 時回滾
}四、關鍵注意事項
1. 方法可見性
必須為 public：由于 Spring AOP 的實現機制，非 public 方法上的 @Transactional 無效
2. 自調用問題
同類中的方法互相調用時，事務不會生效（繞過代理對象）
// 錯誤示例
public void methodA() {
methodB(); // 事務不生效
}
@Transactional
public void methodB() { ... }3. 異常處理
- 默認回滾條件：拋出
RuntimeException或Error - 檢查型異常（Checked Exception）默認不會觸發(fā)回滾
// 處理檢查型異常
@Transactional(rollbackFor = IOException.class)
public void fileOperation() throws IOException {
// ...
}4. 多數據源事務
需配置多個事務管理器，并通過 @Transactional(value = "specificTransactionManager") 指定
五、調試技巧
啟用調試日志：
logging.level.org.springframework.transaction.interceptor=TRACE logging.level.org.springframework.jdbc.datasource.DataSourceTransactionManager=DEBUG
檢查代理對象：
System.out.println(userService.getClass().getName()); // 輸出應為代理類：com.sun.proxy.$ProxyXX 或 ...$$EnhancerBySpringCGLIB$$...
六、最佳實踐
- 服務層使用：在 Service 層而非 Controller 層使用事務
- 保持短事務：避免在事務中包含遠程調用、文件IO等耗時操作
- 精確回滾規(guī)則：明確指定
rollbackFor而非依賴默認行為 - 結合 JPA 使用：
@Transactional
public void updateUserEmail(Long userId, String email) {
User user = userRepository.findById(userId).orElseThrow();
user.setEmail(email); // 自動臟檢查，事務提交時更新
}七、完整示例
@Service
public class OrderService {
@Autowired
private OrderRepository orderRepository;
@Autowired
private InventoryService inventoryService;
@Transactional(
propagation = Propagation.REQUIRED,
isolation = Isolation.READ_COMMITTED,
timeout = 30,
rollbackFor = {InsufficientStockException.class, PaymentFailedException.class}
)
public void placeOrder(Order order) {
inventoryService.reduceStock(order.getItems()); // 可能拋出 InsufficientStockException
orderRepository.save(order);
processPayment(order); // 可能拋出 PaymentFailedException
}
private void processPayment(Order order) {
// 支付邏輯
}
}八、適用于關系型數據庫
@Transactional 的使用與數據庫層有直接關系，但它的事務管理機制是基于數據庫事務的。如果 Service 層方法使用了 Elasticsearch 客戶端讀寫 Elasticsearch，那么 @Transactional 的行為會受到影響。
1.@Transactional 的適用范圍
@Transactional是 Spring 提供的事務管理機制，主要用于管理數據庫事務。- 它依賴于底層的事務管理器（如
DataSourceTransactionManager），而這些事務管理器通常是與關系型數據庫（如 MySQL、PostgreSQL）交互的。
數據庫事務：@Transactional 可以確保數據庫操作的原子性、一致性、隔離性和持久性（ACID）。非數據庫操作：對于非數據庫操作（如 Elasticsearch、Redis、文件系統等），@Transactional 無法直接管理其事務。
2.Elasticsearch 與 @Transactional 的關系
Elasticsearch 是一個分布式搜索引擎，它本身不支持傳統意義上的事務（ACID）。因此，@Transactional 對 Elasticsearch 的操作沒有直接的事務管理能力。
（1）場景分析
假設我們的 Service 方法同時操作了數據庫和 Elasticsearch：
@Service
public class UserService {
@Autowired
private UserRepository userRepository; // 數據庫操作
@Autowired
private ElasticsearchClient elasticsearchClient; // Elasticsearch 操作
@Transactional
public void createUser(User user) {
// 操作數據庫
userRepository.save(user);
// 操作 Elasticsearch
IndexRequest request = new IndexRequest("users")
.id(user.getId().toString())
.source("name", user.getName(), "email", user.getEmail());
elasticsearchClient.index(request, RequestOptions.DEFAULT);
}
}（2）可能出現的問題
- 數據庫事務回滾，Elasticsearch 操作不回滾：
- 如果 userRepository.save(user) 成功，但后續(xù) Elasticsearch 操作失敗，數據庫事務會回滾（因為 @Transactional 生效），但 Elasticsearch 的數據已經寫入，無法回滾。
- 數據庫事務提交，Elasticsearch 操作失?。?/li>
- 如果數據庫操作成功，但 Elasticsearch 操作失敗，數據庫事務已經提交，而 Elasticsearch 數據未更新，導致數據不一致。
3.如何解決 Elasticsearch 與數據庫的事務一致性問題
由于 Elasticsearch 不支持事務，因此需要采用其他機制來保證數據一致性。
（1）手動補償機制 在 Elasticsearch 操作失敗時，手動回滾數據庫操作。
示例：
@Transactional
public void createUser(User user) {
try {
userRepository.save(user); // 數據庫操作
IndexRequest request = new IndexRequest("users")
.id(user.getId().toString())
.source("name", user.getName(), "email", user.getEmail());
elasticsearchClient.index(request, RequestOptions.DEFAULT); // Elasticsearch 操作
} catch (Exception e) {
// Elasticsearch 操作失敗，手動回滾數據庫
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
throw e;
}
}（2）消息隊列（最終一致性）
- 將 Elasticsearch 操作異步化，通過消息隊列（如 Kafka、RabbitMQ）實現最終一致性。
- 示例：
數據庫操作完成后，發(fā)送消息到隊列。
消費者從隊列中讀取消息并更新 Elasticsearch。
（3）兩階段提交（2PC）
- 使用分布式事務管理器（如 Seata）實現數據庫和 Elasticsearch 的分布式事務。
- 這種方法復雜度較高，通常不推薦用于 Elasticsearch。
（4）本地消息表
- 在數據庫中創(chuàng)建一張消息表，記錄需要同步到 Elasticsearch 的數據。
- 通過定時任務或事件監(jiān)聽器將數據同步到 Elasticsearch。
總結
@Transactional只對數據庫事務有效：它無法管理 Elasticsearch 等非關系型數據存儲的事務。- Elasticsearch 操作與數據庫事務的一致性：需要通過補償機制、消息隊列等方式實現。
- 設計建議： 盡量避免在同一個事務中混合數據庫和 Elasticsearch 操作。
- 采用異步化或最終一致性方案來保證數據一致性。
如果你有更多具體的業(yè)務場景，可以進一步討論如何設計解決方案！
到此這篇關于使用Spring boot的@Transactional進行事務管理的文章就介紹到這了,更多相關Spring boot @Transactional事務管理內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要介紹spring如何解決循環(huán)依賴，文中有相關的代碼示例給大家參考，對我們的學習或工作有一定的幫助，感興趣的同學可以借鑒閱讀2023-05-05
這篇文章主要介紹了JAVA面向對象 封裝原理及實例解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-02-02
下面小編就為大家?guī)硪黄猨ava判斷今天,昨天,前天,不能用秒間隔的簡單實例。小編覺得挺不錯的，現在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-03-03
這篇文章主要介紹了Spring Boot如何使用AOP實例解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-04-04
相信響應式編程經常會在各種地方被提到。本篇就為大家從函數式編程一直到Spring?WeFlux做一次簡單的講解，并給出一些示例，希望大家可以更好的理解響應式編程2022-07-07
這篇文章主要介紹了Java如何通過遞歸計算出階乘，文中介紹了遞歸的使用方法和基本特點，以及相關示例代碼，對大家的學習有一定的幫助,需要的朋友可以參考下2023-05-05
在本篇內容里小編給各位分享了一篇關于java迭代器中刪除元素的實例操作詳解內容，有興趣的朋友們可以學習下。2021-01-01
這篇文章主要介紹了MyBatis使用注解開發(fā)實現步驟解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-08-08
這篇文章主要介紹了java讀寫oracle的blob字段示例,需要的朋友可以參考下2014-02-02
java JSON解析庫Alibaba Fastjson用法詳解
這篇文章主要介紹了java JSON解析庫Alibaba Fastjson用法,結合實例形式詳細分析了java JSON解析庫Alibaba Fastjson的基本功能、原理、用法及操作注意事項,需要的朋友可以參考下2020-04-04