MongoDB管理：使用killOp干掉Long Running Operation

lyhabc

MongoDB提供了killOp請(qǐng)求，用于干掉運(yùn)行時(shí)間很長(zhǎng)的請(qǐng)求，killOp通常需要與currentOp組合起來(lái)使用；先根據(jù)currentOp查詢到請(qǐng)求的opid，然后根據(jù)opid發(fā)送killOp的請(qǐng)求。

currentOp

currentOp的使用，參考官方文檔

currentOp會(huì)將后端Mongod上正在執(zhí)行的請(qǐng)求都列出來(lái)，也可根據(jù)查詢條件（如請(qǐng)求類型，請(qǐng)求是否正在等待鎖，請(qǐng)求操作的DB或collection）來(lái)進(jìn)行過(guò)濾。

例1：查詢所有正在等待鎖的寫(xiě)操作

db.currentOp(
   {
     "waitingForLock" : true,
     $or: [
        { "op" : { "$in" : [ "insert", "update", "remove" ] } },
        { "query.findandmodify": { $exists: true } }
    ]
   }
)
例2：查詢所有操作db1并且執(zhí)行時(shí)間已超過(guò)3s的請(qǐng)求

db.currentOp(
   {
     "active" : true,
     "secs_running" : { "$gt" : 3 },
     "ns" : /^db1\./
   }
)
currentOp的過(guò)濾條件包括

請(qǐng)求操作類型，insert、update、delete…
請(qǐng)求對(duì)應(yīng)的connectionId，threadId
請(qǐng)求是否正在等待鎖
請(qǐng)求執(zhí)行時(shí)間
請(qǐng)求操作的DB或collection
請(qǐng)求query的內(nèi)容
…
killOp

currentOp的輸出結(jié)果里，每個(gè)請(qǐng)求包含一個(gè)opid字段，有了opid，就可以發(fā)送killOp來(lái)干掉對(duì)應(yīng)的請(qǐng)求。

db.killOp(opid)
要了解killOp的意義，需要先搞清楚幾個(gè)問(wèn)題

客戶端到Monogd Server連接斷掉后，連接上執(zhí)行的請(qǐng)求是否會(huì)立即結(jié)束？

比如你通過(guò)mongo shell，發(fā)送了一個(gè)createIndex的請(qǐng)求，給某個(gè)包含1000w個(gè)文檔的集合建立索引，這個(gè)請(qǐng)求會(huì)耗時(shí)很久，你想提前中止請(qǐng)求，Ctrl-C停掉了mongo shell，此時(shí)mongo shell到server的連接會(huì)關(guān)閉掉。

但后端createIndex的請(qǐng)求（MongoDB每個(gè)連接的請(qǐng)求由一個(gè)對(duì)應(yīng)的線程來(lái)處理）不會(huì)立即結(jié)束，而是會(huì)一直執(zhí)行下去，直到createIndex結(jié)束，給客戶端發(fā)送應(yīng)答時(shí)，發(fā)現(xiàn)連接已經(jīng)關(guān)閉，然后線程才退出。

為了讓createIndex早點(diǎn)結(jié)束，你就需要killOp來(lái)幫忙，通過(guò)currentOp找到craeteIndex請(qǐng)求的opid，然后發(fā)送killOp，createIndex會(huì)在下個(gè)『檢查點(diǎn)』就結(jié)束執(zhí)行，整個(gè)線程退出。

發(fā)送killOp后，請(qǐng)求是否會(huì)立即結(jié)束？

killOp的實(shí)現(xiàn)原理如下

每個(gè)連接對(duì)應(yīng)的服務(wù)線程存儲(chǔ)了一個(gè)killPending的字段，當(dāng)發(fā)送killOp時(shí)，會(huì)將該字段置1；請(qǐng)求在執(zhí)行過(guò)程中，可以通過(guò)不斷的調(diào)用OperationContext::checkForInterrupt()來(lái)檢查killPending是否被設(shè)置，如果被設(shè)置，則線程退出。

一個(gè)請(qǐng)求要支持killOp，必須在請(qǐng)求的處理邏輯里加上checkForInterrupt()檢查點(diǎn)才行，否則即使發(fā)送了killOp，也只能等待請(qǐng)求完全處理完畢線程才會(huì)退出。

比如createIndex的處理邏輯里包含了類似如下的代碼，在createIndex的循環(huán)過(guò)程中，一旦killPending被置1了，createIndex的執(zhí)行可以在當(dāng)前循環(huán)結(jié)束時(shí)退出。

while (!createIndexFinished) {
    createIndexForOneElement();
    checkForInterupt();
}
所以發(fā)送killOp后，請(qǐng)求要執(zhí)行到下一個(gè)『檢查點(diǎn)』線程才會(huì)退出，MongoDB在很多可能耗時(shí)長(zhǎng)的請(qǐng)求中，都加入了checkForInterrupt()檢查點(diǎn)，如創(chuàng)建索引，repair database，mapreduce、aggregation等。