LeaderRaftNode类中clientRequestHandler方法这个第二阶段的提交为什么是单向的，万一followe节点文件写入异常的话，不做回滚操作吗

if (StateMachines.logPreCommitHandler(taskList, serverConfigs.size()) && (commitLogIndex = logManage.commitLog(cacheLogId)) != 0L) {
            long finalCommitLogIndex = commitLogIndex;
            // 5.给其他节点发送提交请求(单向不需要返回了)
            for (ServerConfig serverConfig : serverConfigs) {
                ThreadPoolUtils.sendAsyncMsgPool.execute(() -> {
                    AppendEntriesCommit commit = AppendEntriesCommit.builder().commitLogId(cacheLogId).commitLogIndex(finalCommitLogIndex).build();
                    RpcSession<Void, AppendEntriesCommit> commitSession = RpcSessionFactory.<Void, AppendEntriesCommit>openSession(serverConfig, commit);
                    if (commitSession != null) {
                        commitSession.asyncSend();
                    }
                });
            }
            // 6.给客户的返回结果
            clientResponse.setCode(200);
            clientResponse.setMsg("SUCCESS");
            return clientResponse;
        }

PS:是因为  在FOLLOW节点会不定期的检查自己的日志信息是否跟LEADER同步，会把缺失的日志从LEADER处同步回来？

colins/raft-java-demo

内容风险标识

评论 (1)

colins/raft-java-demo .gitee-modal { width: 500px !important; }

内容风险标识