Command在Mongodb中是一類(lèi)特殊操作，它提供了強(qiáng)大的管理及各項(xiàng)操作（比如建庫(kù)，索引，刪除集合等）。可以說(shuō)通過(guò)Command可以完成幾乎所有想做的事情。同時(shí)Mongodb開(kāi)發(fā)者在Command上又做了非常清晰體系架構(gòu)和設(shè)計(jì)，便于管理和高效執(zhí)行各種類(lèi)型的Command。

今天就專(zhuān)門(mén)用一篇篇幅來(lái)著重介紹一下其Command的體系架構(gòu)，并用例子來(lái)介紹mongod是如何將Command引入其中的。

為了對(duì)其中大部分command對(duì)一個(gè)大致的了解，我們可以用下面指令來(lái)顯示一個(gè)command列表：

1. mongod --dbpath d:\mongodb\db --port 27017 --rest
2. 在瀏覽器上輸入鏈接地址：http://localhost:28017/_commands

這里mongod就會(huì)為我們顯示command列表，大約有90多個(gè)，這是顯示截圖：

上面90多個(gè)類(lèi)中，按其使用場(chǎng)景可以為分如下幾類(lèi)，分別是：

1. dbcommand.cpp：一般數(shù)據(jù)庫(kù)指令，如數(shù)據(jù)庫(kù)，索引的創(chuàng)建，重建，打開(kāi)/關(guān)閉等
2. dbcommands_admin.cpp：管理指令，如CleanCmd，JournalLatencyTestCmd，ValidateCmd，F(xiàn)SyncCommand
3. dbcommands_generic.cpp：常用指令,ListCommandsCmd,LogRotateCmd,PingCommand,CmdSet,CmdGet等
4. replset_commands.cpp：復(fù)制集指令，CmdReplSetTest，CmdReplSetGetStatus,CmdReplSetReconfig等
5. security_commands.cpp：安全指令,CmdGetNonce,CmdLogout,CmdAuthenticate

    

    

1. commands_admin.cpp：shard管理操作，因其位于mongos項(xiàng)目，這里暫不介紹
2. commands_public.cpp：shard公用操作，因其位于mongos項(xiàng)目，這里暫不介紹

下面是相關(guān)類(lèi)圖：

-----------------------------分割線--------------------------------

-----------------------------分割線--------------------------------

 -----------------------------分割線--------------------------------

-----------------------------分割線--------------------------------

#p#

首先我們看一下在Command的基類(lèi)，其用于定義子類(lèi)要實(shí)現(xiàn)的方法及屬性，自身也實(shí)現(xiàn)了一些通用方法，比如htmlHelp(用于以html方法顯示該command的幫助信息),構(gòu)造方法，findCommand(查詢(xún)命令)等，其聲明如下：

//commands.h  
class Command {  
public:  
   //執(zhí)行當(dāng)前Command時(shí)所使用的鎖類(lèi)型  
   enum LockType { READ = -1/*讀*/ , NONE = 0 /*無(wú)鎖*/, WRITE = 1 /*寫(xiě)*/};  
 
   const string name;  
 
   /* 運(yùn)行指定的命令，需要子類(lèi)實(shí)現(xiàn)  
   fromRepl - command is being invoked as part of replication syncing.  In this situation you  
   normally do not want to log the command to the local oplog.  
 
   如執(zhí)行成功返回true,否則為false, errmsg記錄錯(cuò)誤信息  
   */ 
   virtual bool run(const string& db, BSONObj& cmdObj, string& errmsg, BSONObjBuilder& result, bool fromRepl) = 0;  
 
   /*  
   note: logTheTop() MUST be false if READ  
   if NONE, can't use Client::Context setup  
   use with caution  
   */ 
   virtual LockType locktype() const = 0;  
 
   /* 是否有管理特權(quán)才可運(yùn)行該命令 has privileges to run this command. */ 
   virtual bool adminOnly() const {  
      return false;  
   }  
   //html格式的幫助信息  
   void htmlHelp(stringstream&) const;  
 
