Spring的TransactionEventListener

1. 问题背景:

在之前的项目中,有遇到这样一个使用场景:

在一个TransactionA中,我们先向数据库中插入了一条数据EntityA,之后起了一个线程池,而在线程池中我们需要读取数据库中EntityA。这时候就有个问题了,由于我们知道Transaction是与线程绑定的(ThreadLocal<DataSource>), 那么在线程池中的其他线程,我们可能存在一个情况就是,TransactionA还没提交或处于提交的过程中,那么此时我们是对于EntityA是不可见的。于是就需要将提交到线程的过程与TransactionA分开。在工程中,我们是使用了一种比较丑的方法,也就将待处理的EntityA id当做返回值返回给上层(事务外),然后通过上层来进行调用。但是通过这个流程过耦合了,并不是一种优美的实现方式。

2. 解决方案:
2.1 TransactionEventListener

这几天在浏览Spring Reference的时候,看到了一种方法能够很有效的方式。

在Spring4.2+,有一种较TransactionEventListener的方式,能够控制在事务的时候Event事件的处理方式。

我们知道,Spring的发布订阅模型实际上并不是异步的,而是同步的来将代码进行解耦。而TransactionEventListener仍是通过这种方式,只不过加入了回调的方式来解决,这样就能够在事务进行Commited,Rollback...等的时候才会去进行Event的处理。

代码如下:

@Service("fooService")
public class FooServiceImpl implements FooService {

    private static final Logger LOGGER = Logger.getLogger(FooServiceImpl.class);

    @Override
    public void insertFoo(Foo foo) throws MyTransactionException {
        LOGGER.info("[fooService] start insert foo");
        ApplicationEventPublisher eventPublisher = EventPublisher.getApplicationEventPublisher();
        if (null != eventPublisher) {
            eventPublisher.publishEvent(new MyTransactionEvent("test", this));
        }
        LOGGER.info("[fooServive] finish insert foo");
    }
}


public class MyTransactionEvent extends ApplicationEvent {

    private String name;

    public MyTransactionEvent(String name, Object source) {
        super(source);
        this.name = name;
    }

    public String getName() {
        return this.name;
    }
}

@Component
public class MyTransactionListener {

    private static final Logger LOGGER = Logger.getLogger(MyTransactionListener.class);

    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    public void hanldeOrderCreatedEvent(MyTransactionEvent event) {
        LOGGER.info("transactionEventListener start");
//        do transaction event
        LOGGER.info("event : " + event.getName());
//        finish transaction event
        LOGGER.info("transactionEventListener finish");
    }
}

输出结果:

[DEBUG] 2018-06-01 11:23:50,165 [main]  jdbc.datasource.DataSourceTransactionManager    (DataSourceTransactionManager.java:248) -Acquired Connection [1794768050, URL=jdbc:mysql://127.0.0.1:3306/test, UserName=root@localhost, MySQL Connector Java] for JDBC transaction
[DEBUG] 2018-06-01 11:23:50,172 [main]  jdbc.datasource.DataSourceTransactionManager    (DataSourceTransactionManager.java:265) -Switching JDBC Connection [1794768050, URL=jdbc:mysql://127.0.0.1:3306/test, UserName=root@localhost, MySQL Connector Java] to manual commit
[INFO]  2018-06-01 11:23:50,173 [main]  transaction.declarative.FooServiceImpl  (FooServiceImpl.java:36)    -[fooService] start insert foo
[DEBUG] 2018-06-01 11:23:50,174 [main]  factory.support.DefaultListableBeanFactory  (AbstractBeanFactory.java:251)  -Returning cached instance of singleton bean 'fooService'
[DEBUG] 2018-06-01 11:23:50,175 [main]  jdbc.datasource.DataSourceTransactionManager    (AbstractPlatformTransactionManager.java:476)   -Participating in existing transaction
[INFO]  2018-06-01 11:23:50,175 [main]  transaction.declarative.FooServiceImpl  (FooServiceImpl.java:43)    -[fooServive] finish insert foo
[DEBUG] 2018-06-01 11:23:50,175 [main]  jdbc.datasource.DataSourceTransactionManager    (AbstractPlatformTransactionManager.java:759)   -Initiating transaction commit
[DEBUG] 2018-06-01 11:23:50,178 [main]  jdbc.datasource.DataSourceTransactionManager    (DataSourceTransactionManager.java:310) -Committing JDBC transaction on Connection [1794768050, URL=jdbc:mysql://127.0.0.1:3306/test, UserName=root@localhost, MySQL Connector Java]
[DEBUG] 2018-06-01 11:23:50,184 [main]  factory.support.DefaultListableBeanFactory  (AbstractBeanFactory.java:251)  -Returning cached instance of singleton bean 'myTransactionListener'
[INFO]  2018-06-01 11:23:50,185 [main]  transaction.event.MyTransactionListener (MyTransactionListener.java:21) -transactionEventListener start
[INFO]  2018-06-01 11:23:50,185 [main]  transaction.event.MyTransactionListener (MyTransactionListener.java:23) -event : test
[INFO]  2018-06-01 11:23:50,185 [main]  transaction.event.MyTransactionListener (MyTransactionListener.java:25) -transactionEventListener finish
[DEBUG] 2018-06-01 11:23:50,192 [main]  jdbc.datasource.DataSourceTransactionManager    (DataSourceTransactionManager.java:368) -Releasing JDBC Connection [1794768050, URL=jdbc:mysql://127.0.0.1:3306/test, UserName=root@localhost, MySQL Connector Java] after transaction
[DEBUG] 2018-06-01 11:23:50,193 [main]  jdbc.datasource.DataSourceUtils (DataSourceUtils.java:329)  -Returning JDBC Connection to DataSource

需要注意的是,如果想使用这个注解,需要在配置文件中添加:

<tx:annotation-driven/>

由于只有在AnnotationDrivenBeanDefinitionParser的parse方法中,我们才会将

TransactionalEventListenerFactory加入到容器中。

/**
     * Parses the {@code <tx:annotation-driven/>} tag. Will
     * {@link AopNamespaceUtils#registerAutoProxyCreatorIfNecessary register an AutoProxyCreator}
     * with the container as necessary.
     */
    @Override
    public BeanDefinition parse(Element element, ParserContext parserContext) {
        registerTransactionalEventListenerFactory(parserContext);
        String mode = element.getAttribute("mode");
        if ("aspectj".equals(mode)) {
            // mode="aspectj"
            registerTransactionAspect(element, parserContext);
        }
        else {
            // mode="proxy"
            AopAutoProxyConfigurer.configureAutoProxyCreator(element, parserContext);
        }
        return null;
    }

对于注解@TransactionEventListener来讲,有一个属性fallbackExecutor,其默认值为false。如果将其设为true,则无论当前的场景是否处在事务上下文中,均能够执行。

2.2 TransactionSynchronizationManager.registerSynchronization

第二种解决方法便是通过手动的来注册回调来实现的。

我们可与利用博客Spring Event 事件中的事务控制的方式来进行。

比如:

@EventListener
public void afterRegisterSendMail(MessageEvent event) {
    // Spring 4.2 之前
 
    TransactionSynchronizationManager.registerSynchronization(
            new TransactionSynchronizationAdapter() {
                @Override
                public void afterCommit() {
                    internalSendMailNotification(event);
                }
            });
}

上面的代码将在事务提交后执行.如果在非事务context中将抛出java.lang.IllegalStateException: Transaction synchronization is not active,

@EventListener
        public void afterRegisterSendMail(MessageEvent event) {
            // Spring 4.2 之前
         
            if (TransactionSynchronizationManager.isActualTransactionActive()) {
         
                TransactionSynchronizationManager.registerSynchronization(
                        new TransactionSynchronizationAdapter() {
                            @Override
                            public void afterCommit() {
                                mailService.send(event);
                            }
                        });
            } else {
                mailService.send(event);
            }
        }

通过上面这种进行人为的判断后,我们便可以兼容是否在事务上下文而不用抛出异常。

收藏 (0)
评论列表
正在载入评论列表...
我是有底线的
为您推荐
    暂时没有数据