Apache Camel-使用多路由生成器进行异常处理

Question

public class RestRouter extends RouteBuilder
{
    @Override
    public void configure() throws Exception
    {
        rest("/sample")
                .post()
                .route()
                .routeId("postSample")
                .to("direct:validate")
                .to("direct:save")
                .endRest();
    }
}

public class CustomRouter extends RouteBuilder
{

    @Override
    public void configure() throws Exception
    {
        onException(ValidationException.class)
                .handled(true)
                .setBody(simple("${exchangeProperty[CamelExceptionCaught]}"))
                .to("bean:exceptionHandler?method=constraintViolationHandler")
                .setHeader(Exchange.CONTENT_TYPE, constant(ErrorResponse.class.getName()))
                .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(HttpStatus.SC_BAD_REQUEST));

        validator()
                .type(Sample.class)
                .withBean("sampleValidator");

        from("direct:validate")
                .to("bean-validator://x"); // Runs javax/Hibernate annotated validations

        from("direct:save")
                .routeId("saveSample")
                .inputTypeWithValidate(Sample.class)
                .to("bean:sampleRepository?method=save");
    }
}

安装程序的问题是，Camel没有为validationexception调用我的自定义异常处理程序。路由SaveSample发生验证异常。下面是我的发现，它是如何进一步深入骆驼处理器类型的。

>

控件将转到RedeliveryErrorHandler的handleException（）中，在那里查找异常策略。失败exchange的根（即RestRouter->postSample)在此应定义异常处理程序。

稍后，Camel转到failingunitofwork（即saveSample）以标识异常处理程序。

这意味着，在下面的表达式中，routeId来自CustomRouter，而exceptionPolicy来自RestRouter。组合不存在，Camel无法找到异常处理器。

处理器=ExceptionPolicy.getErrorHandler(routeId)

在上述背景下，我有以下几个问题

1. 在多个RouterBuilder类型中划分一个功能是一个好的做法吗？
2. 骆驼不应该使用当前的UnitOfWork来解决异常策略吗？
3. 如果提供不同的RouteBuilder类型，Camel是否可以调用我的自定义处理程序？

编辑我不能移动到只有一个RouterBuilder。

• 一个，因为我有一个Apache Avro对象从另一个orchestration服务中加入post的有效载荷，然后通过bean方法，而不是使用Camel的transformer来完成到JPA实体的转换。这种安排不适合Camel调用验证器的方式（请参见contractadvice)。ContractAdvice是一个CamelInternalProcessorAdvice，它应用Transformer（如果intype！=outtype)和Validator。
• 其次，转移到单个RouterBuilder将需要我将Avro-to-Entity逻辑转移到骆驼Transformer中，而这种方法将与我们当前所做的方式有很大不同。但是，可以使用单个RouterBuilder+Transformer+Validator。

Answer 1

让我们看看这个来自Camel In Action的示例，它演示了如何在Java DSL中定义的路由构建器之间重用错误处理。

BaseRouteBuilder和InboxRouteBuilder和OrderRouteBuilder

您可以创建一个基类来设置上下文范围的错误配置，然后您的RouteBuilder类扩展这个基类并调用calling Super.Configure以获得公共配置。