本文共 6820 字，大约阅读时间需要 22 分钟。

当只有一个数据源的时候，添加标签@EnableTransactionManagement,然后在dateBaseConfig里添加

@Bean(name = "transactionManager")    public DataSourceTransactionManager transactionManager() {        log.info("-------------------- transactionManager init ---------------------");        return new DataSourceTransactionManager(writeDataSource());    }

后来添加多数据源以后，发现这样写事物不起作用了，所以决定记录一下多数据源的事物配置。

1、引入jar包

   			
    
     org.springframework.boot
    			
    
     spring-boot-starter-jta-atomikos
    		
   

# 主数据源，默认的spring.datasource.driver-class-name=com.mysql.jdbc.Driverspring.datasource.url=jdbc:mysql://localhost:3308/testspring.datasource.username=rootspring.datasource.password=123456spring.datasource.minPoolSize = 3spring.datasource.maxPoolSize = 25spring.datasource.maxLifetime = 20000spring.datasource.borrowConnectionTimeout = 30spring.datasource.loginTimeout = 30spring.datasource.maintenanceInterval = 60spring.datasource.maxIdleTime = 60spring.datasource.validationQuery = select 1

3、创建对应的类

package com.demo.model;import lombok.Data;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Configuration;/** * Created by huguoju on 2017/3/27. */@Configuration@Data@ConfigurationProperties(prefix = "spring.datasource",locations = "classpath:test.properties")public class DBConfig {    private String driverClassName;    private String url;    private String username;    private String password;    /** min-pool-size 最小连接数 **/    private int minPoolSize;    /** max-pool-size 最大连接数 **/    private int maxPoolSize;    /**  max-lifetime 连接最大存活时间 **/    private int maxLifetime;    /** borrow-connection-timeout 获取连接失败重新获等待最大时间，在这个时间内如果有可用连接，将返回 **/    private int borrowConnectionTimeout;    /** login-timeout java数据库连接池，最大可等待获取datasouce的时间 **/    private int loginTimeout;    /** maintenance-interval 连接回收时间 **/    private int maintenanceInterval;    /** max-idle-time 最大闲置时间，超过最小连接池连接的连接将将关闭 **/    private int maxIdleTime;    /** test-query 测试SQL **/    private String validationQuery;}

@Bean(name="writeDataSource", destroyMethod = "close", initMethod="init")    @Primary    public DataSource writeDataSource() throws SQLException {        log.info("-------------------- writeDataSource init ---------------------");//        DruidXADataSource druidXADataSource=new DruidXADataSource();//        druidXADataSource.setDriverClassName(dbConfig.getDriverClassName());//        druidXADataSource.setUrl(dbConfig.getUrl());//        druidXADataSource.setPassword(dbConfig.getPassword());//        druidXADataSource.setUsername(dbConfig.getUsername());        MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource();        mysqlXaDataSource.setUrl(dbConfig.getUrl());        mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);        mysqlXaDataSource.setPassword(dbConfig.getPassword());        mysqlXaDataSource.setUser(dbConfig.getUsername());        mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);        AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean();        xaDataSource.setXaDataSource(mysqlXaDataSource);        xaDataSource.setUniqueResourceName("writeDataSource");        xaDataSource.setMinPoolSize(dbConfig.getMinPoolSize());        xaDataSource.setMaxPoolSize(dbConfig.getMaxPoolSize());        xaDataSource.setMaxLifetime(dbConfig.getMaxLifetime());        xaDataSource.setBorrowConnectionTimeout(dbConfig.getBorrowConnectionTimeout());        /** login-timeout java数据库连接池，最大可等待获取datasouce的时间 **/        xaDataSource.setLoginTimeout(dbConfig.getLoginTimeout());        xaDataSource.setMaintenanceInterval(dbConfig.getMaintenanceInterval());        xaDataSource.setMaxIdleTime(dbConfig.getMaxIdleTime());        xaDataSource.setTestQuery(dbConfig.getValidationQuery());        return xaDataSource;    }

package com.demo.mybatis;import com.atomikos.icatch.jta.UserTransactionImp;import com.atomikos.icatch.jta.UserTransactionManager;import lombok.extern.slf4j.Slf4j;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.ComponentScan;import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.DependsOn;import org.springframework.transaction.PlatformTransactionManager;import org.springframework.transaction.annotation.EnableTransactionManagement;import org.springframework.transaction.jta.JtaTransactionManager;import javax.transaction.TransactionManager;import javax.transaction.UserTransaction;/** * 自定义事务 * Created by huguoju on 2016/12/29. */@Configuration@ComponentScan@EnableTransactionManagement@Slf4jpublic class DataSourceTransactionManager{    /**     * 自定义事务     * MyBatis自动参与到spring事务管理中，无需额外配置，只要org.mybatis.spring.SqlSessionFactoryBean引用的数据源与DataSourceTransactionManager引用的数据源一致即可，否则事务管理会不起作用。     * @return     */    @Bean(name = "userTransaction")    public UserTransaction userTransaction() throws Throwable {        UserTransactionImp userTransactionImp = new UserTransactionImp();        userTransactionImp.setTransactionTimeout(10000);        return userTransactionImp;    }    @Bean(name = "atomikosTransactionManager", initMethod = "init", destroyMethod = "close")    public TransactionManager atomikosTransactionManager() throws Throwable {        UserTransactionManager userTransactionManager = new UserTransactionManager();        userTransactionManager.setForceShutdown(false);        return userTransactionManager;    }    @Bean(name = "transactionManager")    @DependsOn({ "userTransaction", "atomikosTransactionManager" })    public PlatformTransactionManager transactionManager() throws Throwable {        UserTransaction userTransaction = userTransaction();        JtaTransactionManager manager = new JtaTransactionManager(userTransaction,atomikosTransactionManager());        return manager;    }}

@ApiOperation("测试事物")     @RequestMapping(value = "testTransaction",method = {RequestMethod.POST,RequestMethod.GET},produces = MediaType.APPLICATION_JSON_UTF8_VALUE)     public void testTransaction() throws Exception {         try{             testService.testTransaction();         }catch (Exception e){             System.out.println("失败："+e.getMessage());         }     }

@Override    public void testTransaction() throws Exception {        final User user1=User.builder()                .userCode(11112)                .isOldUser("1")                .userName("测试")                .userStyle(1)                .userType("1")                .createdDate(new Date())                .updatedDate(new Date())                .isDeleted((short) 0)                .mobileNumber("18311111111").build();          userMapper.insert(user1);        throw new RuntimeException("插入失败");    }

throw new RuntimeException("插入失败");

转载地址：http://nqpws.baihongyu.com/