對于從事java開發(fā)工作的同學來說，spring的事務肯定再熟悉不過了。在某些業(yè)務場景下，如果同時有多張表的寫入操作，為了保證操作的原子性（要么同時成功，要么同時失敗）避免數(shù)據(jù)不一致的情況，我們一般都會使用spring事務。

沒錯，spring事務大多數(shù)情況下，可以滿足我們的業(yè)務需求。但是今天我要告訴大家的是，它有很多坑，稍不注意事務就會失效。

不信，我們一起看看。

1.錯誤的訪問權限

@Service
publicclassUserService{

@Autowired
privateUserMapper userMapper;

@Transactional
privatevoidadd(UserModel userModel){
userMapper.insertUser(userModel);
}
}

我們可以看到add方法的訪問權限被定義成了private，這樣會導致事務失效，spring要求被代理方法必須是public的。

AbstractFallbackTransactionAttributeSource類的computeTransactionAttribute方法中有個判斷，如果目標方法不是public，則TransactionAttribute返回null，即不支持事務。

protectedTransactionAttribute computeTransactionAttribute(Method method, @NullableClasstargetClass){
// Don't allow no-public methods as required.
if(allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
returnnull;
}

// The method may be on an interface, but we need attributes from the target class.
// If the target class is null, the method will be unchanged.
Method specificMethod = AopUtils.getMostSpecificMethod(method, targetClass);

// First try is the method in the target class.
TransactionAttribute txAttr = findTransactionAttribute(specificMethod);
if(txAttr !=null) {
returntxAttr;
}

// Second try is the transaction attribute on the target class.
txAttr = findTransactionAttribute(specificMethod.getDeclaringClass());
if(txAttr !=null&& ClassUtils.isUserLevelMethod(method)) {
returntxAttr;
}

if(specificMethod != method) {
// Fallback is to look at the original method.
txAttr = findTransactionAttribute(method);
if(txAttr !=null) {
returntxAttr;
}
// Last fallback is the class of the original method.
txAttr = findTransactionAttribute(method.getDeclaringClass());
if(txAttr !=null&& ClassUtils.isUserLevelMethod(method)) {
returntxAttr;
}
}

returnnull;
}

2.方法被定義成final的

@Service
publicclassUserService{

@Autowired
privateUserMapper userMapper;

@Transactional
publicfinalvoidadd(UserModel userModel){
userMapper.insertUser(userModel);
}
}

我們可以看到add方法被定義成了final的，這樣會導致spring aop生成的代理對象不能復寫該方法，而讓事務失效。

3.方法內(nèi)部調(diào)用

@Service
publicclassUserService{

@Autowired
privateUserMapper userMapper;

@Transactional
publicvoidadd(UserModel userModel){
userMapper.insertUser(userModel);
updateStatus(userModel);
}

@Transactional
publicvoidupdateStatus(UserModel userModel){
// doSameThing();
}
}

我們看到在事務方法add中，直接調(diào)用事務方法updateStatus。從前面介紹的內(nèi)容可以知道，updateStatus方法擁有事務的能力是因為spring aop生成代理了對象，但是這種方法直接調(diào)用了this對象的方法，所以updateStatus方法不會生成事務。

4.當前實體沒有被spring管理

//@Service
publicclassUserService{

@Autowired
privateUserMapper userMapper;

@Transactional
publicvoidadd(UserModel userModel){
userMapper.insertUser(userModel);
}
}

我們可以看到UserService類沒有定義@Service注解，即沒有交給spring管理bean實例，所以它的add方法也不會生成事務。

5.錯誤的spring事務傳播特性

@Service
publicclassUserService{

@Autowired
privateUserMapper userMapper;

@Transactional(propagation = Propagation.NEVER)
publicvoidadd(UserModel userModel){
userMapper.insertUser(userModel);
}

}

我們可以看到add方法的事務傳播特性定義成了Propagation.NEVER，這種類型的傳播特性不支持事務，如果有事務則會拋異常。只有這三種傳播特性才會創(chuàng)建新事務：PROPAGATION_REQUIRED，PROPAGATION_REQUIRES_NEW，PROPAGATION_NESTED。

6.數(shù)據(jù)庫不支持事務

msql8以前的版本數(shù)據(jù)庫引擎是支持myslam和innerdb的。我以前也用過，對應查多寫少的單表操作，可能會把表的數(shù)據(jù)庫引擎定義成myslam，這樣可以提升查詢效率。但是，要千萬記得一件事情，myslam只支持表鎖，并且不支持事務。所以，對這類表的寫入操作事務會失效。

