深入理解MongoDB的變更流

mongodb的變更流解釋:

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

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

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

sub端代碼

pub端代碼

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

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

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

下面是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ù)庫變化需要連接副本 "Connection": "mongodb://localhost:27017,localhost:27018,localhost:27019"，只27017不會獲得更新數(shù)據(jù)。具體原因可能是封裝類庫有關(guān)，暫沒有深究。

• 炫舞節(jié)2024現(xiàn)已開啟！全新「炫關(guān)卡」即將上線，來炫舞觸動音舞初心！
• 《熱血傳奇》新百區(qū)本服沙巴克 11月2日全境開戰(zhàn)
• 《龍騰世紀(jì)：影障守護(hù)者》編譯著色器太慢怎么辦
• 《第五人格》選手故事：DOU5_Musk—— 一朝試鋒芒
• 《怪物獵人：荒野》影蜘蛛信息介紹