MongoDB提供了auto-sharding 功能。因为其是auto-sharding，即mongodb通过mongos(一个自动分片模块，用于构建一个大规模的可扩展的数据库集群,这个集群可以并入动态增加的机器)自动建立一个水平扩展的数据库集群系统，将数据库分表存储在sharding的各个节点上。

　　一个mongodb集群包括一些shards(包括一些mongod进程)，mongos路由进程，一个或多个config服务器。

　　下面是一些相关词汇说明：

　　Shards：每一个shard包括一个或多个服务和存储数据的mongod进程(mongod是MongoDB数据的核心进程)典型的每个shard开启多个服务来提高服务的可用性。这些服务/mongod进程在shard中组成一个复制集

　　Chunks：Chunk是一个来自特殊集合中的一个数据范围，(collection，minKey，maxKey)描叙一个chunk，它介于minKey和maxKey范围之间。例如chunks 的maxsize大小是100M，如果一个文件达到或超过这个范围时，会被切分到2个新的chunks中。当一个shard的数据过量时，chunks将会被迁移到其他的shards上。同样，chunks也可以迁移到其他的shards上

　　Config Servers：Config服务器存储着集群的metadata信息，包括每个服务器，每个shard的基本信息和chunk信息Config服务器主要存储的是chunk信息。每一个config服务器都复制了完整的chunk信息。

　　今天要介绍的源码主要是Mongos的主入口函数的执行流程，首先我们打开Mongos的项目(可通过打开源码dbdb_10.sln加载所有项目)，如下图：

　　

　　注：如果要调试mongos，需要设置一个mongod进程和一个Config Server,形如：

　　d:mongodb>bin>mongod –dbpath d:mongodbdb –port 27012

　　d:mongodb>bin>mongod –configsvr –dbpath d:mongodbdb –port 27022

　　然后在vs2010中配置相应的boost路径信息及启动参数信息，如下图：

　　

 点击放大

　　

 点击放大

　　

 点击放大

　　下面开始正文。首先打开mongos项目中的server.cpp文件，找到下面方法：

int main(int argc, char* argv[]) {     try {         return _main(argc, argv);     }     catch(DBException& e) {         cout << “uncaught exception in mongos main:” << endl;         cout << e.toString() << endl;     }     catch(std::exception& e) {         cout << “uncaught exception in mongos main:” << endl;         cout << e.what() << endl;     }     catch(…) {         cout << “uncaught exception in mongos main” << endl;     }     return 20; }

　　该方法是mongos的主函数，代码很简，它主要是try方式执行_main方法，下面是_main的执行流程：

　　在完成option描述信息的初始化操作之后，下面就开始对启动命令行参数进行分析和执行了，如下：

　　上面完成了对命令行参数分析之后，接下来mongos要加载绑定几个hook：

　　上面的hook主要是在mongos主程序启动完成后，在运行期间执行一些数据操作时执行某些额外操作。从代码可以看出，mongos使用了链接池功能以提升获取链接的效率，具体实现机制我会在后绪章节中加以阐述。代码中的ReplicaSetMonitor类为一个维护和获取有效复制集的监视类，它提供了获取有效master,slave 的方法。完成这一步绑定后，接着mongos就会对config server信息进行初始化和升级操作了，如下:

　　最后就是启动侦听服务，这里mongos启动了两个侦听服务器，一个是以线程方式启动，用于接收授权的用户操作信息，另一个则是普遍的循环侦听服务，用于侦听客户端message如下：

　　到这里，main代码就介绍完了，但上面代码段中的start才是启动balancer来均衡各个shard间chunk的操作，所以我们接着再看一下该方法的实现：

void start( const MessageServer::Options& opts ) {         setThreadName( “mongosMain” );//设置线程名称         installChunkShardVersioning();//绑定chunk shard版本控制信息         balancer.go();//均衡shard 中chunk(节点)信息，详情参见 balance.cpp的run()方法         cursorCache.startTimeoutThread();//对空闲(过期)游标进行清除操作         log() << “waiting for connections on port ” << cmdLine.port << endl;         ShardedMessageHandler handler;         MessageServer * server = createServer( opts , &handler );//构造server对象         server->setAsTimeTracker();         server->run();//启动message服务     }