意外回滚异常:事务已回滚,因为它已标记为仅回滚

2022-08-31 14:23:11

我有这个场景:

  1. 传入消息表中提取(读取和删除)记录
  2. 读取记录内容
  3. 向某些表格插入内容
  4. 如果在步骤 1-3 中发生错误(任何异常),请将错误记录插入到传出消息表中
  5. 否则,将成功记录插入到传出消息

因此,步骤 1、2、3、4 应在事务中,或步骤 1、2、3、5 中

我的流程从这里开始(这是一个计划任务):

public class ReceiveMessagesJob implements ScheduledJob {
// ...
    @Override
    public void run() {
        try {
            processMessageMediator.processNextRegistrationMessage();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
// ...
}

我在ProcessMessageMediator中的主要功能(processNextRegistrationMessage):

public class ProcessMessageMediatorImpl implements ProcessMessageMediator {
// ...
    @Override
    @Transactional
    public void processNextRegistrationMessage() throws ProcessIncomingMessageException {
        String refrenceId = null;
        MessageTypeEnum registrationMessageType = MessageTypeEnum.REGISTRATION;
        try {
            String messageContent = incomingMessageService.fetchNextMessageContent(registrationMessageType);
            if (messageContent == null) {
                return;
            }
            IncomingXmlModel incomingXmlModel = incomingXmlDeserializer.fromXml(messageContent);
            refrenceId = incomingXmlModel.getRefrenceId();
            if (!StringUtil.hasText(refrenceId)) {
                throw new ProcessIncomingMessageException(
                        "Can not proceed processing incoming-message. refrence-code field is null.");
            }
            sqlCommandHandlerService.persist(incomingXmlModel);
        } catch (Exception e) {
            if (e instanceof ProcessIncomingMessageException) {
                throw (ProcessIncomingMessageException) e;
            }
            e.printStackTrace();
            // send error outgoing-message
            OutgoingXmlModel outgoingXmlModel = new OutgoingXmlModel(refrenceId,
                    ProcessResultStateEnum.FAILED.getCode(), e.getMessage());
            saveOutgoingMessage(outgoingXmlModel, registrationMessageType);
            return;
        }
        // send success outgoing-message
        OutgoingXmlModel outgoingXmlModel = new OutgoingXmlModel(refrenceId, ProcessResultStateEnum.SUCCEED.getCode());
        saveOutgoingMessage(outgoingXmlModel, registrationMessageType);
    }

    private void saveOutgoingMessage(OutgoingXmlModel outgoingXmlModel, MessageTypeEnum messageType)
            throws ProcessIncomingMessageException {
        String xml = outgoingXmlSerializer.toXml(outgoingXmlModel, messageType);
        OutgoingMessageEntity entity = new OutgoingMessageEntity(messageType.getCode(), new Date());
        try {
            outgoingMessageService.save(entity, xml);
        } catch (SaveOutgoingMessageException e) {
            throw new ProcessIncomingMessageException("Can not proceed processing incoming-message.", e);
        }
    }
// ...
}

正如我所说,如果在步骤1-3中发生任何异常,我想插入一个错误记录:

catch (Exception e) {
    if (e instanceof ProcessIncomingMessageException) {
        throw (ProcessIncomingMessageException) e;
    }
    e.printStackTrace();
    //send error outgoing-message
    OutgoingXmlModel outgoingXmlModel = new OutgoingXmlModel(refrenceId,ProcessResultStateEnum.FAILED.getCode(), e.getMessage());
    saveOutgoingMessage(outgoingXmlModel, registrationMessageType);
    return;
}

它是 SqlCommandHandlerServiceImpl.persist() 方法:

public class SqlCommandHandlerServiceImpl implements SqlCommandHandlerService {
// ...
    @Override
    @Transactional
    public void persist(IncomingXmlModel incomingXmlModel) {
        Collections.sort(incomingXmlModel.getTables());
        List<ParametricQuery> queries = generateSqlQueries(incomingXmlModel.getTables());
        for (ParametricQuery query : queries) {
            queryExecuter.executeQuery(query);
        }
    }
// ...
}

但是当 sqlCommandHandlerService.persist() 抛出异常(这里是 org.hibernate.exception.ConstraintViolationException 异常)时,在 OutgoingMessage 表中插入错误记录后,当事务想要提交时,我得到 UnexpectedRollbackException。我不知道我的问题在哪里:

Exception in thread "null#0" org.springframework.transaction.UnexpectedRollbackException: Transaction rolled back because it has been marked as rollback-only
    at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:717)
    at org.springframework.transaction.interceptor.TransactionAspectSupport.commitTransactionAfterReturning(TransactionAspectSupport.java:394)
    at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:120)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
    at org.springframework.aop.framework.Cglib2AopProxy$DynamicAdvisedInterceptor.intercept(Cglib2AopProxy.java:622)
    at ir.tamin.branch.insuranceregistration.services.schedular.ReceiveMessagesJob$$EnhancerByCGLIB$$63524c6b.run(<generated>)
    at ir.asta.wise.core.util.timer.JobScheduler$ScheduledJobThread.run(JobScheduler.java:132)

