聚合器和 Resequencer
一Aggregator在概念上与Splitter.
它将一系列单独的消息聚合到一条消息中，并且必然更复杂。
默认情况下，聚合器返回一条消息，其中包含来自传入消息的有效负载集合。
相同的规则也适用于Resequencer.
以下示例显示了 splitter-aggregator 模式的规范示例：
@Bean
public IntegrationFlow splitAggregateFlow() {
return IntegrationFlow.from("splitAggregateInput")
.split()
.channel(MessageChannels.executor(this.taskExecutor()))
.resequence()
.aggregate()
.get();
}这split()方法将列表拆分为单独的消息，并将它们发送到ExecutorChannel.
这resequence()method 按消息标头中找到的序列详细信息对消息进行重新排序。
这aggregate()method 收集这些消息。
但是，您可以通过指定发布策略和关联策略等来更改默认行为。 请考虑以下示例：
.aggregate(a ->
a.correlationStrategy(m -> m.getHeaders().get("myCorrelationKey"))
.releaseStrategy(g -> g.size() > 10)
.messageStore(messageStore()))前面的示例将具有myCorrelationKeyheaders 并在至少累积了 10 封邮件后释放邮件。
为resequence()弹性公网 IP 方法。