   /* 與adminOnly相似,但更嚴(yán)格: 要么被驗(yàn)證，要么只運(yùn)行在本地接口（local interface）  
   注：當(dāng)本屬性為true時(shí)，adminOnly()也必須為true.  
   */ 
   virtual bool localHostOnlyIfNoAuth(const BSONObj& cmdObj) { return false; }  
 
   /* 如果replication pair 的slaves可以運(yùn)行命令的，則返回true  
   (the command directly from a client -- if fromRepl, always allowed).  
   */ 
   virtual bool slaveOk() const = 0;  
 
   /* 通過(guò)在查詢(xún)命令中打開(kāi) 'slaveok'選項(xiàng)，客戶(hù)端強(qiáng)制在一個(gè)slave上運(yùn)行一個(gè)命令時(shí)，返回true.  
   */ 
   virtual bool slaveOverrideOk() {  
      return false;  
   }  
 
   /* Override and return true to if true,log the operation (logOp()) to the replication log.  
   (not done if fromRepl of course)  
 
   Note if run() returns false, we do NOT log.  
   */ 
   virtual bool logTheOp() { return false; }  
 
   virtual void help( stringstream& help ) const;  
 
   /* Return true if authentication and security applies to the commands.  Some commands  
   (e.g., getnonce, authenticate) can be done by anyone even unauthorized.  
   */ 
   virtual bool requiresAuth() { return true; }  
 
   /** @param webUI：在web上暴露當(dāng)前command，形如 localhost:28017/<name>  
   @param oldName： 舊選項(xiàng)，表示當(dāng)前command的舊(已棄用)名稱(chēng)  
   */ 
   Command(const char *_name, bool webUI = false, const char *oldName = 0);  
 
   virtual ~Command() {}  
 
protected:  
   BSONObj getQuery( const BSONObj& cmdObj ) {  
     if ( cmdObj["query"].type() == Object )  
        return cmdObj["query"].embeddedObject();  
     if ( cmdObj["q"].type() == Object )  
        return cmdObj["q"].embeddedObject();  
     return BSONObj();  
   }  
 
   static void logIfSlow( const Timer& cmdTimer,  const string& msg);  
   //command map,其包含系統(tǒng)實(shí)現(xiàn)的所有command對(duì)象，以便findCommand查詢(xún)時(shí)使用  
   //注意也包含該command的舊名稱(chēng)（構(gòu)造方法中的oldName參數(shù)）所對(duì)應(yīng)的對(duì)象，  
   static map<string,Command*> * _commands;  
   //與上面形同，但不含舊名稱(chēng)的command map  
   static map<string,Command*> * _commandsByBestName;  
   //將web類(lèi)型的command放到該map中  
   static map<string,Command*> * _webCommands;  
 
public:  
   static const map<string,Command*>* commandsByBestName() { return _commandsByBestName; }  
   static const map<string,Command*>* webCommands() { return _webCommands; }  
   /** @return 返回是否找到或已執(zhí)行command */ 
   static bool runAgainstRegistered(const char *ns, BSONObj& jsobj, BSONObjBuilder& anObjBuilder);  
   static LockType locktype( const string& name );  
   //根據(jù)命令名稱(chēng)在集合中找到相應(yīng)Command對(duì)象  
   static Command * findCommand( const string& name );  
}; 

Command基類(lèi)中提供了幾個(gè)map<string,Command*>類(lèi)型的集合map，用于將系統(tǒng)實(shí)現(xiàn)的Command進(jìn)行收集，以便后面findCommand進(jìn)行便歷查詢(xún)時(shí)使用。如下：

//commands.cpp  
Command* Command::findCommand( const string& name ) {  
   //從_commands map中找到指定name的Command對(duì)象  
   map<string,Command*>::iterator i = _commands->find( name );  
   if ( i == _commands->end() )//如果已到結(jié)尾，表示未找到  
      return 0;  
   return i->second;//返回Command對(duì)象  
}  