我正在使用hibernate-4.1.0-Final,我的数据库是oracle,这是我的事务管理器bean:

<bean id="transactionManager"
    class="org.springframework.orm.hibernate4.HibernateTransactionManager">
    <property name="sessionFactory" ref="sessionFactory" />
</bean>

<tx:annotation-driven transaction-manager="transactionManager"
    proxy-target-class="true" />

提前致谢。


答案 1

这是正常行为,原因是您的方法在执行时需要 TX(因为它标有注释)。但是当它在 内部调用时,因为有一个可用的 TX,容器不会创建一个新的,而是使用现有的 TX。因此,如果方法中发生任何异常,则会导致 TX 设置为 (即使您在调用方中捕获异常并忽略它)。sqlCommandHandlerService.persist@TransactionalprocessNextRegistrationMessagesqlCommandHandlerService.persistrollBackOnly

要解决此问题,您可以对事务使用传播级别。看看这个,找出哪种传播最适合您的要求。

更新;阅读此内容!

在一位同事向我提出几个关于类似情况的问题之后,我觉得这需要一点澄清。
虽然传播解决了这些问题,但你应该非常小心地使用它们,除非你绝对理解它们的含义以及它们是如何工作的,否则不要使用它们。你最终可能会保留一些数据,并回滚一些你不希望它们以这种方式工作的其他数据,事情可能会变得非常糟糕。


编辑 链接到当前版本的文档

答案 2

希亚姆的答案是正确的。我以前已经遇到过这个问题。这不是问题,这是一个SPRING功能。“事务已回滚,因为它已标记为仅回滚”是可以接受的。

结论

  • USE REQUIRES_NEW 如果要提交异常之前执行的操作(本地提交)
  • 如果您只想在所有进程完成时才提交(全局提交),则使用必需,并且您只需要忽略“事务已回滚,因为它已被标记为仅回滚”异常。但是你需要尝试在调用方进程旁边捕获NextRegistrationMessage()才能有一个有意义的日志。

让我解释一下更多细节:

问题:我们有多少笔交易?答:只有一个

因为您配置了传播PROPAGATION_REQUIRED,所以@Transaction persist() 与调用方进程NextRegistrationMessage()使用相同的事务。实际上,当我们遇到异常时,Spring 将为 TransactionManager 设置 rollBackOnly,因此 Spring 将只回滚一个事务。

问题:但是我们在外面有一个尝试捕获(),为什么会发生这个例外?答案 因为独特的交易

  1. 当 persist() 方法有异常时
  2. 去外面的渔获物

    Spring will set the rollBackOnly to true -> it determine we must 
    rollback the caller (processNextRegistrationMessage) also.
    
  3. persist() 将首先回滚自身。

  4. 抛出一个意外的回滚异常来通知,我们还需要回滚调用方。
  5. run() 中的 try-catch 将捕获 UnexpectedRollbackException 并打印堆栈跟踪

问题:为什么我们将传播更改为REQUIRES_NEW,它有效?

答:因为现在进程NextRegistrationMessage()和perast()位于不同的事务中,因此它们仅回滚其事务。

谢谢


推荐