2个事务管理器之间的Spring切换（不需要单个事务行为）

Question

要访问2个数据库，我们使用两个不同的事务管理器（每个都有自己的数据源）：

第一个事务管理器：

<bean id="transactionManager"
    class="org.springframework.orm.hibernate4.HibernateTransactionManager">
    <property name="sessionFactory" ref="sessionFactory" />
</bean>

第二个事务管理器：

<bean id="transactionManager2"
    class="org.springframework.orm.hibernate4.HibernateTransactionManager">
    <property name="sessionFactory" ref="sessionFactory2" />
</bean>

在服务层，我们希望有一个获取id并返回DTO的方法。问题是DTO必须填充来自两个数据库的数据。

我们尝试了第一种方法：

• FooDao：使用 sessionFactory（与 transactionManager 相同）
• BarDao：使用 sessionFactory2（与 transactionManager2 相同的 sessionFactory）

使用以下服务方法:

@Autowired
private FooDao fooDao;

@Autowired
private BarDao barDao;

@Transactional(value="transactionManager", readOnly=true)
public FooBarDto getFoo(int id) {
    Foo foo = fooDao.get(id);

    return createDto(foo);
}

@Transactional(value="transactionManager2", readOnly=true)
public FooBarDto createDto(Foo foo) {
    Bar bar = barDao.get(foo.getId());

    FooBarDto fooBarDto = new FooBarDto();

    fooBarDto.setId(String.valueOf(foo.getId()));
    fooBarDto.setA(String.valueOf(foo.getA()));
    fooBarDto.setB(String.valueOf(foo.getB()));
    fooBarDto.setC(String.valueOf(bar.getC()));
    fooBarDto.setD(String.valueOf(bar.getD()));

    return fooBarDto;
}

但在这种情况下，我们在barDao方法中得到了“未找到当前线程的会话”错误。由于我们不需要在单个事务上执行整个操作（并保持当前配置），因此我们不希望使用JTA。

我们尝试配置事务传播（使用Propagation.REQUIRES_NEW），但看起来它仅适用于来自同一管理器的事务。

我们可以更改这两个方法，并从控制器（顺序）调用这两个，但我们更愿意调用一个服务方法来完成所有工作。有没有办法达到预期的行为？

非常感谢Ricardo Veguilla！按照你的建议，一切都很顺利。我将createDto方法移动到另一个服务（BarService），并在第一个服务（FooService）上自动连接它：

@Service
public class FooServiceImpl implements FooService {

    @Autowired
    private FooDao fooDao;

    @Autowired
    private BarService barService;

    @Transactional(value="transactionManager", readOnly=true)
    public FooBarDto getFoo(int id) {
        Foo foo = fooDao.get(id);

        return barService.createDto(foo);
    }
}

以及创建的 BarService：

@Service
public class BarServiceImpl implements BarService {

    @Autowired
    private BarDao barDao;

    @Transactional(value="transactionManager2", readOnly=true)
    public FooBarDto createDto(Foo foo) {
        FooBarDto fooBarDto = new FooBarDto();

        if (foo != null) {
            Bar bar = barDao.get(foo.getId());

            fooBarDto.setId(String.valueOf(foo.getId()));
            fooBarDto.setA(String.valueOf(foo.getA()));
            fooBarDto.setB(String.valueOf(foo.getB()));

            if (bar != null) {
                fooBarDto.setC(String.valueOf(bar.getC()));
                fooBarDto.setD(String.valueOf(bar.getD()));
            }
        }

        return fooBarDto;
    }
}

Answer 1

如果您使用Java 8，您可以创建如下类:

@Component
class TransactionWrapper {

    @Transactional
    public <T> T doInTransaction(Supplier<T> supplier) {
       return
    }

在事务上下文中调用类内部的方法(即私有方法)。

Answer 2

您在 barDao bacuse 中没有从同一个 bean 内部调用 createDto 的会话，这意味着方法调用不会通过 Spring Transacitional 代理。

在Spring中，需要从包含Spring注入的< code>myBean实例的其他bean中调用带有用< code>@Transactional注释的公共方法的bean myBean,因为事务支持是使用代理实现的。您需要将< code>createDto方法移动到另一个bean:

 @component
 public class ForBarService {

        @Autowired
        private FooDao fooDao;

        @Autowired
        private DtoFactory dtoFactory;

        @Transactional(value="transactionManager", readOnly=true)
        public FooBarDto getFoo(int id) {
        Foo foo = fooDao.get(id);
             return dtoFactory.createDto(foo);
        }
 }

 @Component
 public class DtoFactory {
      @Autowired
      private BarDao barDao;

      @Transactional(value="transactionManager2", readOnly=true)
      public FooBarDto createDto(Foo foo) {
          Bar bar = barDao.get(foo.getId());

          FooBarDto fooBarDto = new FooBarDto();

          fooBarDto.setId(String.valueOf(foo.getId()));
          fooBarDto.setA(String.valueOf(foo.getA()));
          fooBarDto.setB(String.valueOf(foo.getB()));
          fooBarDto.setC(String.valueOf(bar.getC()));
          fooBarDto.setD(String.valueOf(bar.getD()));

          return fooBarDto;
      }

 }