聚合器和 Resequencer

从概念上讲，An 与 . 它将一系列单独的消息聚合到一条消息中，并且必然更复杂。 默认情况下，聚合器返回一条消息，其中包含来自传入消息的有效负载集合。 相同的规则也适用于 . 以下示例显示了 splitter-aggregator 模式的规范示例：AggregatorSplitterResequencerspring-doc.cn

@Bean
public IntegrationFlow splitAggregateFlow() {
    return IntegrationFlow.from("splitAggregateInput")
            .split()
            .channel(MessageChannels.executor(this.taskExecutor()))
            .resequence()
            .aggregate()
            .get();
}

该方法将列表拆分为单独的消息，并将它们发送到 . 该方法按消息标头中找到的序列详细信息对消息重新排序。 该方法收集这些消息。split()ExecutorChannelresequence()aggregate()spring-doc.cn

但是，您可以通过指定发布策略和关联策略等来更改默认行为。 请考虑以下示例：spring-doc.cn

.aggregate(a ->
        a.correlationStrategy(m -> m.getHeaders().get("myCorrelationKey"))
            .releaseStrategy(g -> g.size() > 10)
            .messageStore(messageStore()))

前面的示例将具有标头的消息关联起来，并在至少累积 10 封邮件后释放这些消息。myCorrelationKeyspring-doc.cn

为 EIP 方法提供了类似的 lambda 配置。resequence()spring-doc.cn