ShardingJDBC分布式事务快速上手

引入依赖

• 在项目的 pom.xml 中添加ShardingSphere相关依赖：

          
         
          org.apache.shardingsphere
           
         
          sharding-jdbc-core
           
         
          ${sharding-sphere.version}
         
        
        
          
         
          org.apache.shardingsphere
           
         
          sharding-transaction-xa-core
           
         
          ${sharding-sphere.version}
         
        
        
          
         
          org.apache.shardingsphere
           
         
          shardingsphere-transaction-xa-bitronix
           
         
          ${sharding-sphere.version}
         
        
          
         
          org.apache.shardingsphere
           
         
          shardingsphere-transaction-xa-narayana
           
         
          ${sharding-sphere.version}
         
        

• 下载并引入XA事务所需的具体实现模块（如Bitronix或Narayana）。

配置事务管理器

• 创建事务管理器配置类：

  @Configuration@EnableTransactionManagementpublic class TransactionConfiguration {  @Bean  public PlatformTransactionManager txManager(final DataSource dataSource) {    return new DataSourceTransactionManager(dataSource);  }  @Bean  public JdbcTemplate jdbcTemplate(final DataSource dataSource) {    return new JdbcTemplate(dataSource);  }}

• 在事务管理器中注入ShardingSphere的数据源。

使用事务注解

• 在业务代码中使用XA事务注解：

  @Transactional@ShardingTransactionType(TransactionType.XA)public void insert() {  jdbcTemplate.execute("INSERT INTO t_order (user_id, status) VALUES (?, ?)", new PreparedStatementCallback

• 注意：XA事务默认使用Atomikos作为事务管理器，生成XA事务日志文件xa_tx.log，请勿删除。

部署Seata服务

• 下载并解压Seata服务和配置文件：

  # 下载Seata服务wget https://github.com/seata/seata/releases/download/v1.4.0/seata-server-1.4.0.tar.gz# 启动Seata服务sh seata-server.sh -m standalone

• 配置registry.conf和seata.conf：

  # registry.confregistry {  type = "nacos"  loadBalance = "RandomLoadBalance"  loadBalanceVirtualNodes = 10  nacos {    application = "seata-server"    serverAddr = "192.168.65.232:8848"    namespace = "public"    group = "SEATA_GROUP"    cluster = "default"    username = "nacos"    password = "nacos"  }}# seata.confclient {  application.id = example  transaction.service.group = my_test_tx_group}

• 将配置文件注册到Nacos：

  sh nacos-config.sh localhost

配置客户端

• 在项目中引入Seata客户端依赖：

          
         
          io.seata
           
         
          seata-all
           
         
          1.4.0
         
        
          
         
          com.alibaba.nacos
           
         
          nacos-client
           
         
          1.4.1
         
        

• 创建undo_log表：

  CREATE TABLE IF NOT EXISTS `undo_log` (  `id` BIGINT(20) NOT NULL AUTO_INCREMENT COMMENT 'increment id',  `branch_id` BIGINT(20) NOT NULL COMMENT 'branch transaction id',  `xid` VARCHAR(100) NOT NULL COMMENT 'global transaction id',  `context` VARCHAR(128) NOT NULL COMMENT 'undo_log context,such as serialization',  `rollback_info` LONGBLOB NOT NULL COMMENT 'rollback info',  `log_status` INT(11) NOT NULL COMMENT '0:normal status,1:defense status',  `log_created` DATETIME NOT NULL COMMENT 'create datetime',  `log_modified` DATETIME NOT NULL COMMENT 'modify datetime',  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='AT transaction mode undo table';

配置事务组

• 在seata.conf中配置事务组：

  service.vgroupMapping.my_test_tx_group = defaultservice.default.gouplist = 127.0.0.1:8091

• 将配置文件复制到ShardingSphere的类路径。

使用BASE事务

• 在业务代码中使用@ShardingTransactionType(TransactionType.BASE)注解：

  @Transactional@ShardingTransactionType(TransactionType.BASE)public void insert() {  // 业务逻辑代码  jdbcTemplate.execute("INSERT INTO t_order (user_id, status) VALUES (?, ?)", new PreparedStatementCallback