ShardingDataSource已经整合了分布式事务的功能,因此不需要用户进行额外的配置,每次获取ShardingConnection前,通过修改TransactionTypeHolder
,可以对事务类型进行切换。
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>sharding-transaction-xa-core</artifactId>
<version>${shardingsphere.version}</version>
</dependency>
TransactionTypeHolder.set(TransactionType.XA);
ShardingSphere默认的XA事务管理器为Atomikos,在项目的logs目录中会生成xa_tx.log
, 这是XA崩溃恢复时所需的日志,请勿删除。
也可以通过在项目的classpath中添加jta.properties
来定制化Atomikos配置项。具体的配置规则请参考Atomikos的官方文档。
ShardingSphere中已经整合了Saga和Seata两种BASE类型的事务
<!-- saga柔性事务 -->
<dependency>
<groupId>io.shardingsphere</groupId>
<artifactId>sharding-transaction-base-saga</artifactId>
<version>${shardingsphere-spi-impl.version}</version>
</dependency>
${shardingsphere-spi-impl.version} 的jar暂未发布到maven中央仓,因此需要您根据源码自行部署。项目地址: shardingsphere-spi-impl
<!-- seata柔性事务 -->
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>sharding-transaction-base-seata-at</artifactId>
<version>${sharding-sphere.version}</version>
</dependency>
TransactionTypeHolder.set(TransactionType.BASE);
可以通过在项目的classpath中添加saga.properties
来定制化Saga事务的配置项。当saga.persistence.enabled=true时,事务日志默认按JDBC的方式持久化到数据库中,也可以通过实现io.shardingsphere.transaction.saga.persistence.SagaPersistence
SPI,支持定制化存储,具体可参考项目sharding-transaction-base-saga-persistence-jpa。
配置项的属性及说明如下:
属性名称 | 默认值 | 说明 |
---|---|---|
saga.actuator.executor.size | 5 | 使用的线程池大小 |
saga.actuator.transaction.max.retries | 5 | 失败SQL的最大重试次数 |
saga.actuator.compensation.max.retries | 5 | 失败SQL的最大尝试补偿次数 |
saga.actuator.transaction.retry.delay.milliseconds | 5000 | 失败SQL的重试间隔,单位毫秒 |
saga.actuator.compensation.retry.delay.milliseconds | 3000 | 失败SQL的补偿间隔,单位毫秒 |
saga.persistence.enabled | false | 是否对日志进行持久化 |
saga.persistence.ds.url | 无 | 事务日志数据库JDBC连接 |
saga.persistence.ds.username | 无 | 事务日志数据库用户名 |
saga.persistence.ds.password | 无 | 事务日志数据库密码 |
saga.persistence.ds.max.pool.size | 50 | 事务日志连接池最大连接数 |
saga.persistence.ds.min.pool.size | 1 | 事务日志连接池最小连接数 |
saga.persistence.ds.max.life.time.milliseconds | 0(无限制) | 事务日志连接池最大存活时间,单位毫秒 |
saga.persistence.ds.idle.timeout.milliseconds | 60 * 1000 | 事务日志连接池空闲回收时间,单位毫秒 |
saga.persistence.ds.connection.timeout.milliseconds | 30 * 1000 | 事务日志连接池超时时间,单位毫秒 |
Saga事务日志表:
-- MySQL init table SQL
CREATE TABLE IF NOT EXISTS saga_event(
id BIGINT AUTO_INCREMENT PRIMARY KEY,
saga_id VARCHAR(255) null,
type VARCHAR(255) null,
content_json TEXT null,
create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
INDEX saga_id_index(saga_id)
)ENGINE=InnoDB DEFAULT CHARSET=utf8
在classpath中添加schema-init.sql
可以定日志表,Saga引擎会完成初始化建表操作。
1.按照seata-work-shop中的步骤,下载并启动seata server,参考 Step6 和 Step7即可。
2.在每一个分片数据库实例中执创建undo_log表(目前只支持Mysql)
CREATE TABLE IF NOT EXISTS `undo_log` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`branch_id` bigint(20) NOT NULL,
`xid` varchar(100) NOT NULL,
`rollback_info` longblob NOT NULL,
`log_status` int(11) NOT NULL,
`log_created` datetime NOT NULL,
`log_modified` datetime NOT NULL,
`ext` varchar(100) DEFAULT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
3.在classpath中修改seata.conf
client {
application.id = raw-jdbc ## 应用唯一id
transaction.service.group = raw-jdbc-group ## 所属事务组
}