溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
本篇文章給大家分享的是有關MongoDB中怎么處理Mongos 請求，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
TransportLayer接收到新連接后，會創建專門的conn線程負責處理該連接的后續所有請求，具體邏輯在ServiceEntryPointMongos類的_sessionloop函數中，根據請求的類型循環“收包，處理，回響應”三個步驟，總結狀態機轉換關系如下：
具體到Process業務處理里面，會進一步區分消息類型并走不同處理邏輯，主要分為：查詢類（queryop/getmore）, 更新類（insert/update/delete），killcursors，以及其他ClientCommand這幾種類型。
這幾類命令的前半段處理流程基本類似，包括鑒權，語法判斷，根據分區視圖查找本次操作涉及哪些shardserver，以及錯誤重試機制。后半段則和具體業務邏輯相關，存在較大差異。
查詢請求處理邏輯
因為是Sharding集群模式下的查詢，根據查詢條件的不同，可能會涉及到多個Shard Server的數據，根據分區視圖確認涉及的Shard Server后，針對每個ShardServer生成一個查詢任務交由TaskExecutorPool執行。TaskExecutorPool負責維護mongos到ShardServer的長連接，并包含一個network線程池負責執行和ShardServer的網絡交互。
Conn線程將查詢任務交由TaskExecutorPool任務隊列后，會wait到信號量上阻塞等待，TaskExecutorPool里的network線程完成查詢請求后，喚醒Conn線程進一步處理查詢結果。
Mongos為每一個Shard Server維護一個查詢結果緩存隊列，并按照Merge、Skip、Limit、RemoveSortKey的順序對查詢結果進行逐級處理后返回。其中Merge操作負責合并來自多個Shard Server的查詢結果，根據查詢條件是否要求排序有不同的處理邏輯：
需要排序：根據SortKey在多個隊列中找排最前面的，保證全局有序返回，緩存結果處理完了就觸發到對應ShardServer查詢數據；
不需要排序：一個Shard Server查詢結果返回完了再返回下一個ShardServer的查詢結果；
Mongos還會為每次查詢創建一個ClusterCursor，并維護和每個遠程Shard Server游標的對應關系，用于后續getmore操作進一步獲取數據。
以上就是MongoDB中怎么處理Mongos 請求，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
