1.//命令注册，所有注册的命令最终全部保存到_commands全局map表中  
2.//name和oldName实际上是同一个command，只是可能因为历史原因，命令名改名了  
3.Command::Command(StringData name, StringData oldName)   
4.    //命令名字符串  
5.    : _name(name.toString()),   
6.     //对应命令执行统计，total代表总的，failed代表执行失败的次数  
7.     _commandsExecutedMetric("commands." + _name + ".total", &_commandsExecuted),  
8.     _commandsFailedMetric("commands." + _name + ".failed", &_commandsFailed) {  
9.    //如果_commands map表还没有生成，则new一个  
10.    if (_commands == 0)  
11.        _commands = new CommandMap();  
12.    ......  
13.    //把name命令对应的command添加到map表中  
14.    Command*& c = (*_commands)[name];  
15.    if (c)  
16.        log() << "warning: 2 commands with name: " << _name;  
17.    c = this;  
18.    ......  
19.  
20.    //大部分命令name和oldName是一样的，所以在数组中只会记录一个  
21.    //如果改名过，则name和oldName就不一样，这时候都需要注册到map表，对应同一个command  
22.    if (!oldName.empty()) //也就是name和oldName两个命令对应的是同一个this类  
23.        (*_commands)[oldName.toString()] = this;  
24.}  

1.//insert命令初始化  
2.class CmdInsert : public WriteCommand { //  
3.public:  
4.    //insert命令初始化构造  
5.    CmdInsert() : WriteCommand("insert") {}  
6.    ......  
7.    //认证检查  
8.    Status checkAuthForRequest(...) final {  
9.        ......  
10.    }  
11.  
12.    //真正的Insert插入文档会走这里面  
13.    void runImpl(...);  
14.    }  
15.} cmdInsert; //直接定义一个cmdInsert全局变量  
16.  
17.//update命令初始化  
18.class CmdUpdate: public WriteCommand { //  
19.public:  
20.    //update命令初始化构造  
21.    CmdUpdate() : WriteCommand("update") {}  
22.    ......  
23.    //认证检查  
24.    Status checkAuthForRequest(...) final {  
25.        ......  
26.    }  
1.    //查询计划执行过程  
2.    Status explain(...) const override {  
3.          ......  
4.    }  
27.    //真正的update插入文档会走这里面  
28.    void runImpl(...);  
29.    }  
30.} cmdUpdate; //直接定义一个cmdUpdate全局变量  
31.  
32.//delete命令初始化  
33.class CmdDelete: public WriteCommand { //  
34.public:  
35.    //delete命令初始化构造  
36.    CmdDelete() : WriteCommand("delete") {}  
37.    ......  
38.    //认证检查  
39.    Status checkAuthForRequest(...) final {  
40.        ......  
41.    }  
5.    //查询计划执行过程  
6.    Status explain(...) const override {  
7.          ......  
8.    }  
42.  
43.    //真正的delete插入文档会走这里面  
44.    void runImpl(...);  
45.    }  
46.} cmdDelete; //直接定义一个cmdDelete全局变量  

9.//find命令实现类  
10.class FindCmd : public BasicCommand {  
11.public:  
12.    //初始化构造  
13.    FindCmd() : BasicCommand("find") {}  
14.    ......  
15.      
16.    //查询计划执行过程  
17.    Status explain(...) const override {  
18.          ......  
19.    }  
20.} findCmd; //直接定义一个findCmd全局变量    

1.//执行计划相关的几个command注册过程，通过new实现  
2.MONGO_INITIALIZER_WITH_PREREQUISITES(SetupPlanCacheCommands, MONGO_NO_PREREQUISITES)  
3.(InitializerContext* context) {  
4.    //执行计划相关的几个命令注册  
5.    new PlanCacheListQueryShapes();  
6.    new PlanCacheClear();  
7.    new PlanCacheListPlans();  
8.    return Status::OK();  
9.}   
10.  
11.//test命令相关的几个command注册过程，也是通过new实现  
12.MONGO_INITIALIZER(RegisterEmptyCappedCmd)(InitializerContext* context) {  
13.    //必须使能testCommandsEnabled，该命令才有效  
14.    if (Command::testCommandsEnabled) {  
15.        new CapTrunc();  
16.        new CmdSleep();  
17.        new EmptyCapped();  
18.        new GodInsert();  
19.    }  
20.    return Status::OK();  
} 

