例1:查询全部正在等待锁的写操做
shell
db.currentOp( { "waitingForLock" : true, $or: [ { "op" : { "$in" : [ "insert", "update", "remove" ] } }, { "query.findandmodify": { $exists: true } } ] } )
例2:查询全部操做db1而且执行时间已超过3s
的请求后端
db.currentOp( { "active" : true, "secs_running" : { "$gt" : 3 }, "ns" : /^db1\./ } )
currentOp的过滤条件包括 请求操做类型,insert、update、delete… 请求对应的connectionId,threadId 请求是否正在等待锁 请求执行时间 请求操做的DB或collection 请求query的内容 …
currentOp的输出结果里,每一个请求包含一个opid字段,有了opid,就能够发送killOp来干掉对应的请求。spa
db.killOp(opid)
好比你经过mongo shell,发送了一个createIndex的请求,给某个包含1000w个文档的集合创建索引,这个请求会耗时好久,你想提早停止请求,Ctrl-C停掉了mongo shell,此时mongo shell到server的链接会关闭掉。线程
但后端createIndex的请求(MongoDB每一个链接的请求由一个对应的线程来处理)不会当即结束,而是会一直执行下去,直到createIndex结束,给客户端发送应答时,发现链接已经关闭,而后线程才退出。code
为了让createIndex早点结束,你就须要killOp来帮忙,经过currentOp找到craeteIndex请求的opid,而后发送killOp,createIndex会在下个『检查点』就结束执行,整个线程退出。server
killOp的实现原理以下索引
每一个链接对应的服务线程存储了一个killPending的字段,当发送killOp时,会将该字段置1;请求在执行过程当中,能够经过不断的调用OperationContext::checkForInterrupt()来检查killPending是否被设置,若是被设置,则线程退出。rem
一个请求要支持killOp,必须在请求的处理逻辑里加上checkForInterrupt()检查点才行,不然即便发送了killOp,也只能等待请求彻底处理完毕线程才会退出。文档
好比createIndex的处理逻辑里包含了相似以下的代码,在createIndex的循环过程当中,一旦killPending被置1了,createIndex的执行能够在当前循环结束时退出。it
while (!createIndexFinished) { createIndexForOneElement(); checkForInterupt(); }
因此发送killOp后,请求要执行到下一个『检查点』线程才会退出,MongoDB在不少可能耗时长的请求中,都加入了checkForInterrupt()检查点,如建立索引,repair database,mapreduce、aggregation等。