一种服务方法为 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 调试 TransactionSynchronizationManager:183 - 键 [org.springframework.jdbc.datasource.DriverManagerDataSource@1b9658e] 到线程 [main] 的绑定值 [org.springframework.jdbc.datasource.ConnectionHolder@ba86ef] 21:44:19,546 DEBUG TransactionSynchronizationManager:258 - 初始化事务同步 21:44:19,547 DEBUG TransactionInterceptor:362 - 获取 [com.bluesky.FooServiceImpl.insertA] 的交易 21:44:19,547 调试 JdbcTemplate:416 - 执行 SQL 语句 [插入学生（姓名）值（'stuA'）] 21:44:19,592 调试 JdbcTemplate:416 - 执行 SQL 语句 [插入学生（姓名）值（'stuB'）] 21:44:19,594 DEBUG TransactionInterceptor:406 - 在异常发生后完成 [com.bluesky.FooServiceImpl.insertA] 的事务：java.lang.ArithmeticException: / 为零 21:44:19,594 DEBUG RuleBasedTransactionAttribute:130 - 应用规则来确定事务是否应在 java.lang.ArithmeticException 上回滚：/ 为零 21:44:19,594 DEBUG RuleBasedTransactionAttribute:147 - 获胜回滚规则为：null 21:44:19,595 DEBUG RuleBasedTransactionAttribute:152 - 未找到相关回滚规则：应用默认规则 21:44:19,595 调试 DataSourceTransactionManager:938 - 触发 beforeCompletion 同步 21:44:19,595 调试 DataSourceTransactionManager:843 - 启动事务回滚 21:44:19,596 调试 DataSourceTransactionManager:279 - 在连接 [com.mysql.jdbc.JDBC4Connection@167f4bf] 上回滚 JDBC 事务 21:44:19,598 调试 DataSourceTransactionManager:967 - 触发后完成同步 21:44:19,598 DEBUG TransactionSynchronizationManager:316 - 清除事务同步

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

是否有什么我没有配置或任何担心我弄错了

我的意图是当insertA() 调用insertB() 时有一个REQUIRES_NEW 事务开始。

Answer 1

KLE 关于重构代码的建议是对的，但至于为什么它不起作用，Spring AOP 默认使用JDK dynamic proxies 来提供AOP。这意味着当您将服务注入某些东西时，真正被注入的是实现您的服务接口的代理实例。在此代理上调用方法时，它会在委托给您的实际服务实例之前运行事务代码。但是，一旦控制流在您的服务内部，通过this.foo() 调用另一个方法（即使this 是隐式的）只会调用同一个实例上的一个方法：您的服务。它不会返回到代理，这是唯一知道交易的事情。 If you switched 使用 AspectJ 构建或加载时字节码编织，然后您可以这样做，它会按预期工作，因为事务调用代码将直接编织到您的服务代码中，而不是存在于单独的对象中。

Answer 2

我了解您的问题。有一些技术上复杂的方法可以让它工作，但我们通常认为它们不值得。我建议另一种方法，简单而强大，实际上可以改进您的代码。

不要将它们放在同一个 Spring bean 上，而是将它们放在两个不同的 Bean 上，B 被注入 A。

我知道我没有回答您的问题，但请考虑一下优点：

• 很简单，现在花费的时间很少。
• 要要求新事务，B 可能是一个不同的问题。有不同的关注点是不同的类，这正是我们所寻找的，优秀的设计。
• 您无需向同事解释任何新的和复杂的内容（或为未来的开发人员提供文档），它的简单性使其立即易于理解。

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. Understanding AOP proxies
• AopContext javadoc