redis - 在指向同一个 MessageStore 的集群环境中使用 Spring Integration Aggregator

Question

我们有 Spring Integration Aggregator 组件在多个实例中运行，但都指向同一个 JDBCMessageStore (oracle)。我知道我们可以根据主机名设置区域，以便聚合器聚合与特定主机相关的消息。

但有什么方法可以在所有实例中使用 DEFAULT 区域，并且仍然只有一个实例聚合消息存储中的所有消息？

我正在阅读“Redis Lock Registry”、“Gemfire Lock Registry”和“Zookeeper Lock Registry”。他们是否需要创建/配置他们的相关 MessageStore？或者我可以将它们与现有的 JDBCMessageStore(oracle) 一起使用吗？

使用上述锁注册表机制有什么缺点吗？

Answer 1

谢谢加里。这些不同的 LockRegistry 有什么用？ https://docs.spring.io/spring-integration/docs/4.2.3.RELEASE/reference/html/messaging-routing-chapter.html#aggregator

(20) 对 org.springframework.integration.util.LockRegistry bean 的引用；用于根据 groupId 获取 Lock，用于对 MessageGroup 的并发操作。默认情况下，使用内部 DefaultLockRegistry。使用分布式 LockRegistry，例如 ZookeeperLockRegistry，确保聚合器只有一个实例将同时对一个组进行操作。有关详细信息，请参阅第 24.11 节“Redis 锁注册表”、第 16.6 节“Gemfire 锁注册表”和第 37.3 节“Zookeeper 锁注册表”。