spring Integration(Aggregator) 在分布式环境中的表现如何？

Question

我有一个要求，我想使用基于correlation_id 的聚合器模式聚合消息，但我认为我在分布式环境中可能会遇到问题，例如拥有多个服务器节点。

Answer 1

您必须使用共享消息组存储和共享锁注册表，以便所有实例都可以看到聚合组，但只有一个实例可以同时更新组。

参见Managing State in an Aggregator: MessageGroupStore - JDBC、Redis Mongo 等和Lock Registry - Zookeeper、Redis 等。