springboot jta atomikos实现分布式事物管理
这篇文章主要介绍了springbootjtaatomikos实现分布式事物管理,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
当项目在连接多个数据库时可能会发生事务问题,即一个库的事务不可能去操作另一个数据库的事务,这时就需要使用atomikos对数据库的事务进行统一的管理
第一步添加atomikos的依赖
org.springframework.boot spring-boot-starter-jta-atomikos
第二步配置数据源,我这里有2个数据库(ruan和youxianqi),你有多少就加多少。
spring: datasource: system: jdbc-url:jdbc:oracle:thin:@localhost:1521/orcl driver-class-name:oracle.jdbc.OracleDriver username:yuan password:1234 initial-size:5 min-idle:5 max-active:20 min-evictable-idle-time-millis:300000 validation-query:SELECT1FROMDUAL test-while-idle:true kllogt: jdbc-url:jdbc:oracle:thin:@localhost:1521/orcl driver-class-name:oracle.jdbc.OracleDriver username:youxianqi password:youxianqi initial-size:5 min-idle:5 max-active:20 min-evictable-idle-time-millis:300000 validation-query:SELECT1FROMDUAL test-while-idle:true logging: level: org.springframework.web:debug
然后创建DBConfig1和DBConfig2,这两个实体类就是存放两个数据源的数据的。
packagecom.cgb.config; importorg.springframework.boot.context.properties.ConfigurationProperties; @ConfigurationProperties(prefix="spring.datasource.system") publicclassDBConfig1{ privateStringjdbc-url; privateStringusername; privateStringpassword; privateintminPoolSize; privateintmaxPoolSize; privateintmaxLifetime; privateintborrowConnectionTimeout; privateintloginTimeout; privateintmaintenanceInterval; privateintmaxIdleTime; privateStringtestQuery; publicStringgetJdbc-url(){ returnurl; } publicvoidsetJdbc-url(Stringjdbc-url){ this.jdbc-url=jdbc-url; } publicStringgetUsername(){ returnusername; } publicvoidsetUsername(Stringusername){ this.username=username; } publicStringgetPassword(){ returnpassword; } publicvoidsetPassword(Stringpassword){ this.password=password; } publicintgetMinPoolSize(){ returnminPoolSize; } publicvoidsetMinPoolSize(intminPoolSize){ this.minPoolSize=minPoolSize; } publicintgetMaxPoolSize(){ returnmaxPoolSize; } publicvoidsetMaxPoolSize(intmaxPoolSize){ this.maxPoolSize=maxPoolSize; } publicintgetMaxLifetime(){ returnmaxLifetime; } publicvoidsetMaxLifetime(intmaxLifetime){ this.maxLifetime=maxLifetime; } publicintgetBorrowConnectionTimeout(){ returnborrowConnectionTimeout; } publicvoidsetBorrowConnectionTimeout(intborrowConnectionTimeout){ this.borrowConnectionTimeout=borrowConnectionTimeout; } publicintgetLoginTimeout(){ returnloginTimeout; } publicvoidsetLoginTimeout(intloginTimeout){ this.loginTimeout=loginTimeout; } publicintgetMaintenanceInterval(){ returnmaintenanceInterval; } publicvoidsetMaintenanceInterval(intmaintenanceInterval){ this.maintenanceInterval=maintenanceInterval; } publicintgetMaxIdleTime(){ returnmaxIdleTime; } publicvoidsetMaxIdleTime(intmaxIdleTime){ this.maxIdleTime=maxIdleTime; } publicStringgetTestQuery(){ returntestQuery; } publicvoidsetTestQuery(StringtestQuery){ this.testQuery=testQuery; } }
然后创建两个数据源RuanMyBatisConfig和YouMyBatisConfig,注意@Primary注解只能有一个。
packagecom.cgb.datasource; importjava.sql.SQLException; importjavax.sql.DataSource; importorg.apache.ibatis.session.SqlSessionFactory; importorg.mybatis.spring.SqlSessionFactoryBean; importorg.mybatis.spring.SqlSessionTemplate; importorg.mybatis.spring.annotation.MapperScan; importorg.springframework.beans.factory.annotation.Qualifier; importorg.springframework.context.annotation.Bean; importorg.springframework.context.annotation.Configuration; importorg.springframework.context.annotation.Primary; importcom.atomikos.jdbc.AtomikosDataSourceBean; importcom.cgb.config.DBConfig1; importcom.mysql.jdbc.jdbc2.optional.MysqlXADataSource; @Configuration @MapperScan(basePackages="com.cgb.ruan",sqlSessionTemplateRef="testSqlSessionTemplate") publicclassRuanMyBatisConfig{ //配置数据源 @Primary @Bean(name="dataSource1") publicDataSourcetestDataSource(DBConfig1testConfig)throwsSQLException{ MysqlXADataSourcemysqlXaDataSource=newMysqlXADataSource(); mysqlXaDataSource.setUrl(testConfig.getUrl()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); mysqlXaDataSource.setPassword(testConfig.getPassword()); mysqlXaDataSource.setUser(testConfig.getUsername()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); AtomikosDataSourceBeanxaDataSource=newAtomikosDataSourceBean(); xaDataSource.setXaDataSource(mysqlXaDataSource); xaDataSource.setUniqueResourceName("dataSource1"); 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()); returnxaDataSource; } @Bean(name="testSqlSessionFactory") publicSqlSessionFactorytestSqlSessionFactory(@Qualifier("dataSource1")DataSourcedataSource) throwsException{ SqlSessionFactoryBeanbean=newSqlSessionFactoryBean(); bean.setDataSource(dataSource); returnbean.getObject(); } @Bean(name="testSqlSessionTemplate") publicSqlSessionTemplatetestSqlSessionTemplate( @Qualifier("testSqlSessionFactory")SqlSessionFactorysqlSessionFactory)throwsException{ returnnewSqlSessionTemplate(sqlSessionFactory); } }
其实在多个数据源的时候,我们怎么去指定数据库呢?
其中一个做法是写注解,表明使用哪个数据库,但是这种是不是很麻烦。最好的做法是分包管理:
好啦,大功告成,我们来看看效果吧。
我们发现控制台打印添加学生成功,好我们看看数据库里有没有数据呢?
毫无疑问是没有的,说明事务起作用了。那我们把那行异常代码注释掉,再看看效果。成功了,去看看数据库有没有呢。
ojbk,想想同时操作多个数据库,是不是很爽啊,哈哈哈。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。