shardingsphere-jdbc集成Seata分布式事务

1、导入相关依赖

        <!-- shardingsphere-jdbc --><dependency><groupId>org.apache.shardingsphere</groupId><artifactId>shardingsphere-jdbc</artifactId><version>5.5.1</version></dependency><!-- shardingsphere 集成 seata AT 模式 --><dependency><groupId>org.apache.shardingsphere</groupId><artifactId>shardingsphere-transaction-base-seata-at</artifactId><version>5.5.1</version></dependency><dependency><groupId>org.apache.seata</groupId><artifactId>seata-all</artifactId><version>2.3.0</version><exclusions><exclusion><groupId>org.antlr</groupId><artifactId>antlr4-runtime</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId><exclusions><exclusion><groupId>com.netflix.archaius</groupId><artifactId>archaius-core</artifactId></exclusion></exclusions></dependency>

备注：
【1】shardingsphere-transaction-base-seata-at 的版本最好与 shardingsphere-jdbc 版本一致
【2】seata-all 版本最好与 seata-server 服务端版本一致

2、在应用服务的 classpath 目录下创建以下配置文件

【1】sharding-config.yml：用于支持读写分离。这里以应用已经集成了 shardingsphere-jdbc 为前提，可参考：
https://blog.csdn.net/hkl_Forever/article/details/146602740

【2】seata.conf：用于 shardingsphere-jdbc 支持 seata 分布式事务，内容案例如下：

shardingsphere.transaction.seata.at.enable = true
shardingsphere.transaction.seata.tx.timeout = 120client {application.id = order-servicetransaction.service.group = default_tx_group
}service {vgroupMapping.default_tx_group = "default"default.grouplist = "服务IP:8091"
}

备注：
（1）事务组名称可以自定义，但要与seata服务端配置文件（seata-server.yml）中配置的事务组名称一致(否则报错)，
（2）注意 default_tx_group、default 的映射关系要对应

【3】registry.conf：用于访问 seata 服务所在的注册中心和配置中心，内容案例如下：

registry {type = "nacos"nacos {serverAddr = "http://nacos服务ip:8850"username = "xxx"password = "xxx"namespace = "xxx"group = "DEFAULT_GROUP"}
}config {type = "nacos"nacos {serverAddr = "http://nacos服务ip:8850"username = "xxx"password = "xxx"namespace = "xxx"group = "DEFAULT_GROUP"dataId = "seata-server.yml" # Seata服务端的配置文件，一定要正确保证能访问到该文件}
}

【4】在集成 seata 服务对应的数据库中创建 undo_log 表，(此为必须，否则全局事务无法回滚)，可参考：
https://blog.csdn.net/hkl_Forever/article/details/145803842

3、传递 TX_XID（全局事务id）

【1】在调用方的服务中配置openfeign的接口 RequestInterceptor 的实现类进行传递

@Configuration
public class TransferTxXidInterceptor implements RequestInterceptor {@Overridepublic void apply(RequestTemplate requestTemplate) {//---------------------- 传递 seata 的 TX_XID  start ---------------------String xid = RootContext.getXID();if (StrUtil.isNotBlank(xid)) {requestTemplate.header(RootContext.KEY_XID, xid);}//---------------------- 传递 seata 的 TX_XID  end ---------------------}}

【2】在被调用方的服务中配置 seata 支持的事务传播拦截器，获取调用方传递过来的 TX_XID

@Configuration
public class JakartaSeataConfig {/*** <p>微服务事务传播拦截器（适用SpringBoot 3.x）</p>*/@Beanpublic JakartaSeataWebMvcConfigurer getJakartaSeataWebMvcConfigurer() {return new JakartaSeataWebMvcConfigurer();}//    /**
//     * <p>微服务事务传播拦截器（适用SpringBoot 2.x）</p>
//     */
//    @Bean
//    public SeataWebMvcConfigurer getSeataWebMvcConfigurer() {
//        return new SeataWebMvcConfigurer();
//    }}

4、验证测试，启用微服务应用

调用方代码案例

	@Transactional(rollbackFor = Exception.class)@Overridepublic void saveOrder(AddOrderReq data) {if (ObjUtil.isNull(data)) {return;}//保存订单Order order = BeanUtil.copyProperties(data, Order.class);order.setOrderNo("S-" + IdUtil.getSnowflake().nextIdStr());order.setOrderTotalPrice(ObjUtil.defaultIfNull(data.getOrderTotalPrice(), NumberUtil.toBigDecimal(0.00)));this.save(order);//记录支付流水InsPaymentFlowReq insPaymentFlowReq = new InsPaymentFlowReq();insPaymentFlowReq.setOrderNo(order.getOrderNo());insPaymentFlowReq.setCostPrice(order.getOrderTotalPrice());insPaymentFlowReq.setRemark(order.getRemark());paymentFlowClient.insPaymentFlow(insPaymentFlowReq);ThrowUtil.fail("order服务出错了!");}

被调用方代码案例

    @Transactional(rollbackFor = {Exception.class})@Overridepublic void insPaymentFlow(InsPaymentFlowReq data) {if (ObjUtil.isNull(data)) {return;}PaymentFlow paymentFlow = BeanUtil.copyProperties(data, PaymentFlow.class);paymentFlow.setFlowNo("F-" + IdUtil.getSnowflake().nextIdStr());this.save(paymentFlow);//ThrowUtil.fail("payment服务出错了!");}

经测试验证后，在 shardingsphere-jdbc 读写分离的前提下，服务调用链路中有报错双方都可以正常回滚，符合预期

5、总结注意

【1】shardingsphere-jdbc 集成 seata 与 单数据源集成 seata 完全是各自独立的方式(不搭嘎)

【2】shardingsphere-jdbc 集成 seata 后，切记在主方法上要使用 @Transactional 不能使用 @GlobalTransactional。单数据源集成 seata 则在主方法上使用 @GlobalTransactional 即可

【3】shardingsphere-jdbc 集成 seata 后，如果只使用读写分离场景没问题。但如果使用分片、分库分表场景则 seata 事务不靠谱(不建议分片场景和seata一起使用)