void clusterSendPing(clusterLink *link, int type) { //随机算去本节点所在集群中的任意两个其他node节点(不包括link本节点和link对应的节点)信息发送给link对应的节点

    unsigned char buf[sizeof(clusterMsg)];

    clusterMsg *hdr = (clusterMsg*) buf;

    int gossipcount = , totlen;

    /* freshnodes is the number of nodes we can still use to populate the

     * gossip section of the ping packet. Basically we start with the nodes

     * we have in memory minus two (ourself and the node we are sending the

     * message to). Every time we add a node we decrement the counter, so when

     * it will drop to <= zero we know there is no more gossip info we can

     * send. */

    int freshnodes = dictSize(server.cluster->nodes)-; //除去本节点和接收本ping信息的节点外，整个集群中有多少其他节点

   // 如果发送的信息是 PING ，那么更新最后一次发送 PING 命令的时间戳

    if (link->node && type == CLUSTERMSG_TYPE_PING)

        link->node->ping_sent = mstime();

   // 将当前节点的信息（比如名字、地址、端口号、负责处理的槽）记录到消息里面

    clusterBuildMessageHdr(hdr,type);

    /* Populate the gossip fields */

    // 从当前节点已知的节点中随机选出两个节点

    // 并通过这条消息捎带给目标节点，从而实现 gossip 协议

    // 每个节点有 freshnodes 次发送 gossip 信息的机会

    // 每次向目标节点发送 3 个被选中节点的 gossip 信息（gossipcount 计数）

    while(freshnodes >  && gossipcount < ) {

        // 从 nodes 字典中随机选出一个节点（被选中节点）

        dictEntry *de = dictGetRandomKey(server.cluster->nodes);

        clusterNode *this = dictGetVal(de);

        clusterMsgDataGossip *gossip; ////ping  pong meet消息体部分用该结构

        int j;

        if (this == myself ||

            this->flags & (REDIS_NODE_HANDSHAKE|REDIS_NODE_NOADDR) ||

            (this->link == NULL && this->numslots == ))

        {

                freshnodes--; /* otherwise we may loop forever. */

                continue;

        }

        /* Check if we already added this node */

         // 检查被选中节点是否已经在 hdr->data.ping.gossip 数组里面

         // 如果是的话说明这个节点之前已经被选中了

         // 不要再选中它（否则就会出现重复）

        for (j = ; j < gossipcount; j++) {  //这里是避免前面随机选择clusterNode的时候重复选择相同的节点

            if (memcmp(hdr->data.ping.gossip[j].nodename,this->name,

                    REDIS_CLUSTER_NAMELEN) == ) break;

        }

        if (j != gossipcount) continue;

        /* Add it */

        // 这个被选中节点有效，计数器减一

        freshnodes--;

        // 指向 gossip 信息结构

        gossip = &(hdr->data.ping.gossip[gossipcount]);

        // 将被选中节点的名字记录到 gossip 信息

        memcpy(gossip->nodename,this->name,REDIS_CLUSTER_NAMELEN);

        // 将被选中节点的 PING 命令发送时间戳记录到 gossip 信息

        gossip->ping_sent = htonl(this->ping_sent);

        // 将被选中节点的 PING 命令回复的时间戳记录到 gossip 信息

        gossip->pong_received = htonl(this->pong_received);

        // 将被选中节点的 IP 记录到 gossip 信息

        memcpy(gossip->ip,this->ip,sizeof(this->ip));

        // 将被选中节点的端口号记录到 gossip 信息

        gossip->port = htons(this->port);

        // 将被选中节点的标识值记录到 gossip 信息

        gossip->flags = htons(this->flags);

        // 这个被选中节点有效，计数器增一

        gossipcount++;

    }

    // 计算信息长度

    totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);

    totlen += (sizeof(clusterMsgDataGossip)*gossipcount);

    // 将被选中节点的数量（gossip 信息中包含了多少个节点的信息）

    // 记录在 count 属性里面

    hdr->count = htons(gossipcount);

    // 将信息的长度记录到信息里面

    hdr->totlen = htonl(totlen);

    // 发送信息

    clusterSendMessage(link,buf,totlen);

}

3. 收到集群中超过半数的节点认为某节点处于疑似下线状态，则判定该节点下线，并广播

void clusterSendFail(char *nodename) {

//如果超过一半的主节点认为该nodename节点下线了，则需要把该节点下线信息同步到整个cluster集群

    unsigned char buf[sizeof(clusterMsg)];

    clusterMsg *hdr = (clusterMsg*) buf;

     // 创建下线消息

     clusterBuildMessageHdr(hdr,CLUSTERMSG_TYPE_FAIL);

     // 记录命令

     memcpy(hdr->data.fail.about.nodename,nodename,REDIS_CLUSTER_NAMELEN);

     // 广播消息

    clusterBroadcastMessage(buf,ntohl(hdr->totlen));

}

void clusterBroadcastMessage(void *buf, size_t len) { //buf里面的内容为clusterMsg+clusterMsgData

    dictIterator *di;

    dictEntry *de;

     // 遍历所有已知节点

    di = dictGetSafeIterator(server.cluster->nodes);

    while((de = dictNext(di)) != NULL) {

        clusterNode *node = dictGetVal(de);

         // 不向未连接节点发送信息

        if (!node->link) continue;

         // 不向节点自身或者 HANDSHAKE 状态的节点发送信息

        if (node->flags & (REDIS_NODE_MYSELF|REDIS_NODE_HANDSHAKE))

            continue;

         // 发送信息

        clusterSendMessage(node->link,buf,len);

    }

    dictReleaseIterator(di);