看到上面代碼中的_commands大家可能要問(wèn)，該map是如何初始化并將系統(tǒng)實(shí)現(xiàn)的各個(gè)Command注冊(cè)到其中呢？答案就在Command的構(gòu)造方法中，如下：

//command.cpp  
Command::Command(const char *_name, bool web, const char *oldName) : name(_name) {  
   // register ourself.  
   //如為空（系統(tǒng)剛啟動(dòng)時(shí)）則實(shí)例化_commands  
   if ( _commands == 0 )  
      _commands = new map<string,Command*>;  
   //如為空（系統(tǒng)剛啟動(dòng)時(shí)）則實(shí)例化_commandsByBestName  
   if( _commandsByBestName == 0 )  
      _commandsByBestName = new map<string,Command*>;  
   Command*& c = (*_commands)[name];//獲取指定名稱(chēng)的command對(duì)象  
   if ( c )//如有，表示之前已注冊(cè)了該command  
      log() << "warning: 2 commands with name: " << _name << endl;  
   //將當(dāng)前command（this）賦值到map中相應(yīng)name的command上  
   c = this;  
   //綁定到_commandsByBestName中的相應(yīng)name上  
   (*_commandsByBestName)[name] = this;  
   //如果命令支持web方式  
   if( web ) {  
      //如為空（系統(tǒng)剛啟動(dòng)時(shí)）則實(shí)例化_webCommands  
      if( _webCommands == 0 )  
         _webCommands = new map<string,Command*>;  
      //綁定到_webCommands中的相應(yīng)name上  
      (*_webCommands)[name] = this;  
   }  
   //如有舊名稱(chēng)，則也綁到_commands的oldName所指向的command  
   if( oldName )  
      (*_commands)[oldName] = this;  
}  

有了這些還不夠，我們還要從90多個(gè)command子類(lèi)中找出一個(gè)來(lái)實(shí)際分析其實(shí)現(xiàn)的方式，這里以最經(jīng)常使用的count(獲取指定條件的記錄數(shù))來(lái)分析其向map中注冊(cè)command的流程，參見(jiàn)下面代碼段：

//dbcommands.cpp  
/* select count(*) */ 
class CmdCount : public Command {  
public:  
   virtual LockType locktype() const { return READ; }  
   //調(diào)用基類(lèi)的構(gòu)造方法  
   CmdCount() : Command("count") { }  
 
   virtual bool logTheOp() {  
      return false;  
   }  
   virtual bool slaveOk() const {  
      // ok on --slave setups, not ok for nonmaster of a repl pair (unless override)  
      return replSettings.slave == SimpleSlave;  
   }  
   virtual bool slaveOverrideOk() {  
      return true;  
   }  
   virtual bool adminOnly() const {  
      return false;  
   }  
   virtual void help( stringstream& help ) const { help << "count objects in collection"; }  
   virtual bool run(const string& dbname, BSONObj& cmdObj, string& errmsg, BSONObjBuilder& result, bool) {  
      string ns = dbname + '.' + cmdObj.firstElement().valuestr();  
      string err;  
      long long n = runCount(ns.c_str(), cmdObj, err);//執(zhí)行查詢(xún)  
      long long nn = n;  
      bool ok = true;  
      if ( n == -1 ) {  
         nn = 0;  
         result.appendBool( "missing" , true );  
      }  
      else if ( n < 0 ) {  
         nn = 0;  
         ok = false;  
         if ( !err.empty() )  
            errmsg = err;  
      }  
      result.append("n", (double) nn);  
      return ok;  
   }  
}  cmdCount; 

上面的CmdCount類(lèi)即是在命令行模式下使用count指令時(shí)對(duì)應(yīng)的代碼塊，其自身的構(gòu)造函數(shù)就直接調(diào)用了基類(lèi)(Command)的構(gòu)造方法。但這里只是定義了還不夠，還需要一個(gè)定義類(lèi)實(shí)例代碼（用于啟動(dòng)構(gòu)造函數(shù)），而這個(gè)任務(wù)就交給了該類(lèi)定義的代碼結(jié)尾處的下面代碼來(lái)實(shí)現(xiàn)了：

} cmdCount; 

