Jhonse技术 2011-01-07
今天看了下公司分布式事务的源码,对分布式事务由了初步的了解,先前没有接触过着方面的思想,所以不知道其他公司是不是也是类似的设计思想。
概念
原子活动:一个业务活动有N个数据操作,而这每一个操作都是一个原子活动
业务活动:就是一个本地事务。他包含多个原子活动,他们是一个事务,是一个整体
分布式事务必须建立在本地事务的基础之上,因为分布式事务必须要回查,而前提是本地事务的结果状态是成功还是回滚,本地事务成功,则所有的原子活动都成功,反之亦然。
源码分析
在本地事务中,我们先启动分布式事务,首先会读取当前线程活动中的记录(localThread),其实也就是看看你是不是多次启动了分布式事务,多次启动肯定是不行的。
接下来,是重点了
BusinessActivityManager这个也业务活动管理器,也是分布式事务的核心管理器,他提供了一系列方法(说白了就是一些列关于业务活动和原子活动的增删锁方法),这些活动记录都会存到xts服务器的数据库,不论业务成功还是回滚,结果都是要删除的。
这里的启动方法,会把业务活动记录的状态,标示为待提交,也就是说启动成功了。
接下来的也是重点,是事务的回查,也就是分布式事务真正执行的地方
首先我们要清楚,spring有几个同步器,说白了就是AOP,这里的回查用了TransactionSynchronizationAdapter这个同步适配器,他就2个方法,beforeCompletion和afterCompletion(intstatus),这两个方法是在本地事务的完成前和完成后调用的,前者嘛也就是准备下数据,数据时什么?就是原子活动,业务活动的数据
当本地事务完成的时候,就是调用afterCompletion(intstatus)参数的意思是本地事务的状态,成功还是回滚,如果本地回滚了,所有的原子活动当然也回滚,如果成功嘛,也都成功,
这些只是初学笔记,思路熟悉下而已,还有些我暂时也没看懂,以后搞懂了,再来跟新