Spring Transaction Annotations - 成功执行

Question

我在我的服务层中使用 Spring 应用程序事件来在特定事件发生时通知更广泛的系统。我遇到的问题是事件是在事务上下文中触发的（我使用的是 Spring 的 @Transactional 注释）。危险是我触发了一个事件，然后事务在提交时失败（例如，在使用 Hibernate 时可能发生）。在这种情况下，事件侦听器将假设某些状态，然后在它们执行后回滚。这里的危险是，例如，我可能已经发送了一封电子邮件来确认用户在网站上的注册，而实际上他们的用户帐户并未真正创建。

有没有办法保留注释的使用，在某处标记事务提交后要触发的事件？这有点类似于在 Java Swing 中进行 GUI 编程时使用SwingUtilities.invokeLater(Runnable runnable)。我想说，一旦当前事务成功提交，稍后再执行这段代码。

有什么想法吗？

谢谢，

安德鲁

Answer 1

这对我有用：

TransactionSynchronizationManager.registerSynchronization(
    new TransactionSynchronizationAdapter() {
        @Override
        public void afterCommit() {
            // things to do when commited
        }
        // other methods to override are available too
    });

Answer 2

您可以使用 TransactionSynchronizationManager 而无需破解 PlatformTransactionManager。

注意：TransactionAware 是一个标记接口，表示 ApplicationListener 想要在事务提交成功后接收 Event。

public class TransactionAwareApplicationEventMulticaster extends SimpleApplicationEventMulticaster {

    @Override
    public void multicastEvent(ApplicationEvent event) {
        for (ApplicationListener listener : getApplicationListeners(event)) {
            if ((listener instanceof TransactionAware) && TransactionSynchronizationManager.isSynchronizationActive()) {
                TransactionSynchronizationManager.registerSynchronization(
                    new EventTransactionSynchronization(listener, event));
            }
            else {
                notifyEvent(listener, event);
            }
        }
     }

     void notifyEvent(final ApplicationListener listener, final ApplicationEvent event) {
          Executor executor = getTaskExecutor();
          if (executor != null) {
               executor.execute(new Runnable() {
                    public void run() {
                         listener.onApplicationEvent(event);
                    }
               });
          }
          else {
               listener.onApplicationEvent(event);
          }
     }

    class EventTransactionSynchronization extends TransactionSynchronizationAdapter {
        private final ApplicationListener listener;
        private final ApplicationEvent event;

        EventTransactionSynchronization(ApplicationListener listener, ApplicationEvent event) {
            this.listener = listener;
            this.event = event;
        }

        @Override
        public void afterCompletion(int status) {
            if ((phase == TransactionPhase.AFTER_SUCCESS)
                    && (status == TransactionSynchronization.STATUS_COMMITTED)) {
                notifyEvent(listener, event);
            }
        }
    }
}

Answer 3

解决确认电子邮件问题的正确方法可能是使用分布式事务和参与其中的 JMS 资源。

但是，作为一种快速而简单的解决方案，您可以尝试在 PlatformTransactionManager 周围创建一个包装器，该包装器将在成功提交后执行在某些 ThreadLocal 存储中注册的 Runnables（并将其从 @987654325 中删除） @回滚后）。其实AbstractPlatformTransactionManager和TransactionSynchronizations也有这种逻辑，只是它的实现细节埋得太深了。