共計(jì) 1197 個(gè)字符，預(yù)計(jì)需要花費(fèi) 3 分鐘才能閱讀完成。

自動(dòng)寫代碼機(jī)器人，免費(fèi)開通

本篇文章給大家分享的是有關(guān) MongoDB 中怎么處理 Mongos 請(qǐng)求，丸趣 TV 小編覺(jué)得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著丸趣 TV 小編一起來(lái)看看吧。

TransportLayer 接收到新連接后，會(huì)創(chuàng)建專門的 conn 線程負(fù)責(zé)處理該連接的后續(xù)所有請(qǐng)求，具體邏輯在 ServiceEntryPointMongos 類的_sessionloop 函數(shù)中，根據(jù)請(qǐng)求的類型循環(huán)“收包，處理，回響應(yīng)”三個(gè)步驟，總結(jié)狀態(tài)機(jī)轉(zhuǎn)換關(guān)系如下：

具體到 Process 業(yè)務(wù)處理里面，會(huì)進(jìn)一步區(qū)分消息類型并走不同處理邏輯，主要分為：查詢類（queryop/getmore）, 更新類（insert/update/delete），killcursors，以及其他 ClientCommand 這幾種類型。

這幾類命令的前半段處理流程基本類似，包括鑒權(quán)，語(yǔ)法判斷，根據(jù)分區(qū)視圖查找本次操作涉及哪些 shardserver，以及錯(cuò)誤重試機(jī)制。后半段則和具體業(yè)務(wù)邏輯相關(guān)，存在較大差異。

查詢請(qǐng)求處理邏輯

因?yàn)槭?Sharding 集群模式下的查詢，根據(jù)查詢條件的不同，可能會(huì)涉及到多個(gè) Shard Server 的數(shù)據(jù)，根據(jù)分區(qū)視圖確認(rèn)涉及的 Shard Server 后，針對(duì)每個(gè) ShardServer 生成一個(gè)查詢?nèi)蝿?wù)交由 TaskExecutorPool 執(zhí)行。TaskExecutorPool 負(fù)責(zé)維護(hù) mongos 到 ShardServer 的長(zhǎng)連接，并包含一個(gè) network 線程池負(fù)責(zé)執(zhí)行和 ShardServer 的網(wǎng)絡(luò)交互。

Conn 線程將查詢?nèi)蝿?wù)交由 TaskExecutorPool 任務(wù)隊(duì)列后，會(huì) wait 到信號(hào)量上阻塞等待，TaskExecutorPool 里的 network 線程完成查詢請(qǐng)求后，喚醒 Conn 線程進(jìn)一步處理查詢結(jié)果。

Mongos 為每一個(gè) Shard Server 維護(hù)一個(gè)查詢結(jié)果緩存隊(duì)列，并按照 Merge、Skip、Limit、RemoveSortKey 的順序?qū)Σ樵兘Y(jié)果進(jìn)行逐級(jí)處理后返回。其中 Merge 操作負(fù)責(zé)合并來(lái)自多個(gè) Shard Server 的查詢結(jié)果，根據(jù)查詢條件是否要求排序有不同的處理邏輯：

需要排序：根據(jù) SortKey 在多個(gè)隊(duì)列中找排最前面的，保證全局有序返回，緩存結(jié)果處理完了就觸發(fā)到對(duì)應(yīng) ShardServer 查詢數(shù)據(jù)；

不需要排序：一個(gè) Shard Server 查詢結(jié)果返回完了再返回下一個(gè) ShardServer 的查詢結(jié)果；

Mongos 還會(huì)為每次查詢創(chuàng)建一個(gè) ClusterCursor，并維護(hù)和每個(gè)遠(yuǎn)程 Shard Server 游標(biāo)的對(duì)應(yīng)關(guān)系，用于后續(xù) getmore 操作進(jìn)一步獲取數(shù)據(jù)。

以上就是 MongoDB 中怎么處理 Mongos 請(qǐng)求，丸趣 TV 小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注丸趣 TV 行業(yè)資訊頻道。