7.自己吞掉了異常

@Slf4j
@Service
public class UserService {

@Autowired
private UserMapper userMapper;

@Transactional
public void add(UserModel userModel) {
try{
userMapper.insertUser(userModel);
}catch(Exception e) {
log.error(e.getMessage(), e);
}
}
}

這種情況下事務不會回滾，因為開發(fā)者自己捕獲了異常，又沒有拋出。事務的AOP無法捕獲異常，導致即使出現(xiàn)了異常，事務也不會回滾。

8.拋出的異常不正確

@Slf4j
@Service
public class UserService {

@Autowired
private UserMapper userMapper;

@Transactional
public void add(UserModel userModel) throws Exception {
try{
userMapper.insertUser(userModel);
}catch(Exception e) {
log.error(e.getMessage(), e);
thrownewException(e);
}
}

}

這種情況下，開發(fā)人員自己捕獲了異常，又拋出了異常：Exception，事務也不會回滾。因為spring事務，默認情況下只會回滾RuntimeException（運行時異常）和Error（錯誤），不會回滾Exception。

9.多線程調(diào)用

@Slf4j
@Service
publicclassUserService{

@Autowired
privateUserMapper userMapper;
@Autowired
privateRoleService roleService;

@Transactional
publicvoidadd(UserModel userModel)throwsException{
userMapper.insertUser(userModel);
newThread(() -> {
roleService.doOtherThing();
}).start();
}
}

@Service
publicclassRoleService{

@Transactional
publicvoiddoOtherThing(){
System.out.println("保存role表數(shù)據(jù)");
}
}

我們可以看到事務方法add中，調(diào)用了事務方法doOtherThing，但是事務方法doOtherThing是在另外一個線程中調(diào)用的，這樣會導致兩個事務方法不在同一個線程中，獲取到的數(shù)據(jù)庫連接不一樣，從而是兩個不同的事務。如果想doOtherThing方法中拋了異常，add方法也回滾是不可能的。

如果看過spring事務源碼的朋友，可能會知道spring的事務是通過數(shù)據(jù)庫連接來實現(xiàn)的。當前線程中保存了一個map，key是數(shù)據(jù)源，value是數(shù)據(jù)庫連接。

privatestaticfinal ThreadLocal> resources =
newNamedThreadLocal<>("Transactional resources");

我們說的同一個事務，其實是指同一個數(shù)據(jù)庫連接，只有擁有同一個數(shù)據(jù)庫連接才能同時提交和回滾。如果在不同的線程，拿到的數(shù)據(jù)庫連接肯定是不一樣的，所以是不同的事務。

10.嵌套事務多回滾了

publicclassUserService{

@Autowired
privateUserMapper userMapper;

@Autowired
privateRoleService roleService;

@Transactional
publicvoidadd(UserModel userModel)throwsException{
userMapper.insertUser(userModel);
roleService.doOtherThing();
}
}

@Service
publicclassRoleService{

@Transactional(propagation = Propagation.NESTED)
publicvoiddoOtherThing(){
System.out.println("保存role表數(shù)據(jù)");
}
}

這種情況使用了嵌套的內(nèi)部事務，原本是希望調(diào)用roleService.doOtherThing方法時，如果出現(xiàn)了異常，只回滾doOtherThing方法里的內(nèi)容，不回滾 userMapper.insertUser里的內(nèi)容，即回滾保存點。。但事實是，insertUser也回滾了。

why?

因為doOtherThing方法出現(xiàn)了異常，沒有手動捕獲，會繼續(xù)往上拋，到外層add方法的代理方法中捕獲了異常。所以，這種情況是直接回滾了整個事務，不只回滾單個保存點。

怎么樣才能只回滾保存點呢？

@Slf4j
@Service
public class UserService {

@Autowired
private UserMapper userMapper;

@Autowired
private RoleService roleService;

@Transactional
public void add(UserModel userModel) throws Exception {

userMapper.insertUser(userModel);
try{
roleService.doOtherThing();
}catch(Exception e) {
log.error(e.getMessage(), e);
}
}

}

在代碼中手動把內(nèi)部嵌套事務放在try/catch中，并且不繼續(xù)往拋異常。

介紹到這里，你會發(fā)現(xiàn)spring事務的坑還是挺多的~

審核編輯：湯梓紅