变更流如何在 mongo 中跨多个实例工作？

Question

假设我有两个数据中心，每个数据中心有 3 个实例，运行相同的代码，连接到单个 MongoDB 和单独的 Redis 数据库。

Redis A <----> Data Center A
                            |
                            |--------> MongoDB
                            |
Redis B <-----> Data Center B

期望是，当 Mongo 中的某个集合更新时，会触发 Data Center A 和 B 中的一个 change stream 来清除 redis 缓存。它适用于变更流吗？

Answer 1

当您在 n 个节点/实例上运行更改流代码时，每个实例都将接收更改事件，并且基于该事件和更改流中的数据，您可以进行业务逻辑/redis 清理。

1. 假设您在数据中心 A 上运行了更改流侦听器 (CS1)，并且该数据中心有 redis 服务器 A，您希望在特定条件下从 DB 更改事件中清理它。
2. 假设您在数据中心 B 上运行了另一个更改流侦听器 (CS2)，并且该数据中心有 redis 服务器 B，您希望在特定条件下从 DB 更改事件中清理它。
3. changestream 侦听器（CS1 和 CS2）都侦听相同的 DB 和相同的集合。
4. 当集合发生任何更改时，两个更改流侦听器（CS1 和 CS2）都会收到更改事件
5. CS1 将具有清理 redis A 的逻辑，CS2 将具有清理 redis B 的逻辑，因此当更改事件发生且满足条件时，您的两个 redis 服务器都将被清理。