今天小編給大家分享一下SpringBoot2中如何使用JTA組件實(shí)現(xiàn)多數(shù)據(jù)源事務(wù)管理的相關(guān)知識(shí)點(diǎn)，內(nèi)容詳細(xì)，邏輯清晰，相信大部分人都還太了解這方面的知識(shí)，所以分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后有所收獲，下面我們一起來了解一下吧。
JTA即Java-Transaction-API，JTA允許應(yīng)用程序執(zhí)行分布式事務(wù)處理，即在兩個(gè)或多個(gè)網(wǎng)絡(luò)計(jì)算機(jī)資源上訪問并且更新數(shù)據(jù)。JDBC驅(qū)動(dòng)程序?qū)TA的支持極大地增強(qiáng)了數(shù)據(jù)訪問能力。
XA協(xié)議是數(shù)據(jù)庫層面的一套分布式事務(wù)管理的規(guī)范,JTA是XA協(xié)議在Java中的實(shí)現(xiàn),多個(gè)數(shù)據(jù)庫或是消息廠商實(shí)現(xiàn)JTA接口,開發(fā)人員只需要調(diào)用SpringJTA接口即可實(shí)現(xiàn)JTA事務(wù)管理功能。
JTA事務(wù)比JDBC事務(wù)更強(qiáng)大。一個(gè)JTA事務(wù)可以有多個(gè)參與者，而一個(gè)JDBC事務(wù)則被限定在一個(gè)單一的數(shù)據(jù)庫連接。下列任一個(gè)Java平臺(tái)的組件都可以參與到一個(gè)JTA事務(wù)中
分布式事務(wù)（DistributedTransaction）包括事務(wù)管理器（TransactionManager）和一個(gè)或多個(gè)支持 XA 協(xié)議的資源管理器 ( Resource Manager )。
資源管理器是任意類型的持久化數(shù)據(jù)存儲(chǔ)容器，例如在開發(fā)中常用的關(guān)系型數(shù)據(jù)庫：MySQL，Oracle等，消息中間件RocketMQ、RabbitMQ等。
事務(wù)管理器提供事務(wù)聲明，事務(wù)資源管理，同步，事務(wù)上下文傳播等功能，并且負(fù)責(zé)著所有事務(wù)參與單元者的相互通訊的責(zé)任。JTA規(guī)范定義了事務(wù)管理器與其他事務(wù)參與者交互的接口，其他的事務(wù)參與者與事務(wù)管理器進(jìn)行交互。
項(xiàng)目整體結(jié)構(gòu)圖
org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-jta-atomikos
這里jtaManager的配置，在日志輸出中非常關(guān)鍵。
spring: jta: transaction-manager-id: jtaManager # 數(shù)據(jù)源配置 datasource: type: com.alibaba.druid.pool.DruidDataSource data01: driverClassName: com.mysql.jdbc.Driver dbUrl: jdbc:mysql://localhost:3306/data-one username: root password: 000000 data02: driverClassName: com.mysql.jdbc.Driver dbUrl: jdbc:mysql://localhost:3306/data-two username: root password: 000000
這里兩個(gè)數(shù)據(jù)庫連接的配置手法都是一樣的，可以在源碼中自行下載閱讀?；舅悸范际前褦?shù)據(jù)源交給JTA組件來統(tǒng)一管理，方便事務(wù)的通信。
數(shù)據(jù)源參數(shù)
重慶分公司
重慶分公司
@Component
@ConfigurationProperties(prefix = "spring.datasource.data01")
public class DruidOneParam {
private String dbUrl;
private String username;
private String password;
private String driverClassName;
}JTA組件配置
package com.jta.source.conifg;
@Configuration
@MapperScan(basePackages = {"com.jta.source.mapper.one"},sqlSessionTemplateRef = "data01SqlSessionTemplate")
public class DruidOneConfig {
private static final Logger LOGGER = LoggerFactory.getLogger(DruidOneConfig.class) ;
@Resource
private DruidOneParam druidOneParam ;
@Primary
@Bean("dataSourceOne")
public DataSource dataSourceOne () {
// 設(shè)置數(shù)據(jù)庫連接
MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();
mysqlXADataSource.setUrl(druidOneParam.getDbUrl());
mysqlXADataSource.setUser(druidOneParam.getUsername());
mysqlXADataSource.setPassword(druidOneParam.getPassword());
mysqlXADataSource.setPinGlobalTxToPhysicalConnection(true);
// 事務(wù)管理器
AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();
atomikosDataSourceBean.setXaDataSource(mysqlXADataSource);
atomikosDataSourceBean.setUniqueResourceName("dataSourceOne");
return atomikosDataSourceBean;
}
@Primary
@Bean(name = "sqlSessionFactoryOne")
public SqlSessionFactory sqlSessionFactoryOne(
@Qualifier("dataSourceOne") DataSource dataSourceOne) throws Exception{
// 配置Session工廠
SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
sessionFactory.setDataSource(dataSourceOne);
ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
sessionFactory.setMapperLocations(resolver.getResources("classpath*:/dataOneMapper/*.xml"));
return sessionFactory.getObject();
}
@Primary
@Bean(name = "data01SqlSessionTemplate")
public SqlSessionTemplate sqlSessionTemplate(
@Qualifier("sqlSessionFactoryOne") SqlSessionFactory sqlSessionFactory) {
// 配置Session模板
return new SqlSessionTemplate(sqlSessionFactory);
}
}這里通過兩個(gè)方法測(cè)試結(jié)果做對(duì)比，在兩個(gè)數(shù)據(jù)源之間進(jìn)行數(shù)據(jù)操作時(shí)，只需要在接口方法加上 @Transactional注解即可，這樣保證數(shù)據(jù)在兩個(gè)數(shù)據(jù)源間也可以保證一致性。
@Service
public class TransferServiceImpl implements TransferService {
@Resource
private UserAccount01Mapper userAccount01Mapper ;
@Resource
private UserAccount02Mapper userAccount02Mapper ;
@Override
public void transfer01() {
userAccount01Mapper.transfer("jack",100);
System.out.println("i="+1/0);
userAccount02Mapper.transfer("tom",100);
}
@Transactional
@Override
public void transfer02() {
userAccount01Mapper.transfer("jack",200);
System.out.println("i="+1/0);
userAccount02Mapper.transfer("tom",200);
}
}以上就是“SpringBoot2中如何使用JTA組件實(shí)現(xiàn)多數(shù)據(jù)源事務(wù)管理”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家閱讀完這篇文章都有很大的收獲，小編每天都會(huì)為大家更新不同的知識(shí)，如果還想學(xué)習(xí)更多的知識(shí)，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
