之前项目小的时候,咱们都是一个数据库,使用数据库级别的锁就可以保证事物的一致性,但是随着业务越来越多,数据量越来越大,导致了分库分表的出现,之前的公司原本流量比较小,只有一个项目,没涉及到分布式项目,数据库只有一个,处理起来得心应手,突然有一天,老板改变了思路,要扩张,又不想招人,怎嘛办,只能外包,做了另外一套系统,人家单独使用的数据库,刚开始没有问题,因为都是外包做的,我们只需要调用接口,但是后来,有一些业务需要涉及到另一个库的数据,需要我们集成进来,我们就开始干,弄完了,忽然有一天,发现一个问题我A库的一条记录插入success,但是B库的操作异常了,想当然的以为会一起失败,可是却没有,这才恍然大悟,不在一个库,本地事物已经不起作用了哇,所以就得解决啊!
从本期开始,我就将分布式事务写一个专栏,从开源版本的atomikos 解决分布式事务到rocketmq解决分布式事务,到最后的阿里开源的seata来谈一谈分布式事务的发展,今天是第一期,废话不多说,咱们直接上代码
现在有这样一个需求,我一个项目中同时连了两个数据源,如何保证事物一致性,今天的主角,atomikos
Atomikos公司官方网址为：https://www.atomikos.com/。其旗下最著名的产品就是事务管理器。产品分两个版本：
TransactionEssentials：开源的免费产品
ExtremeTransactions：上商业版，需要收费。
当然咱们用的免费版哈,直接上代码啦
第一步:引入依赖
第二步:修改配置文件
两个不同的数据源
接下来配置config,让spring进行加载,网上的例子很多,不做赘述
MyBatisConfig1的配置
MyBatisConfig2的配置
值得注意的是如果启动出现invalid bound statement (not found)异常,就加入这个配置
第三步:配置事物管理器
第四步:这个service中,我们加入transactional注解来操作,A库的表出款100元,B库的表增加100元
第五步:启动项目
如果看到如下所示,表示启动成功
这里注意,配置文件的配置项一定要和DBconfig一一对应,否则启动是么有问题,但是访问回报空指针异常
第六步:执行访问
访问之前看看数据库的记录
A库里面有一条张三的记录
执行请求
看看数据库的变化
张三减少100元
李四增加100元
接下来模拟异常的情况,在两个业务之间模拟异常,先还原数据库数据
再次访问看看有没有变化哈
都抛出了异常
我们去看看数据有没有变化
没有变化,证明分布式事务success,
大家在运行的时候,不雅debug断电调试运行,否则事务会失效
今天先分享到这里,下一期,我们会一起从源码的角度看看到底是怎么做到不同数据源一起回滚的,Thanks
网友评论