摘要
Apache Camel 提供两种领域特定语言（DSL）用于定义路由规则：Java DSL 和 Spring XML DSL。路由定义的核心构建单元由端点（Endpoint）和 处理器（Processor）构成，其中处理器行为可通过表达式（Expression）和 判断（Predicate）进行动态调整。Camel 支持使用多种语言定义表达式与判断，为路由逻辑提供灵活的表达能力。
1.1 实现RouteBuilder类
核心概念
要构建基于DSL的路由规则，需继承RouteBuilder基类并重写其configure()方法。每个RouteBuilder实例在初始化时会被注册到CamelContext容器中，其生命周期通常由部署环境自动管理。
RouteBuilder实现选择
开发者可选择两种实现方式：
- 通用RouteBuilder：org.apache.camel.builder.RouteBuilder，适用于所有容器类型，位于camel-core组件
- Spring专用RouteBuilder：org.apache.camel.spring.SpringRouteBuilder，针对Spring容器优化，支持Spring Bean查找与事务管理，位于camel-spring组件
实现示例
以下代码展示最小化RouteBuilder实现，定义从文件目录读取并转发消息的基础路由：
import org.apache.camel.builder.RouteBuilder;
public class FileRoute extends RouteBuilder {
@Override
public void configure() {
// 文件路由规则：从src/data读取并保留原文件(noop=true)，转发至target/messages
from("file:src/data?noop=true")
.to("file:target/messages");
}
}重要提示
当使用contextScan进行RouteBuilder类扫描时，默认仅识别单例Bean。可通过includeNonSingletons选项启用原型作用域类的扫描。
1.2 基础Java DSL语法
DSL设计原理
领域特定语言（DSL）通过宿主语言API构建，将专业领域操作映射为方法链式调用。例如：
command01().command02().command03()路由规则结构
Apache Camel路由DSL遵循以下基础语法模式：
from("SourceEndpoint")
.processor1().processor2()...
.to("TargetEndpoint");典型路由由以下元素构成：
- 消息源：from()定义消费者端点
- 处理链：可插入多个处理器进行消息转换/过滤
- 消息目标：to()定义生产者端点（非必须）
路由规则语法
Apache Camel定义了用于定义路由规则的路由DSL。您可以使用此DSL在实现主体中定义规则RouteBuilder.configure()。
路由规则语法
本地规则始终以from("EndpointURL")方法开头，该方法指定路由规则的消息源（消费者端点）。然后，您可以在规则中添加任意长的处理器链（例如filter()）。通常，您可以使用to("EndpointURL")方法来结束规则，该方法指定通过规则的消息的目标（生产者端点）。但是，不一定总是要以to()结束规则。有其他方法可以在规则中指定消息目标。
注意
您还可以定义一个全局路由规则，第一步是用一种特殊的处理器类型的规则（如`intercept()`，`exception()`或`errorHandler()`）。全局规则不在本文的范围内。
交换对象（Exchange）
Exchange是路由中消息传递的核心载体，包含：
- In Message：当前处理消息，包含Body、Headers、Attachments
- Out Message：临时存放处理结果，可自动提升为新的In Message
- 消息交换模式（MEP）：定义交互类型（如InOnly、InOut）
- 属性列表：存放路由处理过程中的元数据
消息交换模式（MEP）
模式 | 描述 |
InOnly | 单向异步消息（默认） |
InOut | 请求-响应模式 |
InOptionalOut | 可选响应模式 |
OutOnly | 特殊场景单向消息 |
分组交换（GroupedExchange）
支持将多个Exchange封装为列表，适用于聚合场景，通过Exchange.GROUPED_EXCHANGE属性访问。
1.3 Spring XML路由配置
命名空间声明
Spring XML DSL使用专用命名空间：
编辑器建议
推荐使用支持XML Schema的IDE（如IntelliJ IDEA、Eclipse）以获得智能提示和语法校验。编辑时可临时指定具体版本Schema：
xsi:schemaLocation="
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring-2.3.0.xsd"
1.4 端点详解
端点URI结构
scheme:contextPath[?option1=value1&option2=value2...]
示例：
ftp://user@host:port/directory?password=secret&binary=true
特殊语法处理
- 长URI拆分：支持换行符分割
- 时间段表示：增强可读性
timer://daily?period=1h30m45s // 1小时30分45秒- 原始值声明：使用RAW()避免编码
.to("smtp://user@host?password=RAW(ab@c!123)")- 资源引用：通过ref:从注册表加载
from("velocity:ref:myTemplateBean")端点类型
- 消费者端点：路由起点，主动接收消息
from("jms:queue:orders").process(...)- 生产者端点：路由中间或终点，被动发送消息
to("http://api.service.com/update")1.5 处理器体系
核心处理器分类
处理器 | 功能描述 | XML元素 |
filter() | 基于判断过滤消息 | |
choice() | 条件分支路由 | |
split() | 消息拆分处理 | |
aggregate() | 消息聚合 | |
transform() | 消息内容转换 | |
throttle() | 流量控制 | |
loadBalance() | 负载均衡 |
典型应用示例
条件路由：
from("direct:start")
.choice()
.when(header("priority").isGreaterThan(10))
.to("jms:priorityQueue")
.otherwise()
.to("jms:standardQueue");
消息过滤：
${body} contains 'urgent'
自定义处理器：
public class HeaderRemover implements Processor {
public void process(Exchange exchange) {
exchange.getIn().removeHeader("sensitiveData");
}
}
// 路由中使用
from("direct:clean")
.process(new HeaderRemover())
.to("mock:processed");
最佳实践
- 路由拆分：复杂逻辑应拆分为多个子路由，通过direct或seda组件连接
- 异常处理：全局配置错误处理机制
errorHandler(deadLetterChannel("jms:deadLetters"));- 性能优化：高并发场景配置线程池
from("jms:highVolume").threads().poolSize(20).maxQueueSize(1000).to("bean:parallelProcessor");通过合理组合这些构建块，开发者可以构建出高效、可靠的企业集成解决方案。建议结合《Apache Camel开发指南》中的EIP模式进行深度设计。
