一、前言

springboot整合多数据源解决分布式事务。

1.多数据源采用分包策略

2.全局分布式事务管理：jta-atomikos。

在此记录下，分享给大家。

二、springboot整合多数据源解决分布式事务

1、pom文件 依赖引入

org.springframework.boot

spring-boot-starter-parent

2.1.8.RELEASE

org.springframework.boot

spring-boot-starter-test

test

org.springframework.boot

spring-boot-starter-web

org.mybatis.spring.boot

mybatis-spring-boot-starter

1.1.1

mysql

mysql-connector-java

5.1.38

org.springframework.boot

spring-boot-starter-jta-atomikos

org.springframework.boot

spring-boot-configuration-processor

true

org.projectlombok

lombok

1.18.4

2、application.yml新增配置

spring:

datasource:

##用户数据库

user:

url: jdbc:mysql://127.0.0.1:3306/yys_user

username: root

password:123456

borrowConnectionTimeout:30

loginTimeout:30

maintenanceInterval:60

maxIdleTime:60

maxLifetime:20000

maxPoolSize:25

minPoolSize:3

uniqueResourceName:

userDataSource

testQuery: select1

##订单数据库

order:

url: jdbc:mysql://127.0.0.1:3306/yys_order

username: root

password:123456

borrowConnectionTimeout:30

loginTimeout:30

maintenanceInterval:60

maxIdleTime:60

maxLifeTime:20000

maxPoolSize:25

minPoolSize:3

uniqueResourceName:

orderDataSource

testQuery: select1

3、userConfig.java

@ConfigurationProperties(prefix ="spring.datasource.user")

@Data

publicclassUserConfig{

private String url;

private String userName;

private String password;

private int

minPoolSize;

private int

maxPoolSize;

private int

maxLifeTime;

private int

maxIdleTime;

private int

loginTimeout;

private int

maintenanceInterval;

private int borrowConnectionTimeout;

private String testQuery;

private String

uniqueResourceName;

}

4、userDataSourceConfig.java

/**

*用户数据源

*      Config

*@authoryys

*/

@Configuration

@MapperScan(basePackages ="com.yys.user.mapper", sqlSessionTemplateRef

="userSqlSessionTemplate")

publicclassUserDataSourceConfig{

/**

*创建XADataSource

*@return

*/

@Bean("userDataSource")

public DataSourceuserDataSource(UserConfig

userConfig) throws SQLException {

// 1、创建Mysql XADataSource

MysqlXADataSource

mysqlXaDataSource = new MysqlXADataSource();

mysqlXaDataSource.setUrl(userConfig.getUrl());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

mysqlXaDataSource.setPassword(userConfig.getPassword());

mysqlXaDataSource.setUser(userConfig.getUserName());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

// 2、将本地事务注册到Atomikos全局事务

AtomikosDataSourceBean

xaDataSource = new AtomikosDataSourceBean();

xaDataSource.setXaDataSource(mysqlXaDataSource);

xaDataSource.setUniqueResourceName(userConfig.getUniqueResourceName());

xaDataSource.setMinPoolSize(userConfig.getMinPoolSize());

xaDataSource.setMaxPoolSize(userConfig.getMaxPoolSize());

xaDataSource.setMaxLifetime(userConfig.getMaxLifeTime());

xaDataSource.setBorrowConnectionTimeout(userConfig.getBorrowConnectionTimeout());

xaDataSource.setLoginTimeout(userConfig.getLoginTimeout());

xaDataSource.setMaintenanceInterval(userConfig.getMaintenanceInterval());

xaDataSource.setMaxIdleTime(userConfig.getMaxIdleTime());

xaDataSource.setTestQuery(userConfig.getTestQuery());

return xaDataSource;

}

/**

*创建SQL会话工厂

*@paramdataSource

*@return

*@throwsException

*/

@Bean("userSqlSessionFactory")

public SqlSessionFactoryuserSqlSessionFactory(@Qualifier("userDataSource") DataSource

dataSource) throws Exception {

SqlSessionFactoryBean

sqlSessionFactoryBean = new SqlSessionFactoryBean();

sqlSessionFactoryBean.setDataSource(dataSource);

return

sqlSessionFactoryBean.getObject();

}

/**

*创建用户SqlSession模板

*@paramsqlSessionFactory

*@return

*/

@Bean("userSqlSessionTemplate")

public SqlSessionTemplateuserSqlSessionTemplate(@Qualifier("userSqlSessionFactory")

SqlSessionFactory sqlSessionFactory) {

return new

SqlSessionTemplate(sqlSessionFactory);

}

}

