此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Integration 6.4.3！spring-doc.cadn.net.cn

重定序器

resequencer 与聚合器相关，但用途不同。当聚合器合并消息时，resequencer 传递消息而不更改它们。spring-doc.cadn.net.cn

功能性

resequencer 的工作方式与聚合器类似，因为它使用CORRELATION_ID将消息存储在组中。区别在于 Resequencer 不以任何方式处理消息。相反，它会按照SEQUENCE_NUMBER标头值。spring-doc.cadn.net.cn

关于这一点，您可以选择一次释放所有消息（在整个序列之后，根据SEQUENCE_SIZE和其他可能性）或有效序列可用时立即进行。（我们将在本章后面介绍我们所说的 “有效序列” 的含义。spring-doc.cadn.net.cn

resequencer 旨在对具有较小间隙的相对较短的消息序列进行重新排序。如果您有大量具有许多间隙的不相交序列，则可能会遇到性能问题。

配置 Resequencer

有关在 Java DSL 中配置重新排序器的信息，请参阅聚合器和重新排序器。spring-doc.cadn.net.cn

配置 resequencer 只需要在 XML 中包含适当的元素。spring-doc.cadn.net.cn

以下示例显示了 resequencer 配置：spring-doc.cadn.net.cn

<int:channel id="inputChannel"/>

<int:channel id="outputChannel"/>

<int:resequencer id="completelyDefinedResequencer"  (1)
  input-channel="inputChannel"  (2)
  output-channel="outputChannel"  (3)
  discard-channel="discardChannel"  (4)
  release-partial-sequences="true"  (5)
  message-store="messageStore"  (6)
  send-partial-result-on-expiry="true"  (7)
  send-timeout="86420000"  (8)
  correlation-strategy="correlationStrategyBean"  (9)
  correlation-strategy-method="correlate"  (10)
  correlation-strategy-expression="headers['something']"  (11)
  release-strategy="releaseStrategyBean"  (12)
  release-strategy-method="release"  (13)
  release-strategy-expression="size() == 10"  (14)
  empty-group-min-timeout="60000"  (15)

  lock-registry="lockRegistry"  (16)

  group-timeout="60000"  (17)
  group-timeout-expression="size() ge 2 ? 100 : -1"  (18)
  scheduler="taskScheduler" />  (19)
  expire-group-upon-timeout="false" />  (20)

1	resequencer 的 id 是可选的。
2	resequencer 的 input channel。必填。
3	resequencer 将重新排序的消息发送到的通道。自选。
4	resequencer 将超时消息发送到的通道（如果`send-partial-result-on-timeout`设置为`false`). 自选。
5	是立即发送有序序列，还是在整个消息组到达后才发送。自选。（默认值为`false`.)
6	对`MessageGroupStore`这可用于将消息组存储在其关联键下，直到它们完成。自选。（默认值为 volatile 内存存储。
7	在组过期时，是否应发送有序的组（即使缺少某些消息）。自选。（默认值为 false。看在 Aggregator 中管理状态：`MessageGroupStore`.
8	发送回复时要等待的超时间隔`Message`到`output-channel`或`discard-channel`. 仅当输出通道具有一些 “发送” 限制（例如`QueueChannel`具有固定的 'capacity' 。在这种情况下，`MessageDeliveryException`被抛出。这`send-timeout`被忽略`AbstractSubscribableChannel`实现。为`group-timeout(-expression)`这`MessageDeliveryException`从 Scheduled Expired 任务中，将重新计划此任务。自选。
9	对实现消息关联（分组）算法的 Bean 的引用。该 bean 可以是`CorrelationStrategy`interface 或 POJO 的 API API 中。在后一种情况下，`correlation-strategy-method`属性。自选。（默认情况下，聚合器使用`IntegrationMessageHeaderAccessor.CORRELATION_ID`标头。
10	在 Bean 上定义的方法，该方法由`correlation-strategy`并且实现了 Correlation Decision 算法。可选，但有限制（需要`correlation-strategy`在场）。
11	表示关联策略的 SPEL 表达式。例：`"headers['something']"`. 只有其中之一`correlation-strategy`或`correlation-strategy-expression`是允许的。
12	对实现发布策略的 bean 的引用。该 bean 可以是`ReleaseStrategy`interface 或 POJO 的 API API 中。在后一种情况下，`release-strategy-method`属性。可选（默认情况下，聚合器将使用`IntegrationMessageHeaderAccessor.SEQUENCE_SIZE`header 属性）。
13	在 Bean 上定义的方法，该方法由`release-strategy`并且实现了 completion decision 算法。可选，但有限制（需要`release-strategy`在场）。
14	表示发布策略的 SPEL 表达式。表达式的根对象是一个`MessageGroup`. 例：`"size() == 5"`. 只有其中之一`release-strategy`或`release-strategy-expression`是允许的。
15	仅当`MessageGroupStoreReaper`配置为`<resequencer>` `MessageStore`. 默认情况下，当`MessageGroupStoreReaper`配置为使部分组过期，则还会删除空组。正常释放组后，存在空组。这是为了能够检测和丢弃延迟到达的消息。如果您希望使空组过期的时间比使部分组过期的时间更长，请设置此属性。然后，空组不会从`MessageStore`直到它们至少在此毫秒数内未被修改。请注意，使空 group 过期的实际时间也受收割者的 timeout 属性的影响，它可能等于此值加上 timeout。
16	请参阅使用 XML 配置聚合器。
17	请参阅使用 XML 配置聚合器。
18	请参阅使用 XML 配置聚合器。
19	请参阅使用 XML 配置聚合器。
20	默认情况下，当组由于超时（或由`MessageGroupStoreReaper`），则会保留空组的元数据。延迟到达的消息将被立即丢弃。将此项设置为`true`以完全删除该组。然后，延迟到达的消息将启动一个新组，并且在该组再次超时之前不会被丢弃。由于导致超时的序列范围中存在 “hole” ，因此新组永远不会正常释放。空组可以在以后使用`MessageGroupStoreReaper`与`empty-group-min-timeout`属性。从版本 5.0 开始，空组也会计划在`empty-group-min-timeout`流逝。默认值为 'false'。

另请参阅 Aggregator Expiring Groups 了解更多信息。spring-doc.cadn.net.cn

由于在 Java 类中没有要为 resequencers 实现的自定义行为，因此没有对它的 Comments 支持。