深入理解MongoDB的变更流

mongodb的变更流解释:

变更流（Change Streams）允许应用程序访问实时数据变更，从而避免事先手动追踪? oplog?的复杂性和风险。应用程序可使用变更流来订阅针对单个集合、数据库或整个部署的所有数据变更，并立即对它们做出响应。由于变更流采用聚合框架，因此，应用程序还可对特定变更进行过滤，或是随意转换通知。( Change Streams - MongoDB Manual v5.0 )

使用场景,需要websocket推送实时数据的时候，我们把数据写入mongo的同时,websocket实时监听mongo数据，拿到后推送到订阅组用户。

这里只做一端新增另一端服务监听测试，及windows下副本集快速搭建流程。

sub端代码

pub端代码

执行结果 pub端

执行结果 sub端

数据库不用新建集合，自动生成很方便

下面是windows下安装副本集步骤一字不拉

demo代码链接

go/mongochangestreamsdemo/demo at main · liuzhixin405/go (github.com)

mongo配置链接

config/mongo windows集群 at main · liuzhixin405/config (github.com)

备注:? c#代码监听数据库变化需要连接副本 "Connection": "mongodb://localhost:27017,localhost:27018,localhost:27019"，只27017不会获得更新数据。具体原因可能是封装类库有关，暂没有深究。