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");
    }
}

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

处理事务路由中的异常不是使用 onException （） 的简单方法是使用路由上的 doTry （） 和 doCatch （） 子句。例如，以下代码演示了如何捕获和处理事务路由中的 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 （） 子句不会重新增长异常，因此可以避免文件端点不会执行任何重试和无限循环。