知識庫 / Spring / Spring Boot RSS 訂閱

3.1. 傳播類型

具體來説，我們希望 審計操作在單獨的事務中執行。由於 Spring 使用 AOP 代理來處理 @Transactional，因此該解決方案需要一個單獨的代理。 實現所需結果的最簡單方法是提取一個專門用於與 審計數據交互的新類：

@Service
class AuditService {

    private final AuditRepo auditRepo;

    // constructor

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void saveAudit(String action, String status, String message) {
        auditRepo.save(new Audit(action, status, message));
    }

}

如我們所見，saveAudit() 也標記為 @Transactional。 默認情況下，如果它從另一個事務方法中調用，它將參與到現有的事務中。 但是，我們使用 Propagation.REQUIRES_NEW 覆蓋了默認行為，因此 Spring 始終為保存 Audit 實體創建新的事務。

現在，我們可以更新主服務以調用此方法。 讓我們創建一個新的方法，publishArticle_v2()，以便我們可以輕鬆地比較這兩種方法：

@Transactional
public Optional<Long> publishArticle_v2(Article article) {
    try {
        article = articleRepo.save(article);
        auditService.saveAudit("SAVE_ARTICLE", "SUCCESS", "saved: " + article.getTitle());
        return Optional.of(article.getId());

    } catch (Exception e) {
        auditService.saveAudit("SAVE_ARTICLE", "FAILURE", "failed to save: " + article.getTitle());
        return Optional.empty();
    }
}

因此，我們可以使用 AOP 和 @Transactional 註解來定義事務範圍，但它需要添加額外的抽象層，以便 Spring 可以創建必要的 AOP 代理。 在本示例中，我們不得不引入 AuditService，其唯一目的是委託給 AuditRepo 並覆蓋事務傳播級別以啓動一個新的事務。

3.2. 嵌套事務

我們所做的是，實際上創建了一個新的嵌套事務，同時保持了初始事務的完整性。這意味着 審計 操作將在其自身的獨立事務中運行，因此即使主事務最終失敗，也能成功提交：

下面我們編寫一個簡單的測試，以驗證這種新方法仍然由於無效的文章 Article 拋出異常，但成功地將記錄插入到 audit 表中：

@Test
void whenPublishingAnInvalidArticle_thenSavesFailureToAudit() {
    assertThatThrownBy(
         () -> articleService.publishArticle_v2(new Article("Test Article", null)))
      .isInstanceOf(Exception.class);

    assertThat(auditRepo.findAll())
      .extracting("description")
      .containsExactly("failed to save: Test Article");
}

正如預期的那樣，主交易可以自由回滾並拋出 Java 異常，同時失敗記錄仍然存在於 審計 表中。

4. 使用順序事務，通過 <em TransactionTemplate</em>> 實現

與其使用嵌套事務，我們可以選擇在啓動第二個事務之前，確保首先提交或回滾第一個事務：

由於在 Spring AOP 中精確定義事務範圍可能比較複雜，因此我們現在使用 <em TransactionTemplate</em>> Bean。

允許我們通過編程方式定義事務邊界，從而對事務的開始和結束時間具有更精細的控制。例如，我們可以使用它來為保存 `` 啓動一個事務，並在發生失敗時，確保在將其記錄到審計表中之前關閉它。 這樣，JPA 就可以為審計操作啓動一個新的事務：

@Component
class Blog {

    private final ArticleRepo articleRepo;
    private final AuditRepo auditRepo;
    private final TransactionTemplate transactionTemplate;

    // constructor

    public Optional publishArticle_v3(final Article article) {
        try {
            Article savedArticle = transactionTemplate.execute(txStatus -> {
                Article saved = articleRepo.save(article);
                auditRepo.save(
                  new Audit("SAVE_ARTICLE", "SUCCESS", "saved: " + article.getTitle()));
                return saved;
            }); // <-- transaction ends here

            return Optional.of(savedArticle.getId());

        } catch (Exception e) {
            auditRepo.save(
              new Audit("SAVE_ARTICLE", "FAILURE", "failed to save: " + article.getTitle()));
            return Optional.empty();
        }
    }
}

如果測試這個解決方案，我們可能會期望它能夠優雅地處理錯誤並返回一個空Optional。 Needless to say，它也應該在審計表中記錄失敗：

@Test
void whenPublishingAnInvalidArticle_thenRecoverFromError_andSavesFailureToAudit() {
    Optional<Long> id = articleService.publishArticle_v3(new Article("Test Article", null));

    assertThat(id).isEmpty();

    assertThat(auditRepo.findAll())
      .extracting("description")
      .containsExactly("failed to save: Test Article");
}