1.//命令模块基类基础接口初始化实现  
2.class Command : public CommandInterface {  
3.public:  
4.    //获取集合名collection  
5.    static std::string parseNsFullyQualified(...);  
6.    //获取DB.COLLECTION  
7.    static NamespaceString parseNsCollectionRequired(...);  
8.    //map表结构  
9.    using CommandMap = StringMap<Command*>;  
10.    ......  
11.    //获取命令名  
12.    const std::string& getName() const final {  
13.        return _name;  
14.    }  
15.    ......  
16.    //应答保留填充字段长度  
17.    std::size_t reserveBytesForReply() const override {  
18.        return 0u;  
19.    }  
20.    //该命令是否只能在admin库执行，默认不可以  
21.    bool adminOnly() const override {  
22.        return false;  
23.    }  
24.    //该命令是否需要权限认证检查？默认不需要  
25.    bool localHostOnlyIfNoAuth() override {  
26.        return false;  
27.    }  
28.    //该命令执行后是否进行command操作计数  
29.    bool shouldAffectCommandCounter() const override {  
30.        return true;  
31.    }  
32.    //该命令是否需要认证  
33.    bool requiresAuth() const override {  
34.        return true;  
35.    }  
36.    //help帮助信息  
37.    void help(std::stringstream& help) const override;  
38.    //执行计划信息  
39.    Status explain(...) const override;  
40.    //日志信息相关  
41.    void redactForLogging(mutablebson::Document* cmdObj) override;  
42.    BSONObj getRedactedCopyForLogging(const BSONObj& cmdObj) override;  
43.    //该命令是否为maintenance模式，默认false  
44.    bool maintenanceMode() const override {  
45.        return false;  
46.    }  
47.    //maintenance是否支持，默认支持  
48.    bool maintenanceOk() const override {  
49.        return true;   
50.    }  
51.    //本地是否支持非本地ReadConcern,默认不支持  
52.    bool supportsNonLocalReadConcern(...) const override {  
53.        return false;  
54.    }  
55.    //是否允许AfterClusterTime，默认允许  
56.    bool allowsAfterClusterTime(const BSONObj& cmdObj) const override {  
57.        return true;  
58.    }  
59.    //3.6版本默认opCode=OP_MSG,所以对应逻辑操作op为LogicalOp::opCommand  
60.    LogicalOp getLogicalOp() const override {  
61.        return LogicalOp::opCommand;  
62.    }  
63.    //例如find就是kRead，update  delete insert就是kWrite，非读写操作就是kCommand  
64.    ReadWriteType getReadWriteType() const override {  
65.        return ReadWriteType::kCommand;  
66.    }  
67.    //该命令执行成功统计  
68.    void incrementCommandsExecuted() final {  
69.        _commandsExecuted.increment();  
70.    }  
71.  
72.    //该命令执行失败统计  
73.    void incrementCommandsFailed() final {  
74.        _commandsFailed.increment();  
75.    }  
76.  
77.    //真正得命令运行  
78.    bool publicRun(OperationContext* opCtx, const OpMsgRequest& request, BSONObjBuilder& result);  
79.  
80.    //获取支持的所有命令信息  ListCommandsCmd获取所有支持的命令 db.listCommands()  
81.    static const CommandMap& allCommands() {  
82.        return *_commands;  
83.    }  
84.  
85.    //没用  
86.    static const CommandMap& allCommandsByBestName() {  
87.        return *_commandsByBestName;  
88.    }  
89.  
90.    //收到不支持命令的统计，例如mongo shell敲一个mongodb无法识别得命令，这里就会统计出来  
91.    static Counter64 unknownCommands;  
92.    //根据命令字符串名查找对应命令  
93.    static Command* findCommand(StringData name);  
94.    //执行结果  
95.    static void appendCommandStatus(...);  
96.    //是否启用了command test功能  
97.    static bool testCommandsEnabled;  
98.    //help帮助信息  
99.    static bool isHelpRequest(const BSONElement& helpElem);  
100.    static const char kHelpFieldName[];  
101.    //认证检查，检查是否有执行该命令得权限  
102.    static Status checkAuthorization(Command* c,  
103.                                     OperationContext* opCtx,  
104.                                     const OpMsgRequest& request);  
105.    ......  
106.private:  
107.    //添加地方见Command::Command(    
108.    //所有的command都在_commands中保存  
109.    static CommandMap* _commands;  
110.    //暂时没用  
111.    static CommandMap* _commandsByBestName;  
112.    //执行对应命令run接口  
113.    virtual bool enhancedRun(OperationContext* opCtx,  
114.                             const OpMsgRequest& request,  
115.                             BSONObjBuilder& result) = 0;  
116.    //db.serverStatus().metrics.commands命令查看，本命令的执行统计,包括执行成功和执行失败的  
117.    Counter64 _commandsExecuted;   
118.    Counter64 _commandsFailed;  
119.   //命令名，如"find" "insert" "update" "createIndexes" "deleteIndexes"  
120.    const std::string _name;  
121.  
122.    //每个命令执行是否成功通过MetricTree管理起来，也就是db.serverStatus().metrics.commands统计信息  
123.    //通过MetricTree特殊二叉树管理起来  
124.    ServerStatusMetricField<Counter64> _commandsExecutedMetric;  
125.    ServerStatusMetricField<Counter64> _commandsFailedMetric;  
126.};  