5、orderConfig.java

@ConfigurationProperties(prefix ="spring.datasource.order")

@Data

publicclassOrderConfig{

private String url;

private String userName;

private String password;

private int minPoolSize;

private int

maxPoolSize;

private int

maxLifeTime;

private int

maxIdleTime;

private int

loginTimeout;

private int

maintenanceInterval;

private int

borrowConnectionTimeout;

private String testQuery;

private String

uniqueResourceName;

}

6、orderDataSourceConfig.java

/**

*订单数据源

*      Config

*@authoryys

*/

@Configuration

@MapperScan(basePackages ="com.yys.order.mapper",

sqlSessionTemplateRef ="orderSqlSessionTemplate")

publicclassOrderDataSourceConfig{

/**

*创建XADataSource

*@return

*/

@Bean("orderDataSource")

public DataSourceorderDataSource(OrderConfig

orderConfig) throws SQLException {

// 1、创建Mysql XADataSource

MysqlXADataSource

mysqlXaDataSource = new MysqlXADataSource();

mysqlXaDataSource.setUrl(orderConfig.getUrl());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

mysqlXaDataSource.setPassword(orderConfig.getPassword());

mysqlXaDataSource.setUser(orderConfig.getUserName());

mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);

// 2、将本地事务注册到Atomikos全局事务

AtomikosDataSourceBean xaDataSource

= new AtomikosDataSourceBean();

xaDataSource.setXaDataSource(mysqlXaDataSource);

xaDataSource.setUniqueResourceName(orderConfig.getUniqueResourceName());

xaDataSource.setMinPoolSize(orderConfig.getMinPoolSize());

xaDataSource.setMaxPoolSize(orderConfig.getMaxPoolSize());

xaDataSource.setMaxLifetime(orderConfig.getMaxLifeTime());

xaDataSource.setBorrowConnectionTimeout(orderConfig.getBorrowConnectionTimeout());

xaDataSource.setLoginTimeout(orderConfig.getLoginTimeout());

xaDataSource.setMaintenanceInterval(orderConfig.getMaintenanceInterval());

xaDataSource.setMaxIdleTime(orderConfig.getMaxIdleTime());

xaDataSource.setTestQuery(orderConfig.getTestQuery());

return xaDataSource;

}

/**

*创建SQL会话工厂

*@paramdataSource

*@return

*@throwsException

*/

@Bean("orderSqlSessionFactory")

public SqlSessionFactoryorderSqlSessionFactory(@Qualifier("orderDataSource") DataSource

dataSource) throws Exception {

SqlSessionFactoryBean

sqlSessionFactoryBean = new SqlSessionFactoryBean();

sqlSessionFactoryBean.setDataSource(dataSource);

return sqlSessionFactoryBean.getObject();

}

/**

*创建订单SqlSession模板

*@paramsqlSessionFactory

*@return

*/

@Bean("orderSqlSessionTemplate")

public SqlSessionTemplateorderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory")

SqlSessionFactory sqlSessionFactory) {

return new

SqlSessionTemplate(sqlSessionFactory);

}

}

UserService.java

publicclassUserService{

@Autowired

private UserMapper

userMapper;

@Autowired

private OrderMapper

orderMapper;

//全局事务处理器

//事务底层原理采用aop技术做增强

//无需再指定某个事务管理器，全交给Atomikos全局事务

@Transactional

public BooleanaddUser(String name,

Integer age, Double amount, String address) {

//操作用户库

int i =

userMapper.addUser(name, age);

//操作订单库

int j =

orderMapper.addOrder(amount, address);

//测试事务回滚(age = 0：回滚；age > 0：事务提交)

int flag =1/ age;

return i >0&& j

>0;

}

}