如何使用 apache-camel 构建管道和过滤器 eip 模式答案

【问题标题】：How to build pipes-and-filters eip pattern with apache-camel如何使用 apache-camel 构建管道和过滤器 eip 模式
【发布时间】：2013-03-17 00:19:57
【问题描述】：

我正在尝试做一个 PoC 来实现 pipes and filters eip pattern 和 Apache Camel。

从Camel documentation 开始，我假设每个过滤器都必须实现为Endpoint（“使用 Camel，您可以将处理拆分为多个独立的 Endpoint 实例，然后这些实例可以链接在一起。”）

所以，如果我理解正确，验证过滤器（来自示例）必须实现 Endpoint interface。

“问题”是我不想“重新发明轮子”。因此，我几乎可以肯定我可以使用已经实现的接口，而不是从头开始实现接口。其中一个是BeanEndpoint。

是吗？

我发现了一些管道和过滤器模式的示例 (like this one)，但没有一个显示如何实现 bean。

谁能提供一个bean实现的例子？

TIA，

鲍勃

【问题讨论】：

【解决方案1】：

首先，虽然当您说“camel 将过滤器实现为端点”时我明白了您的意思，但我不会将它们严格归类为端点。在我看来更像是消息转换器/翻译器。

因此，如果您需要根据自己的要求实施自定义过滤器，请使用processor interface。

基本上，编写一个实现 Camel 处理器的类（例如 CustomProcessor）并编写您的自定义过滤器策略。然后，在您的路线中将其称为 to("CustomProcessor")。

处理器页面一定会清除您所有的疑虑，所以请看一下。

谢谢。

【讨论】：

【解决方案2】：

这里列出了 Camel EIP，它们都有示例等等 http://camel.apache.org/eip

因此，对于管道和过滤器，您可以在该链接上找到它并查看一些示例 http://camel.apache.org/pipes-and-filters.html

看来您是 Camel 的新手。然后我建议阅读这篇介绍文章以了解 Camel：http://java.dzone.com/articles/open-source-integration-apache

【讨论】：