MongoDB源码阅读之ReplSet源码分析

g87616758

1. ReplSet源码结构
  

rs_config.h replSet间同步设置的工具类 　　rs_member.h 心跳检测类和replSet成员状态的定义 　　rs_sync.h 同步数据类 　　rs.h 定义了几乎所有replSet相关的类（Member:replSet中的节点成员， 　　GhostSync：备份同步类，ReplSet：管理所有Member的核心类）

  2. ReplSet的结构分析
  
　　RSBase定义了线程锁。
　　ReplSetImpl完成了大部分Replication Set的操作：心跳检测，选举，设置主节点，查询节点信息。
　　Member记录其他节点的信息，Manager查询节点信息，ReplSetHealthPoolTask心跳检测，ReplSetConfig同步设置，Consensus选举主节点，StateBox设置主节点。
　　ReplSet封装了很多方便的操作。
  3. 创建并设置ReplSet
  　　在mongod开始运行后(mongoDBMain)，会启动监听程序同时，根据运行参数中是否标明了”--replSet”，调用startReplication来创建ReplSet。


    void startReplication() {
        /* if we are going to be a replica set, we aren't doing other forms of replication. */
        if( !cmdLine._replSet.empty() ) {  //看看参数里面有没有--replSet
            if( replSettings.slave || replSettings.master ) {   //这个参数不能与—slave与—master共存
                log() box.getPrimary();           //当前的主服务器
            const Member* hopeful = theReplSet->findById(id);               //希望成为主机的服务器（从上面的代码看是发送请求方服务器）
            const Member *highestPriority = theReplSet->getMostElectable();    //当前节点心目中的主机
            //以下判断发现不符合条件的就否决投票
            if( !hopeful ) {  //没有目标服务器
                errmsg = str::stream() lastOpTimeWritten >= hopeful->hbinfo().opTime ) {  
                // hbinfo is not updated, so we have to check the primary's last optime separately
                errmsg = str::stream() = hopeful->hbinfo().opTime ) {
                // other members might be aware of more up-to-date nodes
                errmsg = str::stream() fullName()  hopeful->config().priority) {
                errmsg = str::stream() fullName() isElectable(id) ||
                (highestPriority && highestPriority->config().priority > hopeful->config().priority)) {
                return true;
            }
            return false;
        }

//得到投票数据以后解析
bool Consensus::weAreFreshest(bool& allUp, int& nTies) {
       //省略发送请求的部分
       //请求返回后存储在list中
        int nok = 0;
        allUp = true;
        for( list::iterator i = L.begin(); i != L.end(); i++ ) {
        //i存储这其他节点返回的结果
            if( i->ok ) {
                nok++;
                if( i->result["fresher"].trueValue() ) {      //当前服务器不是最新的
                    log() result["errmsg"];
                    if (!msg.eoo()) {
                        log()