一个服务方法在Spring事务中调用多个内部方法

Question

package com.bluesky;

public interface FooServiceIface {
    public  void insertA();
    public void insertB();
}

---

package com.bluesky;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class FooServiceImpl extends JdbcDaoSupport implements FooServiceIface {

    public void insertA() {
        this.getJdbcTemplate().execute("insert student(name) values('stuA')");
         insertB();
         int i=10/0;
    }

    public void insertB() {
        this.getJdbcTemplate().execute("insert student(name) values('stuB')");

    }

}

---

public class Client {

    public static void main(String[] args) {

        ApplicationContext appContxt = new ClassPathXmlApplicationContext("applicationContext.xml");

        FooServiceIface  fService= (FooServiceIface)appContxt.getBean("fooService");

        fService.insertA();

    }
}

---

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">

    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
       <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
       <property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&amp;characterEncoding=utf-8"/>
       <property name="username" value="root"/>
       <property name="password" value="root"/>
    </bean>

    <bean id="fooService" class="com.bluesky.FooServiceImpl">
         <property name="dataSource" ref="dataSource"/>  
    </bean>
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  
        <property name="dataSource" ref="dataSource"/>  
    </bean>  

    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="insertA" propagation="REQUIRED" />
             <tx:method name="insertB" propagation="REQUIRES_NEW" />
        </tx:attributes>
    </tx:advice>

    <aop:config proxy-target-class="true">
        <aop:pointcut id="interceptorPointCuts" expression="execution(* com.bluesky.*Service*.*(..))" />
        <aop:advisor advice-ref="txAdvice" pointcut-ref="interceptorPointCuts" />       
    </aop:config>     
</beans>

很抱歉代码看起来比较复杂

当我运行客户端时，出现了以下调试日志:

21:44:19,546 DEBUG TransactionSynchronizationManager:183 - 将值 [org.springframework.jdbc.datasource.ConnectionHolder@ba86ef] 绑定到键 [org.springframework.jdbc.datasource.DriverManagerDataSource@1b9658e] 在线程 [main]
21:44:19,546 DEBUG TransactionSynchronizationManager:258 - 初始化事务同步
21:44:19,547 DEBUG TransactionInterceptor:362 - 为 [com.bluesky.FooServiceImpl.insertA] 获取事务
21:44:19,547 DEBUG JdbcTemplate:416 - 执行 SQL 语句 [insert student(name) values('stuA')]
21:44:19,592 DEBUG JdbcTemplate:416 - 执行 SQL 语句 [insert student(name) values('stuB')]
21:44:19,594 DEBUG TransactionInterceptor:406 - 在出现异常 java.lang.ArithmeticException: / by zero 后完成 [com.bluesky.FooServiceImpl.insertA] 的事务
21:44:19,594 DEBUG RuleBasedTransactionAttribute:130 - 应用规则来确定是否在 java.lang.ArithmeticException: / by zero 上回滚事务
21:44:19,594 DEBUG RuleBasedTransactionAttribute:147 - 获胜的回滚规则是：null
21:44:19,595 DEBUG RuleBasedTransactionAttribute:152 - 找不到相关的回滚规则：应用默认规则
21:44:19,595 DEBUG DataSourceTransactionManager:938 - 触发 beforeCompletion 同步
21:44:19,595 DEBUG DataSourceTransactionManager:843 - 启动事务回滚
21:44:19,596 DEBUG DataSourceTransactionManager:279 - 在连接 [com.mysql.jdbc.JDBC4Connection@167f4bf] 上回滚 JDBC 事务
21:44:19,598 DEBUG DataSourceTransactionManager:967 - 触发 afterCompletion 同步
21:44:19,598 DEBUG TransactionSynchronizationManager:316 - 清除事务同步

我发现当调用 insertA() 方法时，该方法启动了一个事务，但在代码到达 insertB() 时，没有事务可以启动。

是我没有配置或者有什么问题吗？

我的意图是当 insertA() 调用 insertB() 时，会启动一个新的 REQUIRES_NEW 事务。

- user917879

Answer 1

KLE关于重构代码的建议非常恰当，但是关于为什么它不起作用，Spring AOP默认使用JDK动态代理来提供AOP。这意味着当你将服务注入到某个地方时，实际上被注入的是一个实现你的服务接口的代理实例。当在此代理上调用方法时，它会在委托给你的实际服务实例之前运行事务代码。然而，一旦控制流进入你的服务内部，通过this.foo()调用另一个方法（即使this是隐式的）只会在同一实例上调用方法：你的服务。它不会返回到代理，而代理是唯一知道事务的东西。如果你切换到使用AspectJ进行构建或加载时字节码织入，那么你就可以做到这一点，并且它将按预期工作，因为调用事务的代码将直接织入到你的服务代码中，而不是存在于一个单独的对象中。

- Ryan Stewart

---

+1 感谢您提供的技术细节，总是很好地满足需求附近的。 :-) - KLE

Answer 2

我理解你的问题。有一些技术上复杂的方法可以让它运行，但我们通常认为这些方法不值得。我建议另一种简单而强大的方法，实际上可以改善您的代码。 与其在同一个Spring bean上拥有它们，不如将它们放在两个不同的bean中，B被注入到A中。 我知道我没有回答你的问题，但是考虑一下以下优点： - 很简单，现在花费非常少的时间。 - 要求新事务，B可能是一个不同的关注点。有一个不同的关注点是一个不同的类，看起来正是我们所寻找的，好的设计。 - 没有任何新的复杂内容需要向同事（或未来的开发人员）解释或文档化，它的简单性使其立即可理解。

- KLE

---

非常感谢您的回答，我想知道使用Spring AOP调用insertB()时是否会对insertA()产生影响（insertB()方法不应该在Spring事务控制中）。 - user917879

@user...我不确定我理解你的评论。在不同的bean上，Spring将确保事务按预期工作。如果您设置了“REQUIRES_NEW”事务策略，您将得到想要的结果。 - KLE

Answer 3

KLE的回答是可靠的建议。为了完整地说明问题，确实有一个解决方法，但它违背了AOP的一切原则：

public void insertA() {
    this.getJdbcTemplate().execute("insert student(name) values('stuA')");
    // this works, but... gah!
    ((FooServiceIface) AopContext.currentProxy()).insertB();
    int i=10/0;
}

参考资料：

• 7.6.1. 理解AOP代理
• AopContext javadoc文档

- Sean Patrick Floyd

---

+1 谢谢你的黑客技巧！:-) 我希望我的团队永远不会看到这个，否则有些人可能会开始使用它 :-)) - KLE