date: 2022-04-25
categories: [java, 編程]
tags: [分布式事務(wù)]

概述

多數(shù)據(jù)源單服務(wù)寫入, 分布式事務(wù)實現(xiàn)

使用隨機數(shù)控制產(chǎn)生異常

注: 網(wǎng)上很多都是只有多數(shù)據(jù)源配置，實際不能控制事務(wù)統(tǒng)一回滾,
單服務(wù)場景下如果多個數(shù)據(jù)源只有一個寫，剩下都是讀, 則不需要分布式事務(wù)

為減少篇幅，詳細代碼在代碼倉庫，可自行參考

版本

springboot 2.1.7.RELEASE

配置引入

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
</dependency>

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-jta-atomikos</artifactId>
</dependency>

增加配置類

AtomikosJtaPlatform

JPAAtomikosTransactionConfig Atomikos事務(wù)配置類

PrimaryConfig 主數(shù)據(jù)源配置

SecondaryConfig 其它數(shù)據(jù)源配置

數(shù)據(jù)對象實現(xiàn)

User

增加倉儲實現(xiàn)

需要分別實現(xiàn)primary和secondary, 從而支持多個數(shù)據(jù)源訪問

PrimaryUserRepository

SecondaryUserRepository

實現(xiàn)服務(wù)類

PrimaryUserService

SecondaryUserService

ExampleService

負責統(tǒng)一調(diào)用 PrimaryUserService 和 SecondaryUserService,
模擬一個服務(wù)同時訪問多個服務(wù)類(每個服務(wù)類引用了不同數(shù)據(jù)源)

如果其中某個服務(wù)拋出異常，則整個事務(wù)回滾, @Transactional(rollbackOn =
Exception.class) 是必須的

測試

com.example.springbootatomikos.services.UserServiceTest#testSave

代碼

github地址

gitee地址