可以看到，這里使用的是在類(lèi)聲明后定義對(duì)象的方式來(lái)執(zhí)行構(gòu)造方法（這時(shí)并未使用new實(shí)例化方式來(lái)創(chuàng)建對(duì)象指針），進(jìn)而注冊(cè)該command到map。當(dāng)然繼承自Command的子類(lèi)必須要實(shí)現(xiàn)其中的run()方法,因?yàn)橹挥兴蔷唧wcommand要執(zhí)行的具體邏輯（可參見(jiàn)上面CmdCount的具體實(shí)現(xiàn)）。

到這里只能說(shuō)mongod在系統(tǒng)啟動(dòng)到實(shí)始化了相應(yīng)的Command集合map信息，但mongod是如何將client發(fā)來(lái)的操作請(qǐng)求進(jìn)行轉(zhuǎn)換并進(jìn)而執(zhí)行相應(yīng)的command指令的呢？我們接下來(lái)繼續(xù)分析。

之前看過(guò)我的這篇文章的朋友可能還有印象，在mongod啟動(dòng)之后，會(huì)循環(huán)偵聽(tīng)指向端口上的用戶(hù)(client)請(qǐng)求，這些請(qǐng)求在mongod中被改裝成了message在各個(gè)功能類(lèi)中傳遞。當(dāng)用戶(hù)發(fā)送一個(gè)count指令操作時(shí)，其會(huì)在query.cpp中執(zhí)行下面方法（以count查詢(xún)指令的執(zhí)行流程為例來(lái)進(jìn)行分析）：

//query.cpp  
const char *runQuery(Message& m, QueryMessage& q, CurOp& curop, Message &result) {  
   StringBuilder& ss = curop.debug().str;  
   //構(gòu)造ParsedQuery查詢(xún)對(duì)象，該對(duì)象包括查詢(xún)記錄數(shù)字，以及記錄跳轉(zhuǎn)偏移量等信息，  
 
   //這些值會(huì)在訪問(wèn)磁盤(pán)查詢(xún)時(shí)使用，用法參見(jiàn):query.cpp 662行的virtual void _init()方法  
   shared_ptr<ParsedQuery> pq_shared( new ParsedQuery(q) );  
   ParsedQuery& pq( *pq_shared );  
   ......  
   //對(duì)查詢(xún)命令判斷，指令形如abc.$cmd.findOne( { ismaster:1 } )  
   if ( pq.couldBeCommand() ) {//_ns中包括$cmd字符串  
  BufBuilder bb;  
  bb.skip(sizeof(QueryResult));  
  BSONObjBuilder cmdResBuf;  
  //對(duì)查詢(xún)權(quán)限判斷，并執(zhí)行相應(yīng)查詢(xún)指令  
  if ( runCommands(ns, jsobj, curop, bb, cmdResBuf, false, queryOptions) ) {  
     ss << " command: ";  
     jsobj.toString( ss );  
     curop.markCommand();  
     auto_ptr< QueryResult > qr;  
     qr.reset( (QueryResult *) bb.buf() );  
     bb.decouple();  
     qr->setResultFlagsToOk();  
     qr->len = bb.len();  
     ss << " reslen:" << bb.len();  
     qr->setOperation(opReply);  
     qr->cursorId = 0;  
     qr->startingFrom = 0;  
     qr->nReturned = 1;  
     result.setData( qr.release(), true );//設(shè)置返回結(jié)果  
  }  
  else {  
     uasserted(13530, "bad or malformed command request?");  
  }  
  return 0;  
   }  
.....  
} 

上面代碼對(duì)傳遞來(lái)的查詢(xún)消息QueryMessage進(jìn)行分析之后，如果發(fā)現(xiàn)其為command時(shí)，執(zhí)行runCommands方法：

