最新要闻
- 洞庭连天是什么意思?洞庭连天九疑高是什么生肖?
- 国庆一词最早出现在什么时候?国庆一词最早出现在什么地方?
- 蝴蝶发现花蜜靠的是什么?蝴蝶发现花蜜的句子有哪些?
- 造梦西游3金角大王怎么打?造梦西游3金角大王掉什么?
- 传闻中的陈芊芊韩烁失忆是第几集?传闻中的陈芊芊韩烁失忆是真的吗?
- 爱情公寓决战紫禁之巅是第几集?爱情公寓决战紫禁之巅花了多少经费?
- 曾小莲是什么梗?爱情公寓曾小莲是哪一集?
- 睢宁县属于哪个市?睢宁县旅游景点有哪些?
- 类似于惊天魔盗团的电影有哪些?惊天魔盗团剧情解析
- 独家首发是什么意思?独家首发和普通授权有什么区别?
- 美国一战机垂直降落失控 飞行员弹射7秒落地:现场机头先撞地
- 世界时讯:可拆卸手柄神似Switch!OnexPlayer 2掌机海外发布:起售价超6200元
- 全球要闻:混动车鼻祖上新 全新丰田普锐斯售价公布:约19.10万元起
- 一加10T漫威限定版上架:用4年仍然很流畅 4700元
- 天天观焦点:三连降稳了!新一轮油价三天后开调:预计下跌0.41元/升
- 世界资讯:因MacBook Pro蝶式键盘翻车:苹果赔了3个多亿
手机
iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
- 警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- 男子被关545天申国赔:获赔18万多 驳回精神抚慰金
- 3天内26名本土感染者,辽宁确诊人数已超安徽
- 广西柳州一男子因纠纷杀害三人后自首
- 洱海坠机4名机组人员被批准为烈士 数千干部群众悼念
家电
【聚看点】多数据源事务处理-涉及分布式事务
在作者之前的 十二条后端开发经验分享,纯干货 文章中介绍的 优雅得Springboot + mybatis配置多数据源方式
里有很多小伙伴在评论区留言询问多个数据源同时在一个方法中使用时,事务是否会正常有效,这里作者 理论 + 实践
给大家解答一波,老规矩,附作者github地址:
(相关资料图)
- https://github.com/wayn111
一. 数据源跨库但是不跨 MySql
实例
这个形式就是数据源在同一个 MySQL
下,但是 jdbc-url
上的数据库配置不同,涉及多个数据库时,如果方法中发生异常,只有开启事务的数据源会发生回滚,其他数据源不会回滚。看到这里可能有点迷惑,什么是 只有开启事务的数据源会发生回滚,其他数据源不会回滚?
下面给出代码验证:
主数据源配置
@Slf4j@EnableTransactionManagement@EnableAspectJAutoProxy@Configuration@MapperScan(basePackages = "ltd.newbee.mall.core.dao", sqlSessionFactoryRef = "masterSqlSessionFactory")public class Db1DataSourceConfig { @Primary @Bean @ConfigurationProperties("spring.datasource.druid.master") public DataSource masterDataSource(DruidProperties druidProperties) { DruidDataSource build = DruidDataSourceBuilder.create().build(); return druidProperties.dataSource(build); } /** * @param datasource 数据源 * @return SqlSessionFactory * @Primary 默认SqlSessionFactory */ @Primary @Bean(name = "masterSqlSessionFactory") public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource datasource, Interceptor interceptor) throws Exception { MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean(); bean.setDataSource(datasource); // mybatis扫描xml所在位置 bean.setMapperLocations(new PathMatchingResourcePatternResolver() .getResources("classpath*:mapper/*.xml")); bean.setTypeAliasesPackage("ltd.**.core.entity"); bean.setPlugins(interceptor); GlobalConfig globalConfig = new GlobalConfig(); GlobalConfig.DbConfig dbConfig = new GlobalConfig.DbConfig(); dbConfig.setLogicDeleteField("isDeleted"); dbConfig.setLogicDeleteValue("1"); dbConfig.setLogicNotDeleteValue("0"); globalConfig.setDbConfig(dbConfig); bean.setGlobalConfig(globalConfig); log.info("masterDataSource 配置成功"); return bean.getObject(); } @Primary @Bean(name = "masterTransactionManager") public DataSourceTransactionManager masterTransactionManager(@Qualifier("masterDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); }}
从数据源配置
@Slf4j@ConditionalOnProperty(value = "transactional.mode", havingValue = "seata")@EnableTransactionManagement@EnableAspectJAutoProxy@Configuration@MapperScan(basePackages = "ltd.newbee.mall.slave.dao", sqlSessionFactoryRef = "slaveSqlSessionFactory")public class Db2DataSourceConfig { @Bean @ConfigurationProperties("spring.datasource.druid.slave") public DataSource slaveDataSource(DruidProperties druidProperties) { DruidDataSource build = DruidDataSourceBuilder.create().build(); return druidProperties.dataSource(build); } /** * @param datasource 数据源 * @return SqlSessionFactory * @Primary 默认SqlSessionFactory */ @Bean(name = "slaveSqlSessionFactory") public SqlSessionFactory slaveSqlSessionFactory(@Qualifier("slaveDataSource") DataSource datasource, Interceptor interceptor) throws Exception { MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean(); bean.setDataSource(datasource); // mybatis扫描xml所在位置 bean.setMapperLocations(new PathMatchingResourcePatternResolver() .getResources("classpath*:slavemapper/*.xml")); bean.setTypeAliasesPackage("ltd.**.slave.entity"); bean.setPlugins(interceptor); GlobalConfig globalConfig = new GlobalConfig(); GlobalConfig.DbConfig dbConfig = new GlobalConfig.DbConfig(); dbConfig.setLogicDeleteField("isDeleted"); dbConfig.setLogicDeleteValue("1"); dbConfig.setLogicNotDeleteValue("0"); globalConfig.setDbConfig(dbConfig); bean.setGlobalConfig(globalConfig); log.info("slaveDataSource 配置成功"); return bean.getObject(); } @Bean(name = "slaveTransactionManager") public DataSourceTransactionManager slaveTransactionManager(@Qualifier("slaveDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); }}
划重点-上述代码在每个数据源中都配置了 DataSourceTransactionManager
(事务管理器),并且在主配置中添加 @Primary
注解,表示默认事务管理器优先使用主数据源的事务管理器。下面给出测试代码:
/** * Springboot测试类 */@Slf4j@SpringBootTest@RunWith(SpringRunner.class)public class MultiDataSourceTest { @Autowired private MultiDataService multiDataService; @Test public void testRollback() { multiDataService.testRollback(); }}/** * MultiDataService实现类 */@Slf4j@Servicepublic class MultiDataServiceImpl implements MultiDataService { @Autowired private TbTable1Service tbTable1Service; @Autowired private TbTable2Service tbTable2Service; @Autowired private PlatformTransactionManager transactionManager; @Override public void testRollback() { DefaultTransactionDefinition transactionDefinition = new DefaultTransactionDefinition(); TransactionStatus transaction = transactionManager.getTransaction(transactionDefinition); try { TbTable1 tbTable1 = new TbTable1(); tbTable1.setName("test1"); // 插入table1表 boolean save1 = tbTable1Service.save(tbTable1); TbTable2 tbTable2 = new TbTable2(); tbTable2.setName("test2"); // 插入table2表 boolean save2 = tbTable2Service.save(tbTable2); int i = 1 / 0; transactionManager.commit(transaction); Assert.isTrue(save1 && save2); } catch (Exception e) { log.info(e.getMessage(), e); transactionManager.rollback(transaction); } }}
执行结果:table1表回滚成功,table2表回滚失败。由此结果,对于 只有开启事务的数据源会发生回滚,其他数据源不会回滚?
我们的解释就是 Spring
中默认使用的事务管理器是使用主数据源配置还是从数据源配置由我们通过 @Primary
决定,当我们把 @Primary
切换在从数据源配置上,执行结果:table2表回滚成功,table1表回滚失败。那怎么解决这个问题?
当涉及到跨库或者跨 MySQL
实例,想要保证事务操作,我们这里先给出XA
事务解决方案。附 XA
事务的说明:
XA 是由 X/Open 组织提出的分布式事务规范,XA 规范主要定义了事务协调者(Transaction Manager)和资源管理器(Resource Manager)之间的接口。
事务协调者(Transaction Manager),因为 XA 事务是基于两阶段提交协议的,所以需要有一个协调者,来保证所有的事务参与者都完成了准备工作,也就是 2PC 的第一阶段。如果事务协调者收到所有参与者都准备好的消息,就会通知所有的事务都可以提交,也就是 2PC 的第二阶段。
资源管理器(Resource Manager),负责控制和管理实际资源,比如数据库。
(划重点)XA 的 MySQL 实现使 MySQL 服务器能够充当资源管理器,在全局事务中处理 XA 事务。连接到 MySQL 服务器的客户端程序充当事务协调者
XA 事务的执行流程
XA 事务是两阶段提交的一种实现方式,根据 2PC 的规范,XA 将一次事务分割成了两个阶段,即 Prepare 和 Commit 阶段。
Prepare 阶段,TM 向所有 RM 发送 prepare 指令,RM 接受到指令后,执行数据修改和日志记录等操作,然后返回可以提交或者不提交的消息给 TM。如果事务协调者 TM 收到所有参与者都准备好的消息,会通知所有的事务提交,然后进入第二阶段。
Commit 阶段,TM 接受到所有 RM 的 prepare 结果,如果有 RM 返回是不可提交或者超时,那么向所有 RM 发送 Rollback 命令;如果所有 RM 都返回可以提交,那么向所有 RM 发送 Commit 命令,完成一次事务操作。
下面给出两种基于 XA
事务的解决方案:
Springboot
项目中可以使用jta
,完成对XA
协议的支持,缺点就是jta
需要改造数据源配置Springboot
项目引入seata
,seata
支持XA
协议,且引入seata-spring-boot-starter
依赖对业务无侵入,缺点需要引入seata-server
降低了系统可用性
Springboot
项目中可以启用 jta
- 引入
spring-boot-starter-jta-atomikos
org.springframework.boot spring-boot-starter-jta-atomikos
- 修改主从数据源
DataSource
配置,进行包装添加XA
数据源支持,如下;
@Primary @Bean @ConfigurationProperties("spring.datasource.druid.master") public DataSource dataSource(DruidProperties druidProperties) { DruidXADataSource dataSource = druidProperties.dataSource(new DruidXADataSource()); dataSource.setUrl("jdbc:mysql://localhost:3306/xxx?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8"); dataSource.setUsername("root"); dataSource.setPassword(""); dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver"); AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean(); atomikosDataSourceBean.setXaDataSourceClassName("com.alibaba.druid.pool.xa.DruidXADataSource"); atomikosDataSourceBean.setUniqueResourceName("master-xa"); atomikosDataSourceBean.setXaDataSource(dataSource); return atomikosDataSourceBean; }
- 添加
JtaTransactionManager
@Beanpublic JtaTransactionManager transactionManager() throws Exception { JtaTransactionManager transactionManager = new JtaTransactionManager(); UserTransactionManager userTransactionManager = new UserTransactionManager(); userTransactionManager.setForceShutdown(true); userTransactionManager.setTransactionTimeout(3000); transactionManager.setUserTransaction(userTransactionManager); transactionManager.setAllowCustomIsolationLevels(true); return transactionManager;}
- 完成测试,代码如下:
/** * Springboot测试类 */@Slf4j@SpringBootTest@RunWith(SpringRunner.class)public class MultiDataSourceTest { @Autowired private MultiDataService multiDataService; @Test public void jtaTestRollback() { multiDataService.jtaTestRollback(); }}/** * MultiDataService实现类 */@Slf4j@Servicepublic class MultiDataServiceImpl implements MultiDataService { @Autowired private TbTable1Service tbTable1Service; @Autowired private TbTable2Service tbTable2Service; @Autowired private JtaTransactionManager jtaTransactionManager; @Override public void jtaTestRollback() { DefaultTransactionDefinition transactionDefinition = new DefaultTransactionDefinition(); TransactionStatus transaction = jtaTransactionManager.getTransaction(transactionDefinition); try { TbTable1 tbTable1 = new TbTable1(); tbTable1.setName("test1"); boolean save1 = tbTable1Service.save(tbTable1); TbTable2 tbTable2 = new TbTable2(); tbTable2.setName("test2"); boolean save2 = tbTable2Service.save(tbTable2); int i = 1 / 0; jtaTransactionManager.commit(transaction); Assert.isTrue(save1 && save2); } catch (Exception e) { log.info(e.getMessage(), e); jtaTransactionManager.rollback(transaction); } }}
可以看到我们使用的是 JtaTransactionManager
, 执行结果:table1表回滚成功,table2表回滚成功。验证OK
引入 seata
,添加XA协议支持
- 下载安装启动
seata-server
,这里给出官网教程:https://seata.io/zh-cn/docs/ops/deploy-guide-beginner.html - 在 Springboot中引入seata最新依赖
io.seata seata-spring-boot-starter 1.5.2
- 在yml文件中添加
seata
配置
seata: config: type: file registry: type: file application-id: newbeemall # Seata 应用编号,默认为 ${spring.application.name} tx-service-group: newbeemall-group # Seata 事务组编号,用于 TC 集群名 # 服务配置项,对应 ServiceProperties 类 service: # 虚拟组和分组的映射 vgroup-mapping: newbeemall-group: default # 分组和 Seata 服务的映射 grouplist: default: 127.0.0.1:8091 data-source-proxy-mode: XA enabled: true
- 完成测试,代码如下:
/** * Springboot测试类 */@Slf4j@SpringBootTest@RunWith(SpringRunner.class)public class MultiDataSourceTest { @Autowired private MultiDataService multiDataService; @Test public void seataTestRollback() { multiDataService.seataTestRollback(); }}/** * MultiDataService实现类 */@Slf4j@Servicepublic class MultiDataServiceImpl implements MultiDataService { @Autowired private TbTable1Service tbTable1Service; @Autowired private TbTable2Service tbTable2Service; @GlobalTransactional @Override public void seataTestRollback() { log.info("当前 XID: {}", RootContext.getXID()); TbTable1 tbTable1 = new TbTable1(); tbTable1.setName("test1"); boolean save1 = tbTable1Service.save(tbTable1); TbTable2 tbTable2 = new TbTable2(); tbTable2.setName("test2"); boolean save2 = tbTable2Service.save(tbTable2); int i = 1 / 0; }}
如上代码,使用 seata
时需要启用 @GlobalTransactional
注解,并且在事务中传递 XID
( RootContext.getXID()
),执行结果:table1表回滚成功,table2表回滚成功。验证OK
二. 数据源分布在不同 MySql
实例
当数据源分布在不同 MySql
实例时,这时候其实已经进入分布式事务的范畴,由上可知,XA
事务可以解决分布式环境下事务问题,也就是说上述最后两种解决方案都可以解决分布式事务问题,但是实际使用过程中,我们建议使用 seata
,理由是他不仅支持 XA
事务还支持 AT、Saga、TCC
事务模型。引入 seata
官网介绍
Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式,为用户打造一站式的分布式解决方案。
总结
关于多数据源事务的问题,不管跨不跨库其实都属于分布式事务的问题。推荐使用 seata
解决。
实践代码放在newbeemall项目:https://github.com/wayn111/newbee-mall/tree/springboot2.7 分支下
欢迎大家点赞、关注、评论,想要跟作者沟通技术问题的话可以加我微信【waynaqua】,欢迎大家前来交流。
【聚看点】多数据源事务处理-涉及分布式事务
怎么硬盘安装ubuntu?硬盘ubuntu安装教程
佳能5d系列哪个最好?佳能5DX相机参数
诺基亚6200上市价格是多少?诺基亚6200手机参数
烤箱如何预热?烤箱预热的方法有哪些?
短讯!IDEA没有新建jsp文件按钮
VS2022生成控制台引用程序,.net应用导出成exe文件,发部成独立文件的详细图解
MySQL学习笔记2
网页字体变大是怎么回事?网页字体变大了怎么还原?
洞庭连天是什么意思?洞庭连天九疑高是什么生肖?
国庆一词最早出现在什么时候?国庆一词最早出现在什么地方?
蝴蝶发现花蜜靠的是什么?蝴蝶发现花蜜的句子有哪些?
造梦西游3金角大王怎么打?造梦西游3金角大王掉什么?
传闻中的陈芊芊韩烁失忆是第几集?传闻中的陈芊芊韩烁失忆是真的吗?
爱情公寓决战紫禁之巅是第几集?爱情公寓决战紫禁之巅花了多少经费?
曾小莲是什么梗?爱情公寓曾小莲是哪一集?
睢宁县属于哪个市?睢宁县旅游景点有哪些?
类似于惊天魔盗团的电影有哪些?惊天魔盗团剧情解析
独家首发是什么意思?独家首发和普通授权有什么区别?
环球短讯!认证管理(锐捷网关篇)
世界即时看!C语言字符串拆分的两种方式strtok和正则表达式
全球通讯!低代码靠不靠谱?看看低代码在智能物联系统搭建中的应用
美国一战机垂直降落失控 飞行员弹射7秒落地:现场机头先撞地
世界时讯:可拆卸手柄神似Switch!OnexPlayer 2掌机海外发布:起售价超6200元
全球要闻:混动车鼻祖上新 全新丰田普锐斯售价公布:约19.10万元起
一加10T漫威限定版上架:用4年仍然很流畅 4700元
天天观焦点:三连降稳了!新一轮油价三天后开调:预计下跌0.41元/升
世界资讯:因MacBook Pro蝶式键盘翻车:苹果赔了3个多亿
速递!贾跃亭造车梦要成了?FF91交付计划公布 还差10几亿资金
全球热议:爱奇艺VIP会员今起涨价:连续包月黄金25元/月
今日热讯:浙江“火流星”现场被砸大坑!专家:捡到陨石碎片别用水清洗
焦点精选!机械硬盘真没人买!西数股价大跌 公司业绩要暴雷:或将大清库存
每日精选:V2Board机场项目泄露400余万条数据
环球快报:《阿凡达2:水之道》今日内地正式上映:票房瞬间破亿
日系车为什么在中国卖不动了?你为什么不买了?
每日速讯:Blazor和Vue对比学习(进阶.路由导航五):路由守卫
观点:【从零开始学爬虫】采集收视率排行数据
mvn 打包报错:no compiler is provided in this environment
天天微动态丨JavaScript DOM的性能优化详解
每日资讯:VUE的实例的生命周期
每日热门:河洛肉鸽卡牌《天外武林》上架Steam 明年1月发售
别急换机!本月还有6场发布会:劝你先等等再买
世界微动态丨《阿凡达:水之道》预测票房仅25.11亿!远不到《长津湖》一半
【环球新要闻】Epic大促开启 连续15天免费送游戏!75折套娃优惠券来了
【天天播资讯】RTX 4070 Ti跑分首曝:猛升46%、超越RX 7900 XTX
焦点热讯:替代if esle 的高级方法
make学习
天天热门:高手必备10大难题:Mysql如何实现RR级隔离时,不会幻读?
FreeSWITCH学习笔记:应用程序(APP)
速度飞起!全球首款232层闪存SSD细节公布:TLC颗粒、拒绝PCIe 5.0
快资讯:一图看懂moto新机:二代骁龙8 3699元!价格屠夫简直了
全球观察:7-2 案例 字符串关键字的散列映射
天天热议:微软2025年目标:确保非洲再增加1亿人访问互联网
焦点信息:火球坠入浙江 警方带走疑似陨石碎片:现场砸出六七厘米深坑
环球微头条丨初始Docker
热点评!分智慧果 - 2021算法与数据结构实验题
环球观热点:不调好不上市 moto X40驯服二代骁龙8:1小时王者温度仅42度
Nature年度十大人物出炉:猪心移植手术团队负责人等入选
饱满如水滴!联想moto X40开箱图赏
5000mAh大电池+120Hz屏 899元联想moto G53图赏
109度大电池能跑730KM!岚图追光预售:32.29万元起
天天微动态丨自研分布式高性能RPC框架及服务注册中心ApiRegistry实践笔记【原创】【开源】
【独家】图形用户界面(GUI)编程可以学习C++ Builder,多图、实例、书籍
17 Java内存模型与线程_Java与线程
视焦点讯!努比亚Z50散热堆料离谱:散热总面积达到36462m㎡
中国光纤之父赵梓森逝世 享年91岁:拉出了我国第一根光纤
世界观热点:苹果妥协了!将开门迎接第三方应用商店 用户褒贬不一
杭州疑似有陨石掉落:一团火球 照亮夜空
环球要闻:AIRIOT答疑第2期|如何使用物联网平台的数据采集与控制引擎?
《隐秘的角落》游戏来了:Steam版定档明年1月18日
【时快讯】可以薅羊毛了!网易云音乐TV版正式上线:免费送3个月会员
天天快报!男子花12万买世界杯彩票没中要求退款 理由气煞店老板
天天热头条丨微信全新朋友圈点赞互动广告上线:点下就能放烟花秀
天天热资讯!下单15分钟送到:上海开通首条美团无人机常态化航线
世界速读:BaseDet: 走过开发的弯路
今日热门!引迈信息荣登「2022低代码企业50强」:JNPF,你的不二选择!
环球关注:IMDb 8.2分!《阿凡达2》口碑爆棚 影院回应票价高:消费者不缺钱缺服务
OPPO Find N2 Flip外屏惊艳:支持快捷回复、锁屏小游戏
第二家通吃NVIDIA、AMD、Intel的显卡品牌诞生!这也太贵了
天天实时:公牛发布航天级品质超薄插座:可承受2万次拔插
环球微头条丨跌破零下40度!内蒙古出现极寒冰雾天气:冷到“冒白烟”
环球微速讯:SQL的使用总结
天天快资讯:WPF深入简出(一)入门必看
观热点:【机器学习】李宏毅——浅谈机器学习原理+鱼与熊掌兼得的深度学习简述
当前动态:前后端AES加密解密,CryptoJS和Java实现
热讯:记录--手把手带你开发一个uni-app日历插件(并发布)
OPPO Find N成为全国销量第二折叠屏!一经发布就大获成功
微速讯:首次使用钛合金螺丝!OPPO Find N2仅233g:折叠屏比iPhone还轻
OPPO Find N2内外一致好屏:双120Hz+双E6 可自由悬停
让玩家心动的定制 ROG 6游戏手机《暗黑破坏神:不朽》典藏限量版图赏
OPPO Find N2 233g比直板机还轻!央视点赞:刷新折叠屏手机新纪录
【世界速看料】LeetCode HOT 100:旋转图像
环球头条:特斯拉中国上线490元酒杯 限量卖 网友吐槽智商税
世界今日讯!女子连吃5天感冒药 多脏器功能衰竭:专家提醒小心这些症状
IT工程师哪里工资最高?美国仅排第二 第一收入超过70万
天天看热讯:帧数暴涨40%!《巫师3》次时代版画质优化指南
20万级大杀器 长安深蓝首款SUV曝光:增程、纯电全都有
【天天速看料】Shell 标准输入和输出
信息:公司新来一个同事,把网关系统设计的炉火纯青!(万能通用,稳的一批。。)
当前视讯!易基因|NSUN2介导RNA m5C修饰促进食管鳞状细胞癌进展的表观调控机制 | 肿瘤研究