Spring事务不回滚原因分析

Z时代
2024-01-10
分类：综合

本文内容纲要：

- 异常 - service 内部方法调用 - Spring父子容器覆盖

Synchronized用于线程间的数据共享，而ThreadLocal则用于线程间的数据隔离。

在我完成一个项目的时候，遇到了一个Spring事务不回滚的问题，通过aspectJ和@Transactional注解都无法完成对于事务的回滚，经过查看博客和文档

默认回滚RuntimeException

Service内部方法调用

Spring父子容器覆盖

代码已经上传到 https://github.com/morethink/transactional

异常

下面是@Transactional的注释文档，下面有个If no rules are relevant to the exception,it will be treated like {@link org.springframework.transaction.interceptor.DefaultTransactionAttribute} (rolling back on runtime exceptions).

默认会使用RuntimeException,那为什么Spring默认回滚RuntimeException，因为Java把Exception分为两种。

checked Exception：Exception类本身，以及Exception的子类中除了"运行时异常"之外的其它子类都属于被检查异常。

unchecked Exception： RuntimeException和Error都属于未检查异常。

/** * Describes transaction attributes on a method or class. * * <p>This annotation type is generally directly comparable to Spring's * {@link org.springframework.transaction.interceptor.RuleBasedTransactionAttribute} * class, and in fact {@link AnnotationTransactionAttributeSource} will directly * convert the data to the latter class, so that Spring's transaction support code * does not have to know about annotations. If no rules are relevant to the exception, * it will be treated like * {@link org.springframework.transaction.interceptor.DefaultTransactionAttribute} * (rolling back on runtime exceptions). * * <p>For specific information about the semantics of this annotation's attributes, * consult the {@link org.springframework.transaction.TransactionDefinition} and * {@link org.springframework.transaction.interceptor.TransactionAttribute} javadocs. * * @author Colin Sampaleanu * @author Juergen Hoeller * @author Sam Brannen * @since 1.2 * @see org.springframework.transaction.interceptor.TransactionAttribute * @see org.springframework.transaction.interceptor.DefaultTransactionAttribute * @see org.springframework.transaction.interceptor.RuleBasedTransactionAttribute */

因此，如果发生的不是RuntimeException，而你有没有配置rollback for ，那么，异常就不会回滚。

service 内部方法调用

就是一个没有开启事务控制的方法调用一个开启了事务控制方法，不会事务回滚。

AccountService类

@Service
public class AccountService {
    @Autowired
    private AccountDao accountDao;
    /**
     * 完成转钱业务,transfer方法开启事务
     *
     * @param out
     * @param in
     * @param money
     */
    @Transactional(isolation = Isolation.DEFAULT, propagation = Propagation.REQUIRED)
    public void transfer(String out, String in, double money) {
        Account account = new Account();
        account.setName(out);
        account.setMoney(money);
        accountDao.out(account);
        int i = 1 / 0;
        account.setName(in);
        accountDao.in(account);
    }
    /**
     * 完成转钱业务,transferProxy方法没有开启事务
     *
     * @param out
     * @param in
     * @param money
     */
    public void transferProxy(String out, String in, double money) {
        System.out.println("调用transfer方法 开始");
        transfer(out, in, money);
        System.out.println("调用transfer方法 结束");
    }
}

AccountAction类

@RestController
public class AccountAction {
    @Autowired
    private AccountService accountService;
    @RequestMapping("/transfer")
    public String transfer(String out, String in, double money) {
        accountService.transfer(out, in, money);
        return "transfer";
    }
    @RequestMapping("/transferProxy")
    public String transferProxy(String out, String in, double money) {
        accountService.transferProxy(out, in, money);
        return "transfer";
    }
}

通过transferProxy方法调用transfer方法时