1.//该命令执行成功统计  
2.void incrementCommandsExecuted() final {  
3.    _commandsExecuted.increment();  
4.}  
5.  
6.//该命令执行失败统计  
7.void incrementCommandsFailed() final {  
8.    _commandsFailed.increment();  
9.}  
1.//命令入口  
2.void execCommandDatabase(...)  
3.{  
4.    ......  
5.    //该命令执行次数统计  db.serverStatus().metrics.commands可以获取统计信息  
6.    command->incrementCommandsExecuted();  
7.    ......  
8.    //真正的命令执行在这里面  
9.    retval = runCommandImpl(opCtx, command, request, replyBuilder, startOperationTime);  
10.  
11.    //该命令失败次数统计  
12.    if (!retval) {  
13.        command->incrementCommandsFailed();  
14.    }  
15.    ......  
16.}  

1.  bool insertBatchAndHandleErrors(...) {  
2.    ......  
3.    //一次性一条一条插入，上面的固定集合是一次性插入  
4.    for (auto it = batch.begin(); it != batch.end(); ++it) {  
5.        //insert操作计数  
6.        globalOpCounters.gotInsert();   
7.    }  
8.    ......  
9.} 

1.//mongod代理insert统计核心流程  
2.bool ClusterWriteCmd::enhancedRun(...) {  
3.    ......  
4.    if (_writeType == BatchedCommandRequest::BatchType_Insert) {  
5.        //insert计数  
6.        for (size_t i = 0; i < numAttempts; ++i) {  
7.            globalOpCounters.gotInsert();  
8.        }  
9.    }  
10.    ......  
11.} 

1.    bool ClusterFindCmd::run(...) {  
2.    //find操作统计，也就是query统计  
3.    globalOpCounters.gotQuery();  
4.    ......  
5.}  

1.bool FindCmd::run(...) {  
2.    //find操作统计，也就是query统计  
3.    globalOpCounters.gotQuery();  
4.    ......  
5.} 

1.bool ClusterWriteCmd::enhancedRun(...) {  
6.    //update操作统计
7.    globalOpCounters.gotUpdate();  
8.    ......  
9.} 

1.//mongos代理update统计核心流程  
2.bool ClusterWriteCmd::enhancedRun(...) {  
3.    ......  
4.    if (_writeType == BatchedCommandRequest::BatchType_Update) {  
5.        //insert计数  
6.    for (size_t i = 0; i < numAttempts; ++i) {  
7.         globalOpCounters.gotUpdate();  
8.       }  
9.    }  
10.    ......  
11.}  

1.//mongos代理update统计核心流程  
2.bool ClusterWriteCmd::enhancedRun(...) {  
3.    ......  
4.    if (_writeType == BatchedCommandRequest::BatchType_Update) {  
5.        //insert计数  
6.    for (size_t i = 0; i < numAttempts; ++i) {  
7.         globalOpCounters.gotUpdate();  
8.       }  
9.    }  
10.    ......  
11.}  

1.static SingleWriteResult performSingleDeleteOp(...) {  
2.    ......  
3.    //分片mongod实例delete操作统计  
4.    globalOpCounters.gotDelete();  
5.    ......  
6.}  

