5.4. 管道和过滤器

概述

图 5.4 “管道和过滤器模式” 中显示的 管道和过滤器 模式描述了通过创建过滤器链来构建路由的方法，其中一个过滤器的输出会发送到管道中下一过滤器的输入（类似于 UNIX pipe 命令）。管道方法的优势在于，它可让您编写服务（某些服务可能是 Apache Camel 应用程序外部），以创建更加复杂的消息处理。

图 5.4. 管道和过滤器模式

管道和过滤器模式

InOut Exchange pattern 的管道

通常，管道中的所有端点都有输入(In message)和输出(Out message)，这意味着它们与 InOut 消息交换模式兼容。通过 InOut 管道的典型消息流在 图 5.5 “InOut Exchanges 的管道” 中显示。

图 5.5. InOut Exchanges 的管道

InOut 交换的管道

管道将每个端点的输出连接到下一个端点的输入。最终端点的 Out 消息将发回到原始调用者。您可以为这个管道定义路由，如下所示： 

from("jms:RawOrders").pipeline("cxf:bean:decrypt", "cxf:bean:authenticate", "cxf:bean:dedup", "jms:CleanOrders");

同一路由可以在 XML 中配置，如下所示： 

<camelContext id="buildPipeline" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="jms:RawOrders"/>
    <to uri="cxf:bean:decrypt"/>
    <to uri="cxf:bean:authenticate"/>
    <to uri="cxf:bean:dedup"/>
    <to uri="jms:CleanOrders"/>
  </route>
</camelContext>

XML 中没有专用的管道元素。与 元素的组合 与 元素是语义等效的管道。请参阅 “pipeline （）和 to （）DSL 命令的比较”一节。

InOnly 和 RobustInOnly Exchange 模式的管道

如果管道中的端点没有可用的 Out 消息（如 InOnly 和 Robust InOnly Exchange 模式的情况），则管道无法以正常方式连接。在这种情况下，管道通过将原始 In 消息的副本传递给管道中的每个端点（如 图 5.6 “InOnly Exchanges 的管道” 所示）。这个管道类型等同于带有固定目的地的接收者列表（请参阅 第 8.3 节 “接收者列表”）。

图 5.6. InOnly Exchanges 的管道

InOnly Exchanges 的管道

此管道的路由使用与 InOut 管道相同的语法来定义(Java DSL 或在 XML 中)。

pipeline （）和 to （）DSL 命令的比较

在 Java DSL 中，您可以使用以下任意语法来定义管道路由：

  • 使用 pipeline （）处理器命令 Feature-方式使用管道处理器来构建管道路由，如下所示： 

    from(SourceURI).pipeline(FilterA, FilterB, TargetURI);

  • 使用 to （）命令 主机上运行的 to （） 命令构建管道路由，如下所示： 

    from(SourceURI).to(FilterA, FilterB, TargetURI);

    或者，您可以使用等同的语法： 

    from(SourceURI).to(FilterA).to(FilterB).to(TargetURI);

在使用 to （） 命令语法时要小心，因为它 并不总是 等同于管道处理器。在 Java DSL 中，a to （） 的含义可通过路由中的前面的 命令进行修改。例如，当 multicast （） 命令前面执行 to （） 命令时，它会将列出的端点绑定到多播模式，而不是管道模式（请参阅 第 8.13 节 “多播”）。