弹簧集成 - 处理2个不同聚合的消息

Question

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

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

我试过各种技术，但没有任何工作。

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

Answer 1

您需要将消息关联起来，可能是标头（例如标准相关标识）。

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