1.//mongos代理getMore统计核心流程  
2.bool ClusterGetMoreCmd::enhancedRun(...) {  
3.    //代理getMore统计  
4.    globalOpCounters.gotGetMore();  
5.    ......  
6.}  

1.//mongod分片存储节点getMore统计  
2.bool ClusterGetMoreCmd::enhancedRun(...) {  
3.    //存储节点mongod getMore统计  
4.    globalOpCounters.gotGetMore();  
5.    ......  
6.}  

1.//mongos代理commands统计  
2.void execCommandDatabase(...) {  
3.    ......  
4.    if (command->shouldAffectCommandCounter()) {  
5.        OpCounters* opCounters = &globalOpCounters;  
6.        opCounters->gotCommand();  
7.    }  
8.    ......  
9.}  

1.void execCommandDatabase(...) {  
2.    ......  
3.    //是否进行command统计  
4.    if (command->shouldAffectCommandCounter()) {  
5.        OpCounters* opCounters = &globalOpCounters;  
6.        //commands计数自增
7.        opCounters->gotCommand();  
8.    }  
9.    ......  
10.}  

1.class Command : {  
2.    ......  
3.    //该命令是否进行command操作计数，默认需要。如果不需要进行command统计，可在命令继承类中置为false  
4.    bool shouldAffectCommandCounter() const override {  
5.        return true;  
6.    }  
7.    ......  
8.}  

1.DbResponse ServiceEntryPointMongod::handleRequest(...) {  
2.    ......  
3.    //记录开始时间  
4.    //获取当前操作对应curop  
5.    CurOp& currentOp = *CurOp::get(opCtx);  
6.  
7.    ......  
8.    //执行请求对应命令  
9.    runCommands(opCtx, m);  
10.    ......  
11.  
12.    //记录结束时间  
13.    currentOp.ensureStarted();  
14.    currentOp.done();   
15.    //获取开始和结束时间差，也就是命令执行时间  
16.    debug.executionTimeMicros = durationCount<Microseconds>  
17.                 (currentOp.elapsedTimeExcludingPauses());  
18.    //记录超过阀值的慢日志到日志文件  
19.    if (shouldLogOpDebug || (shouldSample && debug.executionTimeMicros > logThresholdMs * 1000LL)) {  
20.        ......  
21.    //记录慢日志到日志文件  
22.        log() << debug.report(&c, currentOp, lockerInfo.stats);   
23.    }  
24.    //记录慢日志到system.profile集合   
25.    if (currentOp.shouldDBProfile(shouldSample)) {  
26.        ......  
27.        //记录慢日志到system.profile集合中  
28.        profile(opCtx, op);  
29.    }  
30.    ......  
31.}  

1.//获取操作类型  
2.Command::ReadWriteType CurOp::getReadWriteType() const {  
3.    ......  
4.    switch (_logicalOp) {  
5.    //getmore find归纳为读  
6.        case LogicalOp::opGetMore:  
7.        case LogicalOp::opQuery:  
8.            return Command::ReadWriteType::kRead;  
9.    //增删改统一归纳为写  
10.        case LogicalOp::opUpdate:  
11.        case LogicalOp::opInsert:  
12.        case LogicalOp::opDelete:  
13.            return Command::ReadWriteType::kWrite;  
14.    //增删改以外的归纳为command  
15.        default:  
16.            return Command::ReadWriteType::kCommand;  
17.    }  
} 

1.//Top::_incrementHistogram调用  
2.//操作和时延计数操作  
3.void OperationLatencyHistogram::increment(uint64_t latency, Command::ReadWriteType type) {  
4.    int bucket = _getBucket(latency);  
5.    switch (type) {  
6.        //读时延累加，读计数自增  
7.        case Command::ReadWriteType::kRead:  
8.            _incrementData(latency, bucket, &_reads);  
9.            break;  
10.        //写时延累加，写计数自增    
11.        case Command::ReadWriteType::kWrite:  
12.            _incrementData(latency, bucket, &_writes);  
13.            break;  
14.        //command时延累加，command计数自增    
15.        case Command::ReadWriteType::kCommand:  
16.            _incrementData(latency, bucket, &_commands);  
17.            break;  
18.        default:  
19.            MONGO_UNREACHABLE;  
20.    }  
21.}