概念

使用组合消息处理器来处理组合消息。组合消息处理器将消息拆分,将子消息路由到适当的目的地,并将响应重新聚合回单个消息。

阅读全文 »

概念

Camel 支持来自 EIP 模式的 Resequencer。

我们如何才能将相关但无序的消息流恢复到正确的顺序?

使用有状态过滤器 Resequencer 来收集和重新排序消息,以便它们可以按指定顺序发布到输出通道。

Camel 中的 Resequencer 实现使用 Expression 作为 Comparator 重新排序消息的方法。通过使用表达式,消息可以很容易地按消息头或消息的另一部分重新排序。

阅读全文 »

概念

如果消息包含多个元素,我们如何处理它,每个元素都可能需要以不同的方式处理?

使用拆分器将复合消息分解为一系列单独的消息,每个消息都包含与一个项目相关的数据。

EIP 模式中的分解器允许您将消息拆分为多个部分并单独处理它们。

阅读全文 »

概念

EIP 模式中的聚合器允许您将多个消息组合成一条消息。

我们如何组合单个但相关消息的结果,以便将它们作为一个整体进行处理?

使用有状态过滤器(聚合器)来收集和存储单个消息,直到收到完整的相关消息集。然后,聚合器发布从各个消息中提取的单个消息。

聚合器是最复杂的 EIP 之一,具有许多功能和配置。

阅读全文 »

命名的优点在于易于理解,把定义的流程场景下,下面记录一下,camel 内部对 CamelContext 和 route 自动命名的实现

阅读全文 »

概念

Loop EIP 允许多次处理消息,每次迭代可能采用不同的方式。主要在测试期间有用。

即循环执行

需要注意的是,loop 并不是迭代器,如果要使用迭代器模式,应该使用 split。

使用场景:对同一消息进行重复处理,比如性能测试。

阅读全文 »

概念

EndpointRouteBuilder 与 RouteBuilder 同样是一个路由构建器,它允许使用类型安全的端点URL配置。

注意点:其只适用于 Java DSL

阅读全文 »
0%