Mongo中如何使用killOp干掉Long Running Operation

這篇文章給大家分享的是有關(guān)Mongo中如何使用killOp干掉Long Running Operation的內(nèi)容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

詳解：

1. 詳解currentOp()
   

2. 
   

3. gechongrepl:PRIMARY> db.currentOp()
   

4. {
   

5.     "inprog" : [
   

6.         {
   

7.             "opid" : 6222,
   

8.             "active" : true,
   

9.             "secs_running" : 3,
   

10.             "microsecs_running" : NumberLong(3662328),
    

11.             "op" : "getmore",
    

12.             "ns" : "local.oplog.rs",
    

13.             "query" : {
    

14.                  
    

15.             },
    

16.             "client" : "192.168.91.132:45745",
    

17.             "desc" : "conn5",
    

18.             "threadId" : "0x7f1370cb4700",
    

19.             "connectionId" : 5,
    

20.             "waitingForLock" : false,
    

21.             "numYields" : 0,
    

22.             "lockStats" : {
    

23.                 "timeLockedMicros" : {
    

24.                     "r" : NumberLong(141),
    

25.                     "w" : NumberLong(0)
    

26.                 },
    

27.                 "timeAcquiringMicros" : {
    

28.                     "r" : NumberLong(16),
    

29.                     "w" : NumberLong(0)
    

30.                 }
    

31.             }
    

32.         }
    

33.     ]
    

34. }
    

35. 
    

36.  
    

37. "opid" : 6222,#進(jìn)程號
    

38. "active" : true,#是否活動狀態(tài)
    

39. "secs_running" : 3,#操作運行了多少秒
    

40. "microsecs_running" : NumberLong(3662328),
    

41. "op" : "getmore",#操作類型，包括(insert/query/update/remove/getmore/command)
    

42. "ns" : "local.oplog.rs",#命名空間
    

43. "query" : {},#如果op是查詢操作，這里將顯示查詢內(nèi)容；也有說這里顯示具體的操作語句的
    

44. 
    

45. "client" : "192.168.91.132:45745",#連接的客戶端信息
    

46. "desc" : "conn5",#數(shù)據(jù)庫的連接信息
    

47. "threadId" : "0x7f1370cb4700",#線程ID
    

48. "connectionId" : 5,#數(shù)據(jù)庫的連接ID
    

49. "waitingForLock" : false,#是否等待獲取鎖
    

50. "numYields" : 0,
    

51. "lockStats" : {
    

52. "timeLockedMicros" : {#持有的鎖時間微秒
    

53. "r" : NumberLong(141),#整個MongoDB實例的全局讀鎖
    

54. "w" : NumberLong(0)},#整個MongoDB實例的全局寫鎖
    

55. "timeAcquiringMicros" : {#為了獲得鎖，等待的微秒時間
    

56. "r" : NumberLong(16),#整個MongoDB實例的全局讀鎖
    

57. "w" : NumberLong(0)}#整個MongoDB實例的全局寫鎖

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

currentOp

currentOp的使用，參考官方文檔

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

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

db.currentOp(
   {
     "waitingForLock" : true,
     $or: [
        { "op" : { "$in" : [ "insert", "update", "remove" ] } },
        { "query.findandmodify": { $exists: true } }
    ]
   }
)

例2：查詢所有操作db1并且執(zhí)行時間已超過3s的請求

db.currentOp(
   {
     "active" : true,
     "secs_running" : { "$gt" : 3 },
     "ns" : /^db1\./
   }
)

currentOp的過濾條件包括

1. 請求操作類型，insert、update、delete…

2. 請求對應(yīng)的connectionId，threadId

3. 請求是否正在等待鎖

4. 請求執(zhí)行時間

5. 請求操作的DB或collection

6. 請求query的內(nèi)容

7. …

killOp

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

db.killOp(opid)

要了解killOp的意義，需要先搞清楚幾個問題

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

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

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

為了讓createIndex早點結(jié)束，你就需要killOp來幫忙，通過currentOp找到craeteIndex請求的opid，然后發(fā)送killOp，createIndex會在下個『檢查點』就結(jié)束執(zhí)行，整個線程退出。

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

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

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

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

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

while (!createIndexFinished) {
    createIndexForOneElement();
    checkForInterupt();
}

所以發(fā)送killOp后，請求要執(zhí)行到下一個『檢查點』線程才會退出，MongoDB在很多可能耗時長的請求中，都加入了checkForInterrupt()檢查點，如創(chuàng)建索引，repair database，mapreduce、aggregation等。

感謝各位的閱讀！關(guān)于“Mongo中如何使用killOp干掉Long Running Operation”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！