日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

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

今天就專門(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è)類中，按其使用場(chǎng)景可以為分如下幾類，分別是：

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)類圖：

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

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

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

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

#p#

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

 
 
 
 

  
  
  
  
//commands.h  
  
  
  
  
class Command {  
  
  
  
  
public:  
  
  
  
  
   //執(zhí)行當(dāng)前Command時(shí)所使用的鎖類型  
  
  
  
  
   enum LockType { READ = -1/*讀*/ , NONE = 0 /*無(wú)鎖*/, WRITE = 1 /*寫(xiě)*/};  
  
  
  
  
 
  
  
  
  
   const string name;  
  
  
  
  
 
  
  
  
  
   /* 運(yùn)行指定的命令，需要子類實(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ò)在查詢命令中打開(kāi) 'slaveok'選項(xiàng)，客戶端強(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/  
  
  
  
  
   @param oldName： 舊選項(xiàng)，表示當(dāng)前command的舊(已棄用)名稱  
  
  
  
  
   */ 
  
  
  
  
   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查詢時(shí)使用  
  
  
  
  
   //注意也包含該command的舊名稱（構(gòu)造方法中的oldName參數(shù)）所對(duì)應(yīng)的對(duì)象，  
  
  
  
  
   static map * _commands;  
  
  
  
  
   //與上面形同，但不含舊名稱的command map  
  
  
  
  
   static map * _commandsByBestName;  
  
  
  
  
   //將web類型的command放到該map中  
  
  
  
  
   static map * _webCommands;  
  
  
  
  
 
  
  
  
  
public:  
  
  
  
  
   static const map* commandsByBestName() { return _commandsByBestName; }  
  
  
  
  
   static const map* webCommands() { return _webCommands; }  
  
  
  
  
   /** @return 返回是否找到或已執(zhí)行command */ 
  
  
  
  
   static bool runAgainstRegistered(const char *ns, BSONObj& jsobj, BSONObjBuilder& anObjBuilder);  
  
  
  
  
   static LockType locktype( const string& name );  
  
  
  
  
   //根據(jù)命令名稱在集合中找到相應(yīng)Command對(duì)象  
  
  
  
  
   static Command * findCommand( const string& name );  
  
  
  
  
}; 
 
 
 
 

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

 
 
 
 

  
  
  
  
//commands.cpp  
  
  
  
  
Command* Command::findCommand( const string& name ) {  
  
  
  
  
   //從_commands map中找到指定name的Command對(duì)象  
  
  
  
  
   map::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;  
  
  
  
  
   //如為空（系統(tǒng)剛啟動(dòng)時(shí)）則實(shí)例化_commandsByBestName  
  
  
  
  
   if( _commandsByBestName == 0 )  
  
  
  
  
      _commandsByBestName = new map;  
  
  
  
  
   Command*& c = (*_commands)[name];//獲取指定名稱的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;  
  
  
  
  
      //綁定到_webCommands中的相應(yīng)name上  
  
  
  
  
      (*_webCommands)[name] = this;  
  
  
  
  
   }  
  
  
  
  
   //如有舊名稱，則也綁到_commands的oldName所指向的command  
  
  
  
  
   if( oldName )  
  
  
  
  
      (*_commands)[oldName] = this;  
  
  
  
  
}  
 
 
 
 

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

 
 
 
 

  
  
  
  
} cmdCount; 
 
 
 
 

可以看到，這里使用的是在類聲明后定義對(duì)象的方式來(lái)執(zhí)行構(gòu)造方法（這時(shí)并未使用new實(shí)例化方式來(lái)創(chuàng)建對(duì)象指針），進(jìn)而注冊(cè)該command到map。當(dāng)然繼承自Command的子類必須要實(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)指向端口上的用戶(client)請(qǐng)求，這些請(qǐng)求在mongod中被改裝成了message在各個(gè)功能類中傳遞。當(dāng)用戶發(fā)送一個(gè)count指令操作時(shí)，其會(huì)在query.cpp中執(zhí)行下面方法（以count查詢指令的執(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查詢對(duì)象，該對(duì)象包括查詢記錄數(shù)字，以及記錄跳轉(zhuǎn)偏移量等信息，  
  
  
  
  
 
  
  
  
  
   //這些值會(huì)在訪問(wèn)磁盤(pán)查詢時(shí)使用，用法參見(jiàn):query.cpp 662行的virtual void _init()方法  
  
  
  
  
   shared_ptr pq_shared( new ParsedQuery(q) );  
  
  
  
  
   ParsedQuery& pq( *pq_shared );  
  
  
  
  
   ......  
  
  
  
  
   //對(duì)查詢命令判斷，指令形如abc.$cmd.findOne( { ismaster:1 } )  
  
  
  
  
   if ( pq.couldBeCommand() ) {//_ns中包括$cmd字符串  
  
  
  
  
  BufBuilder bb;  
  
  
  
  
  bb.skip(sizeof(QueryResult));  
  
  
  
  
  BSONObjBuilder cmdResBuf;  
  
  
  
  
  //對(duì)查詢權(quán)限判斷，并執(zhí)行相應(yīng)查詢指令  
  
  
  
  
  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)的查詢消息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名稱從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子類都有該屬性)，枚舉定義如下(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（其傳參為引用類型，即："& 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ì)比

新聞標(biāo)題：MongoDB源碼分析--Command體系架構(gòu)
分享鏈接：http://www.dlmjj.cn/article/dhcijge.html