打算用 Spring AbstractRoutingDataSource 做一主多从但是和事务搭配实现上感觉不太对头，怎么解决？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1327 天前的主题，其中的信息可能已经有所发展或是发生改变。

需求

1. AbstractRoutingDataSource 想根据当前的事务状态来 routing 
2. 在从库上禁用更新操作
3. 每个请求 打在一个数据源上

问题

1. 在进行 data source routing 时，TransactionSynchronizationManager.isActualTransactionActive 总是返回 false ；按照代码的语义实际上是在事务之中的； 请问有什么其他的 API 可以使用么？
2. 在 data source routing 中想向 TransactionSynchronizationManager 注册 TransactionSynchronization 用于资源清理，但是返回 synchronization is not active

stackoverflow 似乎有人遇到了相同的问题

https://stackoverflow.com/questions/9203122/routing-read-write-transactions-to-primary-and-read-only-transactions-to-replica

Christophe Fondacci 这个回答。。似乎没有解决

第 1 条附言 · 2021-04-07 08:38:03 +08:00

搞定了。。。不要重写事务管理器。。。

1. 重写 DataSourceTransactionManager的dobegin 方法使用如下代码来判断是否进入事务;

JdbcTransactionObjectSupport transaction1 = (JdbcTransactionObjectSupport) transaction;
        if (!transaction1.hasConnectionHolder() || transaction1.getConnectionHolder().isSynchronizedWithTransaction()){
            logger.info("it seems it is in transaction ");
//do thread local bind  in transaction status
        }

2. 重写 DataSourceTransactionManager的prepareSynchronization 方法

   @Override
    protected void prepareSynchronization(DefaultTransactionStatus status, TransactionDefinition definition) {
        super.prepareSynchronization(status, definition);
        if (MasterSlavesDataSourceSynchronization.isInTransaction()){
            TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
                @Override
                public void afterCompletion(int status) {
                  // do your thread local resource clean
                }
            });
        }
    }