Hibernate JPA 多个 Web 服务更新同一个表

Question

下面是我们源代码的sn-p...

@transactional
public void doSomething(){
  User user = (set up user fields)
  userDao.merge(user); //update USER table
  //call another web service which also updates USER table
  //do other processes
}

问题是，来自其他 Web 服务的更新被来自 userDao.merge 的更新覆盖，因为它在事务方法完成之前不会提交合并事务。

你如何处理这种情况？我希望 userdao.merge 的更新和其他 Web 服务完成的更新都记录在案。

Answer 1

将用户的第一次更新放入标有 REQUIRES_NEW 传播的新事务方法中：

@Transactional
public void doSomething(){

  updateUser();

  //call another web service which also updates USER table
  //do other processes
}

@Transactional(propagation = Propagation.REQUIRES_NEW)
public void udateUser(){

 User user = (set up user fields)
  userDao.merge(user); //update USER table

}

在调用 web 服务之前，内部事务将被提交并且结果对 web 服务可见。请记住，如果 web 服务失败.. 用户的第一次更新不会回滚。

Answer 2

这里最大的问题是您是否需要两个更新都以原子方式发生。在许多应用程序中，这是必需的。在其他情况下，使用最终一致性是可以接受的，这取决于您的要求。

如果您需要原子事务，这意味着两个更新都会发生或都不会发生，您将需要在两个应用程序中利用基于 JTA 的分布式事务。应用服务器提供了开箱即用的功能，您只需配置应用程序即可使用它。

非原子解决方案将使用 spring 的 TransactionSynchronization 接口调用以提供 #afterCommit() 回调：

@Transactional
public void doSomething() {
  // do stuff
  userDao.merge( user );

  TransactionSynchronizationManager.registerSynchronization(
    new TransactionSynchronization() {
      void afterCommit() {
        // call to second service somehow
      }
    }
  );
}

如何调用第二项服务完全取决于您。您可以将带有触发器的 JMS 消息发送到第二个 Web 服务侦听的队列，或者您可以直接调用该第二个 Web 服务。

这里的关键部分是对代理或第二个 Web 服务的调用需要具有容错性，因此确保最终的一致性合同。