nacos 笔记

发布时间:2022-07-05 发布网站:脚本宝典
脚本宝典收集整理的这篇文章主要介绍了nacos 笔记脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。

Nacos AP 实现

Distro协议。Distro是阿里巴巴的私有协议,目前流行的 Nacos服务管理框架就采用了 Distro协议。Distro 协议被定位为 临时数据的一致性协议 :该类型协议, 不需要把数据存储到磁盘或者数据库 ,因为临时数据通常和服务器保持一个session会话, 该会话只要存在,数据就不会丢失 。

Distro 协议是一个比较简单的最终一致性协议。整体由节点寻址、数据全量同步、异步增量同步、定时上报client所有信息、心跳探活其他节点等组成。

Distro 协议保证写必须永远是成功的,即使可能会发生网络分区。当网络恢复时,把各数据分片的数据进行合并。

Distro 协议具有以下特点:

专门为了注册中心而创造出的协议;客户端与服务端有两个重要的交互,服务注册与心跳发送;客户端以服务为维度向服务端注册,注册后每隔一段时间向服务端发送一次心跳,心跳包需要带上注册服务的全部信息,在客户端看来,服务端节点对等,所以请求的节点是随机的;客户端请求失败则换一个节点重新发送请求;服务端节点都存储所有数据,但每个节点只负责其中一部分服务,在接收到客户端的“写”(注册、心跳、下线等)请求后,服务端节点判断请求的服务是否为自己负责,如果是,则处理,否则交由负责的节点处理;每个服务端节点主动发送健康检查到其他节点,响应的节点被该节点视为健康节点;服务端在接收到客户端的服务心跳后,如果该服务不存在,则将该心跳请求当做注册请求来处理;服务端如果长时间未收到客户端心跳,则下线该服务;负责的节点在接收到服务注册、服务心跳等写请求后将数据写入后即返回,后台异步地将数据同步给其他节点;节点在收到读请求后直接从本机获取后返回,无论数据是否为最新。

 

Distro协议服务端节点发现使用寻址机制来实现服务端节点的管理。在 Nacos中,寻址模式有三种:

  1. AddressServerMemberLookup, //使用地址服务器存储节点信息,服务端节点定时拉取信息进行管理
  2. FileconfigMemberLookup //使用Cluster.conf 配置集群
  3. StandaloneMemberLookup //单机模式
    public static MemberLookup createLookUp(ServerMemberManager memberManager) throws NacosException {
        if (!envUtil.getStandaloneMode()) {
            String lookupTyPE = EnvUtil.getPRoperty(LOOKUP_MODE_TYPE);
            LookupType type = chooseLookup(lookupType);
            LOOK_UP = find(type);
            currentLookupType = type;
        } else {
            LOOK_UP = new StandaloneMemberLookup();
        }
        LOOK_UP.injectMemberManager(memberManager);
        LOGgers.CLUSTER.info("Current addressing mode selection : {}", LOOK_UP.getClass().getSimpleName());
        return LOOK_UP;
    }

nacos 笔记

 

同步数据分两种:

全量同步数据

Distro协议节点启动时会从其他节点全量同步数据。在 Nacos中,整体流程如下:

nacos 笔记

 

 

异步增量同步

      新增数据使用异步广播同步:

  • DistroProtocol 使用 sync() 方法接收增量数据

  • 向其他节点发布广播任务

    • 调用 distroTaskEngineHolder 发布延迟任务

  • 调用 DistroDelayTaskProcessor.process() 方法进行任务投递:将延迟任务转换为异步变更任务

  • 执行变更任务 DistroSyncChangeTask.run() 方法:向指定节点发送消息

    • 调用 DistroHttpAgent.syncData() 方法发送数据

    • 调用 NamingProxy.syncData() 方法发送数据

  • 异常任务调用 handleFailedTask() 方法进行处理

    • 调用 DistroFailedTaskHandler 处理失败任务

    • 调用 DistroHttpCombinedKeyTaskFailedHandler 将失败任务重新投递成延迟任务。

 

 

Nacos RAFT 实现

Raft 适用于一个管理日志一致性的协议,相比于 Paxos 协议 Raft 更易于理解和去实现它。为了提高理解性,Raft 将一致性算法分为了几个部分,包括领导选取(leader selection)、日志复制(log replication)、安全(safety),并且使用了更强的一致性来减少了必须需要考虑的状态。

Raft算法将 Server划分为3种状态,或者也可以称作角色:【1】Leader:负责 Client交互和 log复制,同一时刻系统中最多存在1个。【2】Follower:被动响应请求RPC,从不主动发起请求RPC。【3】Candidate:一种临时的角色,只存在于 Leader的选举阶段,某个节点想要变成 Leader,那么就发起投票请求,同时自己变成 Candidate。如果选举成功,则变为 Candidate,否则退回为 Follower

在 Raft中,问题分解为:领导选取、日志复制、安全和成员变化。日志:每台机器保存一份日志,日志来自于客户端的请求,包含一系列的命令状态机:状态机会按顺序执行这些命令一致性模型:分布式环境下,保证多机的日志是一致的,这样回放到状态机中的状态是一致的Nacos server在启动时,会通过 RunningConfig.onApplicationEvent()方法调用 RaftCore.inIT()方法。

在 init方法主要做了如下几件事:

  1. 获取 Raft集群节点 peers.add(NamingProxy.getServers());
  2. Raft集群数据恢复 RaftStore.load();
  3. Raft选举 GlobalExecutor.register(new MasterElection());
  4. Raft心跳 GlobalExecutor.register(new HeartBeat());
  5. Raft发布内容
  6. Raft保证内容一致性

 

 

参照: https://www.cnblogs.COM/zhengzhaoxiang/p/14009118.htML

 

  

脚本宝典总结

以上是脚本宝典为你收集整理的nacos 笔记全部内容,希望文章能够帮你解决nacos 笔记所遇到的问题。

如果觉得脚本宝典网站内容还不错,欢迎将脚本宝典推荐好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。