etcd中raft协议的消息(六)——客户端的写请求相关的消息(MsgProp消息)

妖狐艹你老母 2022-03-21 07:12 251阅读 0赞

在etcd-raft模块中，客户端发往集群中的写请求是通过MsgProp消息表示的。Raft集群中只有Leader节点能够响应客户端的写入请求。

客户端请求的写操作，会通过调用Node接口的Propose函数请求到raft模块中，当Follower接收到MsgProp类型的消息会转发到Leader节点，所以MsgProp消息的主要处理是在raft.stepLeader()方法中实现。主要流程如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NraDIwMTVqYXZh_size_16_color_FFFFFF_t_70][]

1.判断MsgProp是否携带Entry记录，如果未携带则输出异常日志并终止程序

2.检测当前节点是否被移除集群，如果当前节点以Leader状态被移除集群，则不再处理MsgProp消息

3.判断当前是否正在进行Leader节点转移，如果正在转移则返回错误

4.遍历MsgProp消息携带的全部Entry，如果pendingConfIndex大于已提交的位置，则该Entry的类型设置为EntryNormal，否则更新pendingConfIndex值

5.将上述Entries记录追加到当前节点的raftLog中

6.向集群中的其他节点发送MspApp消息复制日志

func stepLeader(r *raft, m pb.Message) error {
        switch m.Type {
        //其他消息省略.....
        case pb.MsgProp:
        if len(m.Entries) == 0 {  //判断MsgProp是否携带Entry记录，如果未携带则输出异常日志并终止程序
            r.logger.Panicf("%x stepped empty MsgProp", r.id)
        }
        if _, ok := r.prs[r.id]; !ok {  //检测当前节点是否被移除集群，如果当前节点以Leader状态被移除集群，则不再处理MsgProp消息
           // If we are not currently a member of the range (i.e. this node
           // was removed from the configuration while serving as leader),
           // drop any new proposals.
           return ErrProposalDropped
        }
        if r.leadTransferee != None {   //判断当前是否正在进行Leader节点转移
           r.logger.Debugf("%x [term %d] transfer leadership to %x is in progress; dropping proposal", r.id, r.Term, r.leadTransferee)
           return ErrProposalDropped
        }
    
        for i, e := range m.Entries {  //遍历MsgProp消息携带的全部Entry
           if e.Type == pb.EntryConfChange {
              if r.pendingConfIndex > r.raftLog.applied {
                 r.logger.Infof("propose conf %s ignored since pending unapplied configuration [index %d, applied %d]",
                e.String(), r.pendingConfIndex, r.raftLog.applied)
                 m.Entries[i] = pb.Entry{Type: pb.EntryNormal}
              } else {
                 r.pendingConfIndex = r.raftLog.lastIndex() + uint64(i) + 1
              }
           }
        }
        r.appendEntry(m.Entries...)  //将上述Entry记录追加到当前节点的raftLog中
        r.bcastAppend()  //向集群中的其他节点发送MspApp消息复制日志
        return nil
        }
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NraDIwMTVqYXZh_size_16_color_FFFFFF_t_70]: /images/20220321/17e5c4adafe44def8e823c22a2450071.png

发表评论取消回复

表情：

评论列表（有 0 条评论，251人围观）

还没有评论，来说两句吧...

相关阅读

相关对HTTP协议的请求消息与响应消息的认识

什么是HTTP呢？ HTTP：概念：Hyper Text Transfer Protocol 超文本传输协议传输协议：定义了，客户端和服务器端通信时，发送数据的格

素颜马尾好姑娘i/ 2022年12月23日 09:44/ 0 赞/ 122 阅读

相关服务器忽略客户端的消息,subethasmtp服务器不打印来自客户端的消息

当我运行客户端时，它应该发送一封电子邮件到我的服务器，然后我想让我的电子邮件服务器将电子邮件的详细信息(到，从，端口，消息)打印到控制台。出于某种原因运行客户端后，服务器上没有

亦凉/ 2022年09月04日 12:54/ 0 赞/ 189 阅读

相关 HTTP的请求消息和响应消息

1.请求消息请求消息：请求行（大致了解请求的内容）消息头（请求的附加信息，对请求和接收数据的一些规定）消息体（客户端向服务器发送的数据） ![在这里插入

爱被打了一巴掌/ 2022年04月25日 06:30/ 0 赞/ 297 阅读

相关 etcd中raft协议的消息(七)——快照复制消息(MsgSnap消息)

MsgSnap消息通过前面介绍的raft.sendAppend()方法可知，在Leader节点尝试向集群中的Follower节点发送MsgApp消息时，如

妖狐艹你老母/ 2022年03月21日 07:12/ 0 赞/ 280 阅读

相关 etcd中raft协议的消息(六)——客户端的写请求相关的消息(MsgProp消息)

在etcd-raft模块中，客户端发往集群中的写请求是通过MsgProp消息表示的。Raft集群中只有Leader节点能够响应客户端的写入请求。

妖狐艹你老母/ 2022年03月21日 07:12/ 0 赞/ 252 阅读

相关 etcd中raft协议的消息(五)—— 客户端只读相关的消息(MsgReadIndex和MsgReadIndexResp消息)

readOnly模式在看MsgReadIndex类型的消息之前需要先对readOnly的模式有所了解，raft结构体中的readOnly作用是批量处理只读

太过爱你忘了你带给我的痛/ 2022年03月21日 07:11/ 0 赞/ 165 阅读

相关 etcd中raft协议的消息(三) ——MspApp和MsgAppResp消息

MsgApp消息上小结我们看到节点发起选举的相关消息，当候选人通过选举成为新的Leader后，首先会调用becomeLeader方法初始化相关状态，然后

叁歲伎倆/ 2022年03月21日 06:26/ 0 赞/ 279 阅读

相关 etcd中raft协议的消息(二) —— 选举相关的消息(MsgHup、MsgPreVote/MsgPreVoteResp、MsgVote/MsgVoteResp）

一、MsgHup消息在raft协议中我们看到，Leader节点推动心跳计时器，而Follower节点会推动选举计时器。源码主要在etcd的github.com/e

野性酷女/ 2022年03月21日 06:12/ 0 赞/ 165 阅读

相关 etcd中raft协议的消息(一) —— 简述raft中的所有类型消息

etcd中的Raft算法简介 Raft 是一种为了管理复制日志的一致性算法。一致性算法是从复制状态机的背景下提出的（参考英文原文引用37）。在这种方法中，一组服务器

心已赠人/ 2022年03月21日 06:08/ 0 赞/ 417 阅读

相关 etcd中raft协议的消息(四) —— 心跳相关的消息(MsgBeat、MsgHeartbeat、MsgHeartbeatResp和MsgCheckQuorum）

MsgBeat和MsgHeartbeat消息 Leader推动心跳计时器(heartbeatElapsed)，而Follower推动选举计时器(electio

不念不忘少年蓝@/ 2022年03月20日 21:12/ 0 赞/ 225 阅读