Как весна интеграция (агрегатор) ведет себя в распределенной среде?

Question

У меня есть требование, когда я хочу агрегировать сообщения с использованием шаблона агрегатора на основе корреляции, но я думаю, что может столкнуться с проблемой в распределенной среде, например, с несколькими серверными узлами.

Answer 1

Вы должны использовать хранилище групп общих сообщений и общий регистр блокировки, чтобы все экземпляры могли видеть группу агрегации, но только одно может обновлять группу одновременно.

См Managing State in an Aggregator: MessageGroupStore - JDBC, Redis Монго и т.д. и Lock Registry - Zookeeper, Redis и т.д.