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

Question

我正在尝试进行 PoC 以实现 pipes and filters eip pattern与 Apache Camel .

来自Camel documentation ，我假设每个过滤器必须实现为 Endpoint (“使用 Camel，您可以将处理拆分为多个独立的端点实例，然后将这些实例链接在一起。”)

所以，如果我理解正确的话，验证过滤器(来自示例)必须实现 Endpoint interface .

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

是吗？

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

有人可以提供一个 bean 实现示例吗？

TIA，

鲍勃

Answer 1

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

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

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

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

此外，我假设您知道 camel message-filter pattern .

谢谢。