第 306 章 简单的 JMS Batch 组件

从 Camel 版本 2.16 开始提供

SJMS Batch 是专门的组件，可用于来自 JMS 队列的高性能、交易型批处理消耗。它可以被认为是仅限消费者组件和聚合器的混合。

Camel 中的常见用例是消耗来自队列的消息，并在将聚合状态发送到另一个端点前聚合它们。为确保在系统执行处理失败时数据不会丢失，它通常在队列中的事务中消耗，一次聚合存储在持久 聚合Repository 中，如 JDBC 组件 中找到的。

聚合器模式的行为涉及从 AggregationRepository 获取数据，然后再聚合传入消息，之后再写入结果。本质上，当聚合的工件数量增加时，读取和写入会逐渐长。使用表示此问题影响的任意时间单位的粗略示例如下：

相反，使用 SJMS 批处理组件消耗性能是线性的。在获取下一个消息前，使用 AggregationStrategy 来消耗并聚合每个消息。因为所有消耗和聚合都是在单个 JMS 事务中执行的，因此不需要外部存储才能保持中间状态 - 这可避免上面描述的读写成本。实际上，这会产生多个数量较高的吞吐量顺序。

满足完成条件后，从第一个消息起按大小或周期，聚合的 Exchange 将传递到路由中。在处理此 交换 过程中，如果抛出异常或系统关闭，则所有原始使用的消息都会返回到队列（或根据代理配置），所有原始使用的消息都会备份到死信队列。

与使用常规聚合器不同，没有聚合条件的工具，这意味着无法批量使用多个消息组。所有使用的消息都会聚合到一个批处理中。

提供的多个 JMS 使用者支持允许您利用一个路由并行使用，并且同时使用 JMS 消息组等功能来分组相关消息。

Maven 用户需要将以下依赖项添加到这个组件的 pom.xml 中：

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-sjms</artifactId>
    <version>x.x.x</version>
    <!-- use the same version as your Camel core version -->
</dependency>

sjms:[queue:]destinationName[?options]

sjms:FOO.BAR

sjms:queue:FOO.BAR