MongoDB中怎么處理Mongos請求-創(chuàng)新互聯(lián)

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

成都創(chuàng)新互聯(lián)成立于2013年，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項(xiàng)目網(wǎng)站設(shè)計(jì)制作、做網(wǎng)站網(wǎng)站策劃，項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢想脫穎而出為使命，1280元新榮做網(wǎng)站,已為上家服務(wù),為新榮各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:18980820575

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

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

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

查詢請求處理邏輯

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

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

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

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

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

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

以上就是MongoDB中怎么處理Mongos 請求，小編相信有部分知識點(diǎn)可能是我們?nèi)粘９ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)-成都網(wǎng)站建設(shè)公司行業(yè)資訊頻道。

網(wǎng)站題目：MongoDB中怎么處理Mongos請求-創(chuàng)新互聯(lián)
標(biāo)題URL：http://bm7419.com/article40/hedho.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)建站、ChatGPT、響應(yīng)式網(wǎng)站、軟件開發(fā)、品牌網(wǎng)站制作、服務(wù)器托管

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)