Atomikos是一個(gè)為Java平臺(tái)提供增值服務(wù)的并且開(kāi)源類(lèi)事務(wù)管理器，如果將事務(wù)統(tǒng)一注冊(cè)到Atomikos中，則可以統(tǒng)一管理。常用于后臺(tái)管理系統(tǒng)的多數(shù)據(jù)庫(kù)操作。

方式： a、按包名 b、按注解區(qū)分Springboot默認(rèn)集成事務(wù),只主要在方法上加上@Transactional即可，不需要開(kāi)啟@EnableTransactionManagement注解如果多個(gè)數(shù)據(jù)庫(kù)，則每個(gè)方法都需要單獨(dú)設(shè)置事務(wù)管理器@Transactional(transactionManager = 'test2TransactionManager')，如果事務(wù)中含多數(shù)據(jù)源則無(wú)效。

1.依賴(lài)引入

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

2.多數(shù)據(jù)源配置文件

# Mysql 1mysql.datasource.test1.url = jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf-8mysql.datasource.test1.username = rootmysql.datasource.test1.password = rootmysql.datasource.test1.minPoolSize = 3mysql.datasource.test1.maxPoolSize = 25mysql.datasource.test1.maxLifetime = 20000mysql.datasource.test1.borrowConnectionTimeout = 30mysql.datasource.test1.loginTimeout = 30mysql.datasource.test1.maintenanceInterval = 60mysql.datasource.test1.maxIdleTime = 60# Mysql 2mysql.datasource.test2.url =jdbc:mysql://localhost:3306/test02?useUnicode=true&characterEncoding=utf-8mysql.datasource.test2.username =rootmysql.datasource.test2.password =rootmysql.datasource.test2.minPoolSize = 3mysql.datasource.test2.maxPoolSize = 25mysql.datasource.test2.maxLifetime = 20000mysql.datasource.test2.borrowConnectionTimeout = 30mysql.datasource.test2.loginTimeout = 30mysql.datasource.test2.maintenanceInterval = 60mysql.datasource.test2.maxIdleTime = 60

3.配置代碼

@Data@ConfigurationProperties(prefix = 'mysql.datasource.test1')public class DBConfig1 { private String url; private String username; private String password; private int minPoolSize; private int maxPoolSize; private int maxLifetime; private int borrowConnectionTimeout; private int loginTimeout; private int maintenanceInterval; private int maxIdleTime; private String testQuery;}@Data@ConfigurationProperties(prefix = 'mysql.datasource.test2')public class DBConfig2 { private String url; private String username; private String password; private int minPoolSize; private int maxPoolSize; private int maxLifetime; private int borrowConnectionTimeout; private int loginTimeout; private int maintenanceInterval; private int maxIdleTime; private String testQuery;}@Configuration// basePackages 最好分開(kāi)配置 如果放在同一個(gè)文件夾可能會(huì)報(bào)錯(cuò)@MapperScan(basePackages = 'com.itmayiedu.test01', sqlSessionTemplateRef = 'testSqlSessionTemplate')public class MyBatisConfig1 { // 配置數(shù)據(jù)源 @Primary @Bean(name = 'testDataSource') public DataSource testDataSource(DBConfig1 testConfig) throws SQLException { MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource(); mysqlXaDataSource.setUrl(testConfig.getUrl()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); mysqlXaDataSource.setPassword(testConfig.getPassword()); mysqlXaDataSource.setUser(testConfig.getUsername()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean(); xaDataSource.setXaDataSource(mysqlXaDataSource); xaDataSource.setUniqueResourceName('testDataSource'); xaDataSource.setMinPoolSize(testConfig.getMinPoolSize()); xaDataSource.setMaxPoolSize(testConfig.getMaxPoolSize()); xaDataSource.setMaxLifetime(testConfig.getMaxLifetime()); xaDataSource.setBorrowConnectionTimeout(testConfig.getBorrowConnectionTimeout()); xaDataSource.setLoginTimeout(testConfig.getLoginTimeout()); xaDataSource.setMaintenanceInterval(testConfig.getMaintenanceInterval()); xaDataSource.setMaxIdleTime(testConfig.getMaxIdleTime()); xaDataSource.setTestQuery(testConfig.getTestQuery()); return xaDataSource; } @Primary @Bean(name = 'testSqlSessionFactory') public SqlSessionFactory testSqlSessionFactory(@Qualifier('testDataSource') DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); return bean.getObject(); } @Primary @Bean(name = 'testSqlSessionTemplate') public SqlSessionTemplate testSqlSessionTemplate( @Qualifier('testSqlSessionFactory') SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); }}@Configuration@MapperScan(basePackages = 'com.itmayiedu.test02', sqlSessionTemplateRef = 'test2SqlSessionTemplate')public class MyBatisConfig2 { // 配置數(shù)據(jù)源 @Bean(name = 'test2DataSource') public DataSource testDataSource(DBConfig2 testConfig) throws SQLException { MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource(); mysqlXaDataSource.setUrl(testConfig.getUrl()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); mysqlXaDataSource.setPassword(testConfig.getPassword()); mysqlXaDataSource.setUser(testConfig.getUsername()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean(); xaDataSource.setXaDataSource(mysqlXaDataSource); xaDataSource.setUniqueResourceName('test2DataSource'); xaDataSource.setMinPoolSize(testConfig.getMinPoolSize()); xaDataSource.setMaxPoolSize(testConfig.getMaxPoolSize()); xaDataSource.setMaxLifetime(testConfig.getMaxLifetime()); xaDataSource.setBorrowConnectionTimeout(testConfig.getBorrowConnectionTimeout()); xaDataSource.setLoginTimeout(testConfig.getLoginTimeout()); xaDataSource.setMaintenanceInterval(testConfig.getMaintenanceInterval()); xaDataSource.setMaxIdleTime(testConfig.getMaxIdleTime()); xaDataSource.setTestQuery(testConfig.getTestQuery()); return xaDataSource; } @Bean(name = 'test2SqlSessionFactory') public SqlSessionFactory testSqlSessionFactory(@Qualifier('test2DataSource') DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); return bean.getObject(); } @Bean(name = 'test2SqlSessionTemplate') public SqlSessionTemplate testSqlSessionTemplate( @Qualifier('test2SqlSessionFactory') SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); }}

4.啟動(dòng)加載配置

@EnableConfigurationProperties(value = { DBConfig1.class, DBConfig2.class })使用還是正常使用@Transactional方式

到此這篇關(guān)于SpringBoot使用Atomikos技術(shù)整合多數(shù)據(jù)源的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)SpringBoot Atomikos多數(shù)據(jù)源內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！