mongodb的變更流解釋:

變更流（Change Streams）允許應(yīng)用程序訪問實(shí)時(shí)數(shù)據(jù)變更，從而避免事先手動(dòng)追蹤? oplog?的復(fù)雜性和風(fēng)險(xiǎn)。應(yīng)用程序可使用變更流來訂閱針對(duì)單個(gè)集合、數(shù)據(jù)庫(kù)或整個(gè)部署的所有數(shù)據(jù)變更，并立即對(duì)它們做出響應(yīng)。由于變更流采用聚合框架，因此，應(yīng)用程序還可對(duì)特定變更進(jìn)行過濾，或是隨意轉(zhuǎn)換通知。( Change Streams - MongoDB Manual v5.0 )

使用場(chǎng)景,需要websocket推送實(shí)時(shí)數(shù)據(jù)的時(shí)候，我們把數(shù)據(jù)寫入mongo的同時(shí),websocket實(shí)時(shí)監(jiān)聽mongo數(shù)據(jù)，拿到后推送到訂閱組用戶。

這里只做一端新增另一端服務(wù)監(jiān)聽測(cè)試，及windows下副本集快速搭建流程。

sub端代碼

pub端代碼

執(zhí)行結(jié)果 pub端

執(zhí)行結(jié)果 sub端

數(shù)據(jù)庫(kù)不用新建集合，自動(dòng)生成很方便

下面是windows下安裝副本集步驟一字不拉

demo代碼鏈接

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

mongo配置鏈接

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

備注:? c#代碼監(jiān)聽數(shù)據(jù)庫(kù)變化需要連接副本 "Connection": "mongodb://localhost:27017,localhost:27018,localhost:27019"，只27017不會(huì)獲得更新數(shù)據(jù)。具體原因可能是封裝類庫(kù)有關(guān)，暫沒有深究。

• 異色邊緣龍局北辰卡組詳解
• 《怪化貓》系列第二章《火鼠》近日公開諸多新情報(bào)
• steam特賣頁(yè)面出現(xiàn)神秘粉發(fā)女孩 引發(fā)網(wǎng)友熱烈討論
• 大雪節(jié)氣活動(dòng)：桃源深處有人家雪盛冬藏
• 游俠晚報(bào)：《絕地潛兵2》口碑上升 Fami通一周評(píng)分