栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

atomikos实现分布式事务

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

atomikos实现分布式事务

概述

多数据源单服务写入, 分布式事务实现

使用随机数控制产生异常

注: 网上很多都是只有多数据源配置,实际不能控制事务统一回滚,
单服务场景下如果多个数据源只有一个写,剩下都是读, 则不需要分布式事务

为减少篇幅,详细代码在代码仓库,可自行参考

版本

springboot 2.1.7.RELEASE

配置引入

  org.springframework.boot
  spring-boot-starter-data-jpa



  mysql
  mysql-connector-java



  org.springframework.boot
  spring-boot-starter-jta-atomikos

增加配置类

AtomikosJtaPlatform

JPAAtomikosTransactionConfig Atomikos事务配置类

PrimaryConfig 主数据源配置

SecondaryConfig 其它数据源配置

数据对象实现

User

增加仓储实现

需要分别实现primary和secondary, 从而支持多个数据源访问

PrimaryUserRepository

SecondaryUserRepository

实现服务类

PrimaryUserService

SecondaryUserService

ExampleService

负责统一调用 PrimaryUserService 和 SecondaryUserService,
模拟一个服务同时访问多个服务类(每个服务类引用了不同数据源)

如果其中某个服务抛出异常,则整个事务回滚, @Transactional(rollbackOn =
Exception.class) 是必须的

测试

com.example.springbootatomikos.services.UserServiceTest#testSave

代码

github地址

gitee地址

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/838631.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号