事务/提交后guava eventbus发布

Question

我目前正在Spring玩番石榴的eventbus，虽然一般功能运行良好，但到目前为止，我遇到了以下问题：

当用户希望更改“行”实体上的数据时，这将在后端服务中照常处理。在这个服务中，数据将首先通过JPA持久化，然后我创建一个“NotificationEvent”，引用已更改的实体。通过EventBus，我将线路参考发送给所有订阅者。

public void notifyUI(String lineId) {
    EventBus eventBus = getClientEventBus();
    eventBus.post(new LineNotificationEvent(lineId));
}

eventbus本身是在后台使用new eventbus（）创建的。

在这种情况下，我的订阅者在前端，在@Transactional领域之外。所以当我更改我的数据时，发布事件并让订阅者从数据库中获得所有必要的更新，实际的事务尚未提交，这使得订阅者获取旧数据。

我能想到的唯一快速解决方案是异步处理并等待一两秒钟。但是，在事务提交后，是否有另一种方法可以使用番石榴发布事件？

Answer 1

我认为番石榴根本没有“意识到”Spring，尤其是它的“@事务性”东西。

所以你需要一个创造性的解决方案。我可以考虑的一个解决方案是将此代码移动到您确定事务已完成的位置。实现这一目标的一种方法是使用TransactionSyncrhonizationManager：

TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization(){
           void afterCommit(){
                // do what you want to do after commit
                // in this case call the notifyUI method
           }
});

请注意，如果事务失败（回滚），则不会调用该方法，在这种情况下，您可能需要在完成方法之后使用。请参阅留档

另一种可能的方法是将应用程序重构为以下内容：

@Service
public class NonTransactionalService {

   @Autowired 
   private ExistingService existing;

   public void entryPoint() {

      String lineId = existing.invokeInTransaction(...);
      // now you know for sure that the transaction has been committed
      notifyUI(lineId);
   }
}

@Service
public class ExistingService  {

   @Transactional
   public String invokeInTransaction(...) {
      // do your stuff that you've done before
   }
}

我想在这里提到的最后一件事是，Spring本身提供了一种事件机制，您可以使用它来代替guava的机制。

例如，请参阅此教程