【JAVA】Spring 事務失效的幾種場景

目錄

概述

 事務的傳播類型

 事務隔離級别

事務失效的場景

事務方法未被Spring管理

同一個類中的事務方法被非事務方法調用

方法的事務傳播類型不支援事務

 異常被内部catch，程式生吞異常

 資料庫不支援事務

未配置開啟事務

多線程調用

概述

Spring針對Java Transaction API (JTA)、JDBC、Hibernate和Java Persistence API(JPA)等事務 API，實作了一緻的程式設計模型，而Spring的聲明式事務功能更是提供了極其友善的事務配置方式，配合Spring Boot的自動配置，大多數Spring Boot項目隻需要在方法上标記

@Transactional

注解，即可一鍵開啟方法的事務性配置。

但是，事務如果沒有被正确使用，很有可能會導緻事務的失效，帶來意想不到的資料不一緻問題，随後就是大量的人工查找問題和修複資料，本次主要分享Spring事務在技術上的正确使用方式，避免因為事務處理不當導緻業務邏輯産生大量偶發性BUG。

 事務的傳播類型

//如果沒有事務就進行建立，存在則加入

@Transactional(propagation=Propagation.REQUIRED)

//不為目前方法開啟事務 

@Transactional(propagation=Propagation.NOT_SUPPORTED)

//不管是否存在事務, 都建立一個新的事務, 原來的挂起, 新的執行完畢後, 繼續執行老的事務 

@Transactional(propagation=Propagation.REQUIRES_NEW) 

//必須在一個已有的事務中執行, 否則抛出異常

@Transactional(propagation=Propagation.MANDATORY) 

//必須在一個沒有的事務中執行, 否則抛出異常(與Propagation.MANDATORY相反)

@Transactional(propagation=Propagation.NEVER) 

//如果其他bean調用這個方法, 在其他bean中聲明事務, 那就用事務, 如果其他bean沒有聲明事務, 那就不用事務

@Transactional(propagation=Propagation.SUPPORTS) 

 事務隔離級别

// 讀未送出(會出現髒讀, 不可重複讀) 基本不使用

@Transactional(isolation = Isolation.READ_UNCOMMITTED)

// 讀已送出(會出現不可重複讀和幻讀) Oracle預設

@Transactional(isolation = Isolation.READ_COMMITTED)

// 可重複讀(會出現幻讀) MySQL預設

@Transactional(isolation = Isolation.REPEATABLE_READ)

// 串行化

@Transactional(isolation = Isolation.SERIALIZABLE)

事務失效的場景

事務方法未被Spring管理

如果事務方法所在的類沒有注冊到Spring IOC容器中，也就是說，事務方法所在類并沒有被Spring管理，則Spring事務會失效，舉個例子🌰：

public class BackGroupServiceImpl {

    @Autowired
    private SelfHelpBackgroundMapper backgroundMapper;

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void updateSelfHelpBackground(SelfHelpBackground background) {
        backgroundMapper.updateByPrimaryKey(background);
    }
}
           

BackGroupServiceImpl 實作類上沒有添加 @Service注解，執行個體也就沒有被加載到Spring IOC容器，此時updateSelfHelpBackground()方法的事務就會在Spring中失效。      

同一個類中的事務方法被非事務方法調用

@Service
public class BackGroupServiceImpl {

    @Autowired
    private SelfHelpBackgroundMapper backgroundMapper;

    @Transactional(propagation = Propagation.REQUIRED)
    public  void updateSelfHelpBackground(SelfHelpBackground background) {
        backgroundMapper.updateByPrimaryKey(background);
    }

    public void updateBackground(){
        updateSelfHelpBackground(new SelfHelpBackground());
    }
}
           

updateBackgroup()

方法和

updateSelfHelpBackgroup()

方法都在BackGroupServiceImpl類中，然而

updateBackgroup()

方法沒有添加事務注解，

updateSelfHelpBackgroup()

方法雖然添加了事務注解，這種情況

updateSelfHelpBackgroup()

會在Spring事務中失效。

方法的事務傳播類型不支援事務

@Service
public class BackGroupServiceImpl {

    @Autowired
    private SelfHelpBackgroundMapper backgroundMapper;

    @Transactional(propagation = Propagation.REQUIRED)
    public  void updateSelfHelpBackground(SelfHelpBackground background) {
        backgroundMapper.updateByPrimaryKey(background);
    }

    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void updateBackground(SelfHelpBackground background){
       backgroundMapper.updateByPrimaryKey(background);
    }
}
           

如果内部方法的事務傳播類型為不支援事務的傳播類型，則内部方法的事務同樣會在Spring中失效,如@Transactional(propagation = Propagation.NOT_SUPPORTED)

 異常被内部catch，程式生吞異常

@Service
public class OrderServiceImpl{
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private ProductMapper productMapper;

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public ResponseEntity submitOrder(Order order) {
        long orderNo = Math.abs(ThreadLocalRandom.current().nextLong(1000));
        order.setOrderNo("ORDER_" + orderNo);
        orderMapper.insert(order);

        // 扣減庫存
        this.updateProductStockById(order.getProductId(), 1L);
        return new ResponseEntity(HttpStatus.OK);
    }

    /**
     * 事務類型聲明為NOT_SUPPORTED不支援事務的傳播
     */
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void updateProductStockById(Integer num, Long productId) {
        try {
            productMapper.updateProductStockById(num, productId);
        } catch (Exception e) {
            // 這裡僅僅是捕獲異常之後的列印（相當于程式吞掉了異常）
            log.error("Error updating product Stock: {}", e);
        }
    }
}
           

 資料庫不支援事務

Spring事務生效的前提是連接配接的資料庫支援事務，如果底層的資料庫都不支援事務，則Spring事務肯定會失效的，例如🌰：使用MySQL資料庫，選用

MyISAM

存儲引擎，因為

MyISAM

存儲引擎本身不支援事務，是以事務毫無疑問會失效

未配置開啟事務

如果項目中沒有配置Spring的事務管理器，即使使用了Spring的事務管理功能，Spring的事務也不會生效，例如，如果你是Spring Boot項目，沒有在SpringBoot項目中配置如下代碼：

@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
}
           

多線程調用

@Slf4j
@Service
public class OrderServiceImpl {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private MessageService messageService;

    @Transactional
    public void orderCommit(orderModel orderModel) throws Exception {
        orderMapper.insertOrder(orderModel);
        new Thread(() -> {
            messageService.sendSms();
        }).start();
    }
}

@Service
public class MessageService {

    @Transactional
    public void sendSms() {
        // 發送短信
    }
}
           

通過示例，我們可以看到訂單送出的事務方法 

orderCommit()

中，調用了發送短信的事務方法

sendSms()

，但是發送短信的事務方法

sendSms()

是另起了一個線程調用的。

這樣會導緻兩個方法不在同一個線程中，進而是兩個不同的事務。如果是

sendSms()

方法中抛了異常，

orderCommit()

方法也復原是不可能的。

實際上，Spring的事務是通過ThreadLocal來保證線程安全的，事務和目前線程綁定，多個線程自然會讓事務失效。