重排序器与聚合器相关，但用途不同。 当聚合器合并消息时，重排序器在不更改消息的情况下传递消息。

功能性

重排序器的工作方式与聚合器类似，从某种意义上说，它使用 将消息存储在组中。 不同之处在于 Resequencer 不会以任何方式处理消息。 相反，它会按标头值的顺序释放它们。CORRELATION_IDSEQUENCE_NUMBER

关于这一点，您可以选择一次发布所有消息（在整个序列之后，根据 和其他可能性）或在有效序列可用时立即发布。 （我们将在本章后面介绍“有效序列”的含义。SEQUENCE_SIZE

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

配置重排序器

请参阅聚合器和重排序器，了解如何在 Java DSL 中配置重排序器。

配置重排序器只需要在 XML 中包含相应的元素。

以下示例显示了重排序器配置：

<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 重排序器的 ID 是可选的。
2 重排序器的输入通道。 必填。
3 重排序器将重新排序的消息发送到的通道。 自选。
4 重排序器将超时消息发送到的通道（如果设置为 ）。 自选。send-partial-result-on-timeoutfalse
5 是在整个消息组到达后立即发送有序序列，还是仅在整个消息组到达后发送。 自选。 （默认值为 .）false
6 对 a 的引用，可用于将消息组存储在其相关键下，直到它们完成。 自选。 （默认值为易失性内存中存储。MessageGroupStore
7 在组到期时，是否应发送有序的组（即使缺少某些消息）。 自选。 （默认值为 false。 请参阅管理聚合器中的状态：MessageGroupStore。
8 向 或 发送回复时要等待的超时间隔。 仅当输出通道具有某些“发送”限制（例如具有固定“容量”）时，才应用它。 在本例中，将抛出 a。 对于实现，将忽略 。 对于 ，来自已计划的过期任务会导致重新计划此任务。 自选。Messageoutput-channeldiscard-channelQueueChannelMessageDeliveryExceptionsend-timeoutAbstractSubscribableChannelgroup-timeout(-expression)MessageDeliveryException
9 对实现消息关联（分组）算法的 Bean 的引用。 Bean 可以是接口的实现，也可以是 POJO。 在后一种情况下，还必须定义属性。 自选。 （默认情况下，聚合器使用标头。CorrelationStrategycorrelation-strategy-methodIntegrationMessageHeaderAccessor.CORRELATION_ID
10 在所引用的 Bean 上定义并实现相关决策算法的方法。 可选，但有限制（需要在场）。correlation-strategycorrelation-strategy
11 表示相关策略的 SpEL 表达式。 例：。 只允许使用其中之一。"headers['something']"correlation-strategycorrelation-strategy-expression
12 对实现发布策略的 Bean 的引用。 Bean 可以是接口的实现，也可以是 POJO。 在后一种情况下，还必须定义属性。 可选（默认情况下，聚合器将使用 header 属性）。ReleaseStrategyrelease-strategy-methodIntegrationMessageHeaderAccessor.SEQUENCE_SIZE
13 在所引用的 Bean 上定义并实现完成决策算法的方法。 可选，但有限制（需要在场）。release-strategyrelease-strategy
14 表示发布策略的 SpEL 表达式。 表达式的根对象是 . 例：。 只允许使用其中之一。MessageGroup"size() == 5"release-strategyrelease-strategy-expression
15 仅当为 . 默认情况下，当 a 配置为使部分组过期时，也会删除空组。 正常释放组后，存在空组。 这是为了能够检测和丢弃延迟到达的邮件。 如果希望空组的过期时间比过期分部组的时间更长，请设置此属性。 然后，空组不会从中删除，直到它们至少在此毫秒数内未被修改。 请注意，空组过期的实际时间也受收割者的超时属性的影响，它可能与此值加上超时一样多。MessageGroupStoreReaper<resequencer>MessageStoreMessageGroupStoreReaperMessageStore
16 请参阅使用 XML 配置聚合器。
17 请参阅使用 XML 配置聚合器。
18 请参阅使用 XML 配置聚合器。
19 请参阅使用 XML 配置聚合器。
20 默认情况下，当组因超时（或超时）而完成时，将保留空组的元数据。 迟到的消息会立即被丢弃。 设置为可完全删除该组。 然后，迟到的消息会启动一个新组，并且在组再次超时之前不会被丢弃。 由于序列范围中的“漏洞”导致超时，新组永远不会正常释放。 空组可以稍后通过与属性一起使用而过期（完全删除）。 从版本 5.0 开始，空组也计划在到期后删除。 默认值为“false”。MessageGroupStoreReapertrueMessageGroupStoreReaperempty-group-min-timeoutempty-group-min-timeout

