Seata集成dynamic datasource，怎么操作？

在使用Seata集成动态数据源（dynamic datasource）时，需要根据具体的场景和需求进行配置。以下是详细的步骤和操作方法，基于知识库中的相关内容：

1. 引入依赖

确保项目中已正确引入Seata相关依赖。通常需要以下两种依赖之一： - 仅依赖seata-all：适用于手动配置数据源代理。 - 依赖seata-spring-boot-starter：适用于自动代理数据源。

2. 配置动态数据源

动态数据源的核心是通过Spring的AbstractRoutingDataSource实现数据源的动态切换。以下是具体操作步骤：

2.1 定义动态数据源

创建一个动态数据源类，继承AbstractRoutingDataSource，并实现determineCurrentLookupKey方法，用于决定当前线程使用的数据源。

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataSourceKey();
    }
}

2.2 配置数据源上下文

创建一个上下文类DataSourceContextHolder，用于存储和切换当前线程的数据源标识。

public class DataSourceContextHolder {
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();

    public static void setDataSourceKey(String key) {
        contextHolder.set(key);
    }

    public static String getDataSourceKey() {
        return contextHolder.get();
    }

    public static void clearDataSourceKey() {
        contextHolder.remove();
    }
}

3. 集成Seata

根据不同的依赖方式，选择以下三种方法之一进行Seata集成：

方法一：仅依赖seata-all

将动态数据源代理为Seata的DatasourceProxy，并在配置中替换原有的TxcDataSource。

@Bean("dataSourceProxy")
public DataSource dataSourceProxy(DynamicDataSource dynamicDataSource) {
    return new DatasourceProxy(dynamicDataSource);
}

方法二：仅依赖seata-all + 注解方式

去掉手动配置dataSourceProxy的逻辑，改为在启动类或配置类中添加@EnableAutoDataSourceProxy注解，Seata会自动代理数据源。

@EnableAutoDataSourceProxy
@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

方法三：依赖seata-spring-boot-starter

如果使用seata-spring-boot-starter，无需手动配置dataSourceProxy，Seata会自动将所有实现了DataSource接口的数据源代理为DatasourceProxy。

4. 配置Seata事务模式

Seata支持多种事务模式，如AT、TCC、SAGA等。对于动态数据源，推荐使用AT模式，因为它对业务代码侵入性最小。

TCC模式（可选）

如果需要使用TCC模式，需按照以下API映射关系进行迁移： - 迁移前GTS API：@MtBranch - 迁移后Seata API：@TwoPhaseBusinessAction

示例代码如下：

@TwoPhaseBusinessAction(name = "exampleTccAction", commitMethod = "commit", rollbackMethod = "rollback")
public boolean prepare(BusinessActionContext actionContext) {
    // 准备阶段逻辑
    return true;
}

public boolean commit(BusinessActionContext actionContext) {
    // 提交阶段逻辑
    return true;
}

public boolean rollback(BusinessActionContext actionContext) {
    // 回滚阶段逻辑
    return true;
}

5. 注意事项

• 数据源切换时机：确保在事务开始前完成数据源切换，避免事务管理器无法正确代理数据源。
• 事务传播行为：动态数据源与事务传播行为可能存在冲突，建议在设计时明确事务边界。
• 性能优化：动态数据源切换可能带来一定的性能开销，建议结合业务场景进行优化。

通过以上步骤，您可以成功将Seata与动态数据源集成，并根据实际需求选择合适的事务模式。