第 35 章 实施处理器
摘要
Apache Camel 允许您实施自定义处理器。然后,您可以将自定义处理器插入到路由中,以便在通过路由时对交换对象执行操作。
35.1. 处理模型
pipelining 模型
pipelining 模型 描述了处理器在 第 5.4 节 “管道和过滤器” 中排列的方式。pipelining 是处理一系列端点(生产者端点只是特殊类型的处理器)的最常见方法。当处理器以这种方式排列时,交换的 In 和 Out 信息将按照 图 35.1 “pipelining Model” 所示进行处理。
图 35.1. pipelining Model
管道中的处理器看起来像服务,其中 In 消息与请求类似,而 Out 消息类似于回复。实际上,在现实管道中,管道中的节点通常由 Web 服务端点(如 CXF 组件)实现。
例如,例 35.1 “Java DSL Pipeline” 显示一个 Java DSL 管道,它由两个处理器、ProcessorA
、ProcessorB
和生成者端点 TargetURI 组成。
例 35.1. Java DSL Pipeline
from(SourceURI).pipeline(ProcessorA, ProcessorB, TargetURI);