<dependencies>
        <!-- Spring Boot Starter -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

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

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

        <!-- mybatis plus -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.3.1</version>
        </dependency>

        <!-- mysql 驅(qū)動(dòng)包 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.26</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>

    </dependencies>

# 服務(wù)端口號(hào)
server:
  port:
    8069

# 多數(shù)據(jù)源配置
spring:
  datasource:
    properties:
      user_db:
        url: jdbc:mysql://192.168.1.18:3306/user_db
        user: root
        password: xxxxxxx
      data_db:
        url: jdbc:mysql://192.168.1.18:3306/data_db
        user: root
        password: xxxxxxx

package personal.gltm.demo.config;

import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import com.mysql.cj.jdbc.MysqlXADataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jta.atomikos.AtomikosDataSourceBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.DependsOn;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import javax.sql.DataSource;
import java.util.LinkedHashMap;
import java.util.Map;

@Configuration
@ConfigurationProperties("spring.datasource")
public class DataSourceConfiguration {
    private Map<String,Map<String,String>> properties; // spring.datasource.properties

    private Map<String,DataSource> sourceMap; // 用來(lái)保存數(shù)據(jù)源信息

    public Map<String, Map<String,String>> getProperties() {
        return properties;
    }

    public void setProperties(Map<String, Map<String,String>> properties) {
        this.properties = properties;
    }


    /**
     * 添加user_db數(shù)據(jù)源
     * @return
     */
    @Bean("user_db")
    @DependsOn({"datasourceMap"})
    public DataSource userDatasource(){
        return sourceMap.get("user_db");
    }

    /**
     * 添加user_db  SqlSessionFactory
     * @return
     * @throws Exception
     */
    @Bean("user_db_sql_session_factory")
    @DependsOn("user_db")
    public SqlSessionFactory userDbSqlSessionFactory() throws Exception {
        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
        bean.setDataSource(this.sourceMap.get("user_db"));
        // 設(shè)置mapper位置
        bean.setTypeAliasesPackage("personal.gltm.demo.mapper.user");
        // 設(shè)置mapper.xml文件的路徑
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:user/mapper/*.xml"));
        return bean.getObject();
    }


    /**
     * 添加 data_db 數(shù)據(jù)源
     * @return
     */
    @Bean("data_db")
    @DependsOn({"datasourceMap"})
    public DataSource dataDatasource(){
        return sourceMap.get("data_db");
    }

    /**
     * 添加data_db SqlSessionFactory
     * @return
     * @throws Exception
     */
    @Bean("data_db_sql_session_factory")
    @DependsOn("data_db")
    public SqlSessionFactory dataDbSqlSessionFactory() throws Exception {
        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
        bean.setDataSource(this.sourceMap.get("data_db"));
        // 設(shè)置mapper位置
        bean.setTypeAliasesPackage("personal.gltm.demo.mapper.data");

        // 設(shè)置mapper.xml文件的路徑
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:data/mapper/*.xml"));
        return bean.getObject();
    }


    /**
     * 創(chuàng)建XA 數(shù)據(jù)源并添加到sourceMap中
     * @param dataSourceConfiguration
     * @return
     */
    @Bean("datasourceMap")
    @Primary
    public Map<String, DataSource> datasourceMap(DataSourceConfiguration dataSourceConfiguration){
        Map<String, DataSource> map = new LinkedHashMap<>();
        for(Map.Entry<String,Map<String, String>> entry:dataSourceConfiguration.properties.entrySet()){
            // 讀取每個(gè)數(shù)據(jù)源的配置創(chuàng)建datasource
            MysqlXADataSource dataSource = new MysqlXADataSource();
            dataSource.setUrl(entry.getValue().get("url"));
            dataSource.setUser(entry.getValue().get("user"));
            dataSource.setPassword(entry.getValue().get("password"));

            // 創(chuàng)建atomikosDataSource數(shù)據(jù)源
            AtomikosDataSourceBean atomikosDataSource = new AtomikosDataSourceBean();
            atomikosDataSource.setMaxPoolSize(10);
            atomikosDataSource.setMinPoolSize(5);
            atomikosDataSource.setBeanName(entry.getKey()); // 設(shè)置bean的名稱
            atomikosDataSource.setXaDataSource(dataSource); // 設(shè)置Xa數(shù)據(jù)源
            atomikosDataSource.setTestQuery("select now()");

            map.put(entry.getKey(), atomikosDataSource);
        }
        this.sourceMap = map;
        return map;
    }

}

package personal.gltm.demo.config;

import com.atomikos.icatch.jta.UserTransactionImp;
import com.atomikos.icatch.jta.UserTransactionManager;
import lombok.SneakyThrows;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.mybatis.spring.annotation.MapperScans;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.jta.JtaTransactionManager;

import javax.transaction.SystemException;
import javax.transaction.TransactionManager;
import javax.transaction.UserTransaction;

@Configuration
@EnableTransactionManagement
@MapperScans({@MapperScan(basePackages={"personal.gltm.demo.mapper.user"},sqlSessionFactoryRef = "user_db_sql_session_factory"),
        @MapperScan(basePackages = {"personal.gltm.demo.mapper.data"},sqlSessionFactoryRef = "data_db_sql_session_factory")})
public class AtomikosConfig {

    // 用于在應(yīng)用程序中執(zhí)行事務(wù)的控制操作。
    @Bean(name = "userTransaction")
    @SneakyThrows(Exception.class)
    public UserTransaction userTransaction() throws SystemException {
        final UserTransactionImp userTransactionImp = new UserTransactionImp();
        userTransactionImp.setTransactionTimeout(1000);
        return userTransactionImp;
    }


    // 用于管理和控制分布式事務(wù)的整個(gè)生命周期。
    @Bean(name = "atomikosTransactionManager")
    @SneakyThrows(Exception.class)
    public TransactionManager atomikosTransactionManager() {
        final UserTransactionManager userTransactionManager = new UserTransactionManager();
        userTransactionManager.setForceShutdown(false);
        return userTransactionManager;
    }


    // JtaTransactionManager 的主要作用是管理和協(xié)調(diào)分布式事務(wù)，它支持使用 JTA 來(lái)處理分布式事務(wù)，與 JTA 兼容的事務(wù)管理器進(jìn)行交互。
    @Bean(name = "transactionManager")
    @SneakyThrows(Throwable.class)
    public PlatformTransactionManager transactionManager(
            @Qualifier("atomikosTransactionManager") TransactionManager atomikosTransactionManager,
                                                         @Qualifier("userTransaction") UserTransaction userTransaction) throws SystemException {
        return new JtaTransactionManager(userTransaction(), atomikosTransactionManager());
    }

}

package personal.gltm.demo.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import personal.gltm.demo.model.Data;
import personal.gltm.demo.model.User;
import personal.gltm.demo.service.DataService;
import personal.gltm.demo.service.UserService;

import java.math.BigDecimal;

@RequestMapping("/test")
@RestController
public class TestController {

    @Autowired
    private UserService userService;

    @Autowired
    private DataService dataService;

    @GetMapping("/test/{u-id}/{d-id}")
    @Transactional(rollbackFor = Throwable.class)
    public String Test(@PathVariable("u-id")BigDecimal uId,@PathVariable("d-id") BigDecimal dId){
        User user = new User();
        user.setId(uId);
        user.setUserName("sihong" + Math.floor(Math.random() * 20));
        userService.insert(user);

        Data data = new Data();
        data.setId(dId);
        data.setContext("mine mine mine ..... " + System.nanoTime());
        dataService.insert(data);

        return "success";
    }
}