//query.cpp     
bool runCommands(const char *ns, BSONObj& jsobj, CurOp& curop, BufBuilder &b, BSONObjBuilder& anObjBuilder, bool fromRepl, int queryOptions) {  
   try {  
      return _runCommands(ns, jsobj, b, anObjBuilder, fromRepl, queryOptions);  
   }  
   catch ( AssertionException& e ) {  
      e.getInfo().append( anObjBuilder , "assertion" , "assertionCode" );  
   }  
   curop.debug().str << " assertion ";  
   anObjBuilder.append("errmsg", "db assertion failure");  
   anObjBuilder.append("ok", 0.0);  
   BSONObj x = anObjBuilder.done();  
   b.appendBuf((void*) x.objdata(), x.objsize());  
   return true;  
}  

接著其會(huì)執(zhí)行dbcommands.cpp中的_runCommands()方法

//dbcommands.cpp  
  bool _runCommands(const char *ns, BSONObj& _cmdobj, BufBuilder &b, BSONObjBuilder& anObjBuilder, bool fromRepl, int queryOptions) {  
  cc().curop()->ensureStarted();  
  string dbname = nsToDatabase( ns );  
 
  if( logLevel >= 1 )  
     log() << "run command " << ns << ' ' << _cmdobj << endl;  
 
  const char *p = strchr(ns, '.');  
  if ( !p ) return false;  
  //再次進(jìn)行cmd判斷，以確定是command  
  if ( strcmp(p, ".$cmd") != 0 ) return false;  
 
  BSONObj jsobj;  
  {  
     BSONElement e = _cmdobj.firstElement();  
     if ( e.type() == Object && string("query") == e.fieldName() ) {  
        jsobj = e.embeddedObject();  
     }  
     else {  
        jsobj = _cmdobj;  
     }  
  }  
 
  Client& client = cc();  
  bool ok = false;  
 
  BSONElement e = jsobj.firstElement();  
  //根據(jù)command名稱(chēng)從map中找出相應(yīng)的command對(duì)象  
  Command * c = e.type() ? Command::findCommand( e.fieldName() ) : 0;  
 
  if ( c ) {  
     //執(zhí)行該對(duì)象  
     ok = execCommand( c , client , queryOptions , ns , jsobj , anObjBuilder , fromRepl );  
  }  
  else {  
     anObjBuilder.append("errmsg", str::stream() << "no such cmd: " << e.fieldName() );  
     anObjBuilder.append("bad cmd" , _cmdobj );  
  }  
 
  // switch to bool, but wait a bit longer before switching?  
  // anObjBuilder.append("ok", ok);  
  anObjBuilder.append("ok", ok?1.0:0.0);  
  BSONObj x = anObjBuilder.done();  
  b.appendBuf((void*) x.objdata(), x.objsize());  
 
  return true;  

上面代碼主要是從map中找出相應(yīng)的command對(duì)象，并將該對(duì)象及操作命令參數(shù)和client(用于獲取其中的認(rèn)證信息，以確定其執(zhí)行權(quán)限)作為參數(shù)，來(lái)調(diào)用 execCommand方法：

//dbcommands.cpp  
bool execCommand( Command * c ,  
  Client& client , int queryOptions ,  
  const char *cmdns, BSONObj& cmdObj ,  
  BSONObjBuilder& result /*返回command執(zhí)行結(jié)果*/,  
  bool fromRepl ) {  
 
     string dbname = nsToDatabase( cmdns );  
 
     AuthenticationInfo *ai = client.getAuthenticationInfo();  
     
     if( c->adminOnly() /*如果需要有管理特權(quán)開(kāi)可運(yùn)行*/ 
     && c->localHostOnlyIfNoAuth( cmdObj ) /*要么被驗(yàn)證，要么只運(yùn)行在本地接口*/ 
     && noauth && !ai->isLocalHost ) {//未認(rèn)證 且 不是在本地運(yùn)行  
        result.append( "errmsg" ,  
        "unauthorized: this command must run from localhost when running db without auth" );  
        log() << "command denied: " << cmdObj.toString() << endl;  
        return false;  
     }  
 
    if ( c->adminOnly() && ! fromRepl && dbname != "admin" ) {  
       result.append( "errmsg" ,  "access denied; use admin db" );  
       log() << "command denied: " << cmdObj.toString() << endl;  
       return false;  
    }  
 
   if ( cmdObj["help"].trueValue() ) {  
      stringstream ss;  
      ss << "help for: " << c->name << " ";  
      c->help( ss );  
      result.append( "help" , ss.str() );  
      result.append( "lockType" , c->locktype() );  
      return true;  
   }  
 
   bool canRunHere =  
   isMaster( dbname.c_str() ) /*如為master庫(kù)*/||  
   c->slaveOk() /*如果replication pair 的slaves可以運(yùn)行命令*/||  
   ( c->slaveOverrideOk() && ( queryOptions & QueryOption_SlaveOk ) ) ||  
   fromRepl;  
 
   if ( ! canRunHere ) {  
      result.append( "errmsg" , "not master" );  
      return false;  
   }  
 
   if ( c->adminOnly() )  
      log( 2 ) << "command: " << cmdObj << endl;  
 
   //如當(dāng)前command無(wú)須鎖時(shí)  
   if ( c->locktype() == Command::NONE ) {  
      // we also trust that this won't crash  
      string errmsg;  
      //運(yùn)行當(dāng)前command  
      int ok = c->run( dbname , cmdObj , errmsg , result , fromRepl );  
      if ( ! ok )  
         result.append( "errmsg" , errmsg );  
      return ok;  
   }  
   //判斷執(zhí)行當(dāng)前command是否需要'寫(xiě)鎖'(每個(gè)command子類(lèi)都有該屬性)，枚舉定義如下(command.h)：  
   //enum LockType { READ = -1/*讀*/ , NONE = 0 /*無(wú)鎖*/, WRITE = 1 /*寫(xiě)*/};  
   bool needWriteLock = c->locktype() == Command::WRITE;  
 
   if ( ! needWriteLock ) {  
      assert( ! c->logTheOp() );  
   }  
 
   mongolock lk( needWriteLock );//聲明鎖對(duì)象  
   Client::Context ctx( dbname , dbpath , &lk , c->requiresAuth() );  
 
   try {  
      string errmsg;  
      //運(yùn)行當(dāng)前command(本文中提到的count命令)  
      if ( ! c->run(dbname, cmdObj, errmsg, result, fromRepl ) ) {  
         result.append( "errmsg" , errmsg );  
         return false;  
      }  
   }  
   catch ( DBException& e ) {  
      stringstream ss;  
      ss << "exception: " << e.what();  
      result.append( "errmsg" , ss.str() );  
      result.append( "code" , e.getCode() );  
      return false;  
   }  
 
   if ( c->logTheOp() && ! fromRepl ) {  
      logOp("c", cmdns, cmdObj);  
   }  
 
   return true;  
} 

到這里，流程基本就執(zhí)行完畢了，之后它會(huì)將結(jié)果傳給result（其傳參為引用類(lèi)型，即："& result"方式）.

#p#

***用一張時(shí)間序來(lái)大體回顧一下這***程：

好了，今天的內(nèi)容到這里就告一段落了。

參考鏈接：
http://www.mongodb.org/display/DOCS/Commands
http://www.10gen.com/reference

原文鏈接:http://www.cnblogs.com/daizhj/archive/2011/04/29/mongos_command_source_code.html

【編輯推薦】

1. Mongodb源碼分析--內(nèi)存文件映射(MMAP)
2. 走進(jìn)MongoDB的世界 展開(kāi)MongoDB的學(xué)習(xí)之旅
3. 淺析Mongodb源碼之游標(biāo)Cursor
4. 野心勃勃的NoSQL新貴 MongoDB應(yīng)用實(shí)戰(zhàn)
5. MongoDB與CouchDB全方位對(duì)比