摘要

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）

分组交换（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 处理器体系

核心处理器分类

典型应用示例

条件路由：

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

最佳实践

1. 路由拆分：复杂逻辑应拆分为多个子路由，通过direct或seda组件连接
2. 异常处理：全局配置错误处理机制

errorHandler(deadLetterChannel("jms:deadLetters"));

3. 性能优化：高并发场景配置线程池

from("jms:highVolume").threads().poolSize(20).maxQueueSize(1000).to("bean:parallelProcessor");

通过合理组合这些构建块，开发者可以构建出高效、可靠的企业集成解决方案。建议结合《Apache Camel开发指南》中的EIP模式进行深度设计。