关于Raft算法RequestVote RPC接收方实现逻辑的疑问

你的代码确实遗漏了Raft协议中几个关键判断逻辑，且日志新旧的比较逻辑不符合论文定义，具体问题和修正方案如下：

核心遗漏点与错误 #

1. 未处理任期优先级检查
   Raft协议的核心原则是高任期优先，接收方必须先对比请求的term和自身的currentTerm：

• 如果请求term < currentTerm：直接拒绝投票，当前节点任期更高，候选者已过时
• 如果请求term > currentTerm：节点需立刻转为跟随者，更新自身currentTerm为请求的term，清空votedFor后再进行后续判断

2. votedFor判断逻辑不完整
   当votedFor不为空时，必须先确认是否已投给当前候选者（votedFor == vote.candidateId），只有满足这个前提，才需要继续检查日志新旧；若votedFor是其他节点，直接拒绝投票。

3. 日志新旧比较逻辑错误
   论文中“候选者日志至少与接收方一样新”的判断规则是先比任期，再比索引：

• 取接收方最后一条日志的任期（self_last_log_term）和索引（self_last_log_index）
• 情况1：候选者的lastLogTerm > self_last_log_term → 候选者日志更新
• 情况2：候选者的lastLogTerm == self_last_log_term且lastLogIndex >= self_last_log_index → 候选者日志一样新或更新
  你的代码直接访问log[vote.lastLogIndex]不仅可能出现索引越界，逻辑也完全不符合该规则。

修正后的实现示例 #

class LogEntry:
    def __init__(self, term: int, command):
        self.term = term
        self.command = command

# 节点自身状态
current_term: int = 0
voted_for: str | None = None
log: list[LogEntry] = []

class RequestVote:
    def __init__(self, term: int, candidate_id: str, last_log_index: int, last_log_term: int):
        self.term = term
        self.candidate_id = candidate_id
        self.last_log_index = last_log_index
        self.last_log_term = last_log_term

def on_request_vote_received(vote: RequestVote) -> None:
    # 1. 请求任期小于当前任期，直接拒绝
    if vote.term < current_term:
        send_failure()
        return
    
    # 2. 请求任期更高，转为跟随者并更新状态
    if vote.term > current_term:
        global current_term, voted_for
        current_term = vote.term
        voted_for = None
    
    # 3. 已投给其他节点，拒绝投票
    if voted_for is not None and voted_for != vote.candidate_id:
        send_failure()
        return
    
    # 4. 判断候选者日志是否足够新
    self_last_log_index = len(log) - 1
    self_last_log_term = log[self_last_log_index].term if log else 0
    
    log_is_up_to_date = False
    if vote.last_log_term > self_last_log_term:
        log_is_up_to_date = True
    elif vote.last_log_term == self_last_log_term:
        if vote.last_log_index >= self_last_log_index:
            log_is_up_to_date = True
    
    if log_is_up_to_date:
        # 授予投票并记录投票对象
        global voted_for
        voted_for = vote.candidate_id
        send_success()
    else:
        send_failure()

补充说明 #

• 空日志处理：若接收方日志为空（刚启动），self_last_log_term设为0，此时只要候选者的lastLogTerm≥0（必然满足）且索引≥0（候选者日志为空时也满足），就会授予投票
• 状态一致性：授予投票后必须更新voted_for，避免同一任期内投给多个节点

内容的提问来源于stack exchange，提问作者Ryan Glenn