Logging initialized using 'class org.apache.ibatis.logging.stdout.StdOutImpl' adapter.
调用transfer方法 开始
Creating a new SqlSession
SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@a0dbf4] was not registered for synchronization because synchronization is not active
JDBC Connection [com.mchange.v2.c3p0.impl.NewProxyConnection@6386ed [wrapping: com.mysql.jdbc.JDBC4Connection@9f2009]] will not be managed by Spring
==>  Preparing: update account set money = money - ? where name = ?
==> Parameters: 100.0(Double), aaa(String)
<==    Updates: 1
Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@a0dbf4]

发现没有开启事务

直接调用transfer方法时

Logging initialized using 'class org.apache.ibatis.logging.stdout.StdOutImpl' adapter.
Creating a new SqlSession
Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@238be2]
JDBC Connection [com.mchange.v2.c3p0.impl.NewProxyConnection@a502e0 [wrapping: com.mysql.jdbc.JDBC4Connection@3dbe42]] will be managed by Spring
==>  Preparing: update account set money = money - ? where name = ?
==> Parameters: 100.0(Double), aaa(String)
<==    Updates: 1
Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@238be2]
Transaction synchronization deregistering SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@238be2]
Transaction synchronization closing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@238be2]

我们都知道Spring事务管理是通过AOP代理实现的，可是那么什么条件会使得AOP代理开启？通过查看

Sprin官方文档，发现只有把整个Service设为事务控制时，才会进行AOP代理。如果我们通过一个没有事务的transferProxy方法去调用有事务的transfer方法，是通过this引用进行调用，没有开启事务，即使发生了RuntimeException也不会回滚。

然后

Spring父子容器覆盖

Spring容器优先加载由ServletContextListener（对应applicationContext.xml）产生的父容器，而SpringMVC（对应mvc_dispatcher_servlet.xml）产生的是子容器。子容器Controller进行扫描装配时装配的@Service注解的实例是没有经过事务加强处理，即没有事务处理能力的Service，而父容器进行初始化的Service是保证事务的增强处理能力的。如果不在子容器中将Service exclude掉，此时得到的将是原样的无事务处理能力的Service，因为在多上下文的情况下，如果同一个bean被定义两次，后面一个优先。

当我们在applicationContext.xml,spring-mvc.xml都配置如下扫描包时，spring-mvc.xml中的service就会覆盖applicationContext.xml中的service。

context:component-scan base-package="net.morethink"/>

注意：当我们使用JUnit测试的时候，不会出现这种情况。

JUnit配置如下

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:applicationContext.xml", "classpath:dispatcher-servlet.xml"})
@WebAppConfiguration
public class AccountActionTest {
    protected MockMvc mockMvc;
    @Autowired
    protected WebApplicationContext wac;
    @Before()  //这个方法在每个方法执行之前都会执行一遍
    public void setup() {
        mockMvc = MockMvcBuilders.webAppContextSetup(wac).build();  //初始化MockMvc对象
    }
    @Test
    public void testTransfer() throws Exception {
        String responseString = mockMvc.perform(
                get("/transfer")    //请求的url,请求的方法是get
                        .contentType(MediaType.APPLICATION_FORM_URLENCODED)  //数据的格式
                        .param("out", "aaa")
                        .param("in", "bbb")
                        .param("money", "100")
        ).andExpect(status().isOk())    //返回的状态是200
//                .andDo(print())         //打印出请求和相应的内容
                .andReturn().getResponse().getContentAsString();   //将相应的数据转换为字符串
        System.out.println(responseString);
    }
    @Test
    public void testTransferProxy() throws Exception {
        String responseString = mockMvc.perform(
                get("/transferProxy")    //请求的url,请求的方法是get
                        .contentType(MediaType.APPLICATION_FORM_URLENCODED)  //数据的格式
                        .param("out", "aaa")
                        .param("in", "bbb")
                        .param("money", "100")
        ).andExpect(status().isOk())    //返回的状态是200
//                .andDo(print())         //打印出请求和相应的内容
                .andReturn().getResponse().getContentAsString();   //将相应的数据转换为字符串
        System.out.println(responseString);
    }
}