Sharding-JDBC目前还整合其他分布式事务模式来解决事务问题，今天就来介绍一下两阶段事务XA是如何解决分布式事务
什么是XA规范
XA 规范 是 X/Open 组织定义的分布式事务处理（DTP，Distributed Transaction Processing）标准。
XA 规范描述了全局的事务管理器与局部的资源管理器之间的接口。XA规范的目的是允许多个资源（如数据库，应用 服务器 ，消息队列等）在同一事务中访问，这样可以使ACID属性跨越应用程序而保持有效。
XA 规范使用两阶段提交来保证所有资源同时提交或回滚任何特定的事务。
XA 事务的基础是两阶段提交协议。需要有一个事务协调者来保证所有的事务参与者都完成了准备工作(第一阶段)。如果协调者收到所有参与者都准备好的消息，就会通知所有的事务都可以提交了（第二阶段）。
MySQL 在这个 XA 事务中扮演的是参与者的角色，而不是协调者(事务管理器)。
MySQL中的XA事务分为外部XA和内部XA：
基于XA规范分布式事务对业务是无侵入的，用户可以像使用本地事务一样使用基于XA规范的分布式事务。
但是基于XA规范的分布式事务属于强一致性事务，性能比较低，尤其在长事务的情况下，对资源的锁定时间较长，一般适用于短事务、低并发的场景。
MySQL中XA事务
接下来就以为MySQL中XA来演示一下，如下；
上述命令什么意思呢？解析如下：
Sharding-JDBC中的XA事务
Sharding-JDBC目前已经整合了XA事务的支持，支持的Atomikos、NARAYANA 、BITRONIX 事务的实现，默认的实现是Atomikos。下面将以Atomikos为例子介绍一下Sharding-JDBC如何实现XA事务
SharingSphere是通过SPI的方式去定制分布式事务解决方案的，XA的默认实现是org.apache.shardingsphere.transaction.xa.XAShardingTransactionManager，有兴趣的可以看下其中源码
后文介绍到的弱一致性事务使用Seata的AT模式，对应的是org.apache.shardingsphere.transaction.base.seata.at.SeataATShardingTransactionManager
当然Seata也是支持XA事务，如果后续改写的话，可以通过SPI的方式的定制
1. 添加依赖
使用XA事务需要添加一个依赖，如下：
dependencygroupIdorggroupIdartifactIdshardingtransactionxacoreartifactIddependency
可以看到这个依赖中内置了ATOMIKOS，如下：
2. 配置事务管理器
使用事务之前当然需要配置一个事务管理器，这里和Spring Boot 中配置没差别，如下：
@Configuration@EnableTransactionManagementpublic class TransactionConfiguration @Beanpublic PlatformTransactionManager txManagerfinal>)return new>(DataSource
3. @ShardingTransactionType注解
想要开启XA分布式事务还需要使用一个注解@ShardingTransactionType，其中的value属性的值如下：
那么显然这里只需要配置TransactionType.XA就能开启XA事务的支持
伪代码如下：
@ShardingTransactionTypevalue TransactionType@Transactionalpublic void method跨库操作..............
4. 启动测试
演示的源码请看视频教程中的源码，需要注意的是Atomikos会在项目的logs目录下生成xa_tx.log文件，其中记录了事务日志，在XA崩溃恢复时所需要的日志，一定不要删除
对于Atomikos的一些配置可以通过在项目的classpath中添加jta.properties来定制化Atomikos配置项，这里就不再给大家详细介绍了。
spring boot 怎么解析 application.yml
看下中的注解呢
Connection和 DataSource 的关系?
你好，Connectiong Pools是连接池，连接池有很多种。 数据源连接池只能算里面的一种，比如还有线程连接池等等。 连接池，主要就是把创建和销毁工作，用一种类似于借和还的概念来代替。 DataSource是数据源。 就是数据的源头。 两个是不同的概念，但是经常要结合工作。
spring事务@Transaction注解配置回滚为什么失败
你说的没有回滚是不是testTransaction(TestModel testModel)这个方法没有整体提交或回滚。 你现在的代码和spring的事务配置是不配套的。 在spring配置中一个事务单元是一个方法。 就是说UpdateData(long id)是一个事务管理
发表评论