有关更多信息，另请参阅聚合器过期组。

由于在 Java 类中没有要实现的自定义行为，因此没有对它的注释支持。
1 重排序器的 ID 是可选的。
2 重排序器的输入通道。 必填。
3 重排序器将重新排序的消息发送到的通道。 自选。
4 重排序器将超时消息发送到的通道（如果设置为 ）。 自选。send-partial-result-on-timeoutfalse
5 是在整个消息组到达后立即发送有序序列，还是仅在整个消息组到达后发送。 自选。 （默认值为 .）false
6 对 a 的引用，可用于将消息组存储在其相关键下，直到它们完成。 自选。 （默认值为易失性内存中存储。MessageGroupStore
7 在组到期时，是否应发送有序的组（即使缺少某些消息）。 自选。 （默认值为 false。 请参阅管理聚合器中的状态：MessageGroupStore。
8 向 或 发送回复时要等待的超时间隔。 仅当输出通道具有某些“发送”限制（例如具有固定“容量”）时，才应用它。 在本例中，将抛出 a。 对于实现，将忽略 。 对于 ，来自已计划的过期任务会导致重新计划此任务。 自选。Messageoutput-channeldiscard-channelQueueChannelMessageDeliveryExceptionsend-timeoutAbstractSubscribableChannelgroup-timeout(-expression)MessageDeliveryException
9 对实现消息关联（分组）算法的 Bean 的引用。 Bean 可以是接口的实现，也可以是 POJO。 在后一种情况下，还必须定义属性。 自选。 （默认情况下，聚合器使用标头。CorrelationStrategycorrelation-strategy-methodIntegrationMessageHeaderAccessor.CORRELATION_ID
10 在所引用的 Bean 上定义并实现相关决策算法的方法。 可选，但有限制（需要在场）。correlation-strategycorrelation-strategy
11 表示相关策略的 SpEL 表达式。 例：。 只允许使用其中之一。"headers['something']"correlation-strategycorrelation-strategy-expression
12 对实现发布策略的 Bean 的引用。 Bean 可以是接口的实现，也可以是 POJO。 在后一种情况下，还必须定义属性。 可选（默认情况下，聚合器将使用 header 属性）。ReleaseStrategyrelease-strategy-methodIntegrationMessageHeaderAccessor.SEQUENCE_SIZE
13 在所引用的 Bean 上定义并实现完成决策算法的方法。 可选，但有限制（需要在场）。release-strategyrelease-strategy
14 表示发布策略的 SpEL 表达式。 表达式的根对象是 . 例：。 只允许使用其中之一。MessageGroup"size() == 5"release-strategyrelease-strategy-expression
15 仅当为 . 默认情况下，当 a 配置为使部分组过期时，也会删除空组。 正常释放组后，存在空组。 这是为了能够检测和丢弃延迟到达的邮件。 如果希望空组的过期时间比过期分部组的时间更长，请设置此属性。 然后，空组不会从中删除，直到它们至少在此毫秒数内未被修改。 请注意，空组过期的实际时间也受收割者的超时属性的影响，它可能与此值加上超时一样多。MessageGroupStoreReaper<resequencer>MessageStoreMessageGroupStoreReaperMessageStore
16 请参阅使用 XML 配置聚合器。
17 请参阅使用 XML 配置聚合器。
18 请参阅使用 XML 配置聚合器。
19 请参阅使用 XML 配置聚合器。
20 默认情况下，当组因超时（或超时）而完成时，将保留空组的元数据。 迟到的消息会立即被丢弃。 设置为可完全删除该组。 然后，迟到的消息会启动一个新组，并且在组再次超时之前不会被丢弃。 由于序列范围中的“漏洞”导致超时，新组永远不会正常释放。 空组可以稍后通过与属性一起使用而过期（完全删除）。 从版本 5.0 开始，空组也计划在到期后删除。 默认值为“false”。MessageGroupStoreReapertrueMessageGroupStoreReaperempty-group-min-timeoutempty-group-min-timeout
由于在 Java 类中没有要实现的自定义行为，因此没有对它的注释支持。