spring - Spring集成-以不同方式处理聚合中的2条相同消息

Question

我正在使用弹簧集成连接到 TCP 套接字。我在出站网关上发送 2 条不同的消息，它们返回相同的输出，即标头和有效负载。

现在我想以不同的方式处理回复消息，然后聚合成一条消息，然后可以由主服务类处理。

我尝试了各种技术，但没有任何效果。

这样做是否可行？如果是，请帮助我。

Answer 1

你需要一些东西来关联消息，也许是一个标题（例如标准的相关ID）。

使用 header-enricher 设置每个出站消息的相关 id 标头。<aggregator />使用简单的发布策略 ( )将回复消息发送到release-strategy-expression="size() == 2"。当收到第二个回复时，将释放带有有效负载（2 个有效负载的集合）的消息。