摘要

Apache Camel提供丰富的处理器和组件，支持通过链式调用构建复杂路由。本章将深入讲解路由构建的核心原理，帮助开发者掌握基础构建模块的使用方法。

2.1 管道处理机制

核心概念

Apache Camel采用类似UNIX管道的处理范式作为路由节点连接的核心模式。如同UNIX命令ls | more将目录列表传递给分页工具，Camel的管道机制将前一个处理器的输出作为下一个处理器的输入。

处理器节点分类

除初始端点外，路由中的每个节点都是
org.apache.camel.Processor接口的实现。常见的处理器包括：

消息过滤：filter()
延迟处理：delayer()
消息体操作：setBody()
头部操作：setHeader()
端点转发：to()

根据处理方式差异，处理器可分为两类：

In消息修改型：仅修改入站消息

处理器修改入栈信息

from("activemq:orderQueue")
    .setHeader("BillingSystem", xpath("/order/billingSystem"))
    .to("activemq:billingQueue");

Out消息生成型：创建出站消息

from("activemq:orderQueue")
    .transform(constant("DummyBody"))
    .to("activemq:billingQueue");

交换模式处理

InOnly模式（异步）

默认管道模式，自动串联处理节点：

from("activemq:userdataQueue")
    .to(ExchangePattern.InOut, "velocity:file:AdressTemplate.vm")
    .to("activemq:envelopeAddresses");

InOut模式（同步）

支持RPC风格请求-响应，需确保最终节点生成Out消息：

from("jetty:http://localhost:8080/foo")
    .to("cxf:bean:addAccountDetails")
    .to("cxf:bean:getCreditRating")
    .to("cxf:bean:processTransaction");

2.2 多输入处理

独立输入源

from("URI1", "URI2", "URI3").to("DestinationUri");

分段路由整合

使用Direct/SEDA/VM端点桥接路由段：

内容增强模式

from("jms:queue:creditRequests")
    .pollEnrich("file:src/data/ratings?noop=true", new GroupedExchangeAggregationStrategy())
    .bean(new MergeCreditRequestAndRatings(), "merge")
    .to("jms:queue:reformattedRequests");

2.3 异常处理体系

多粒度控制

路由级：doTry/doCatch/doFinally
构建器级：onException
全局级：errorHandler

onException策略

onException(ValidationException.class)
    .maximumRedeliveries(5)
    .handled(true)
    .to("activemq:validationFailed");

错误处理程序

传播策略

抑制异常：.handled(true)
继续处理：.continued(true)
定制响应：.transform().constant("Custom Error")

2.4 Bean集成

注册机制

支持Spring/Blueprint/OSGi等多种注册方式

调用方式：直接调用

from("file:data/inbound")
    .bean(MyBeanProcessor.class, "processBody")
    .to("file:data/outbound");

调用方式：参数绑定

public void processExchange(
    @Header("user") String user,
    @Body String body,
    Exchange exchange) {
    // 处理逻辑
}

2.5 消息转换

数据格式处理

编组：Java对象 → 低级格式
解组：低级格式 → Java对象

支持格式：

JAXB
XMLBeans
XStream

from("jms:orderQueue")
    .unmarshal(jaxb)
    .process(new OrderProcessor())
    .marshal(xmlBeans)
    .to("file:processedOrders");

2.6 性能优化

线程管理

路由控制

延迟启动：autoStartup="false"
有序启动：startupOrder
优雅关闭：shutdownRunningTask=CompleteAllTasks

2.7 监控管理

JMX集成

指标收集

context.addRoutePolicyFactory(new MetricsRoutePolicyFactory());

2.8 最佳实践

路由ID规范化：为每个路由设置唯一ID
异常隔离：不同异常类型分开处理
资源清理：及时关闭非托管资源
性能监控：启用JMX和指标收集
配置外化：使用属性占位符

通过深入理解这些核心原理，开发者可以构建出健壮、高效的企业集成解决方案，充分发挥Apache Camel在复杂系统集成中的优势。

基于Apache Camel的企业集成模式实践:第二章-路由构建基本原则