9.5. 错误处理和回滚

您可以使用以下方法之一来回滚事务：

9.5.1.1. 使用运行时例外来触发回滚

回滚 Spring 事务的最常见方法是抛出运行时（未检查）异常。换句话说，异常是 java.lang.RuntimeException 的一个实例或子类。java.lang.Error 类型的 Java 错误也会触发事务回滚。另一方面，检查异常不会触发回滚。

下图总结了触发回滚的灰色类如何影响事务的 Java 错误和例外。

注意

Spring 框架也提供 XML 注解系统，您可以指定哪些例外，或者不应触发回滚。详情请查看 Spring 参考指南中的"回滚"。

警告

如果在事务中处理运行时异常，即在异常的几率前，与交易分离的代码不同，则不会回滚事务。详情请查看 第 9.5.2 节 “如何定义死信队列”。

from("file:src/data?noop=true")
    .transacted()
    .bean("accountService","credit")
    .choice().when(xpath("/transaction/transfer[amount > 100]"))
        .rollback()
    .otherwise()
        .to("direct:txsmall");

from("direct:txsmall")
    .bean("accountService","debit")
    .bean("accountService","dumpTable")
    .to("file:target/messages/small");

from("file:src/data?noop=true")
    .transacted()
    .bean("accountService","credit")
    .choice().when(xpath("/transaction/transfer[amount > 100]"))
        .markRollbackOnly()
    .otherwise()
        .to("direct:txsmall");
...

要跟踪失败的事务，您可以定义 onException（） 子句，它可让您将相关交换对象重新放入一个死信队列。但是，在事务上下文中使用时，您需要仔细了解如何定义 onException（） 子句，因为异常处理和事务处理间的潜在的交互。下例演示了定义 onException（） 子句的正确方法，假设您需要阻止重新行异常。

// Java
import org.apache.camel.builder.RouteBuilder;

public class MyRouteBuilder extends RouteBuilder {
    ...
    public void configure() {
        onException(IllegalArgumentException.class)
            .maximumRedeliveries(1)
            .handled(true)
            .to("file:target/messages?fileName=deadLetters.xml&fileExist=Append")
            .markRollbackOnly();  // NB: Must come *after* the dead letter endpoint.

        from("file:src/data?noop=true")
            .transacted()
            .bean("accountService","credit")
            .bean("accountService","debit")
            .bean("accountService","dumpTable")
            .to("file:target/messages");
    }
}

在前面的示例中，对Exception（） 配置为捕获 IllegalArgumentException 异常，并将出错交换发送到死信文件 deadLetters.xml。当然，您可以更改此定义，以捕获应用程序中出现的任何异常。异常 rethrow 行为和事务回滚行为由 onException（） 中的以下特殊设置控制：

在事务路由中使用 doTry（） 和 doCatch（） 子句，不使用 onException（） 处理异常的简单方法。例如，以下代码显示了在事务路由中如何捕获和处理 IllegalArgumentException，而不考虑陷入无限循环的风险。

// Java
import org.apache.camel.builder.RouteBuilder;

public class MyRouteBuilder extends RouteBuilder {
    ...
    public void configure() {
        from("file:src/data?noop=true")
            .doTry()
                .to("direct:split")
            .doCatch(IllegalArgumentException.class)
                .to("file:target/messages?fileName=deadLetters.xml&fileExist=Append")
            .end();

        from("direct:split")
            .transacted()
            .bean("accountService","credit")
            .bean("accountService","debit")
            .bean("accountService","dumpTable")
            .to("file:target/messages");
    }
}

在本例中，路由被分成两个片段。第一个网段（来自 file:src/data 端点）接收传入的交换，并使用 doTry（） 和 doCatch（） 执行异常处理。第二段（来自 direct:split 端点）执行所有事务的工作。如果这个事务段中发生异常，它将第一个都传播到 transacted（） 命令，从而导致回滚当前事务，然后然后由第一个路由网段中的 doCatch（） 子句进行接收。doCatch（） 子句不会重新定义异常，因此文件端点不会进行任何重试，避免无限循环。