Nacos服务端心跳续约

先看下服务端处理的InstanceController概览图:

InstanceController概览图

当客户端调用reqApi向服务器发送Http PUT心跳请求,URI是/nacos/v1/ns/instance/beat,对应的controller就是InstanceController的beat方法。beat方法首先检查Instance是否存在,Instance不存在的情况:比如客户端超过30秒没有向服务器发送心跳,这时服务端会删除这个实例,30秒后再发送心跳时就会出现Instance不存在的情况。

说回来,如果实例不存在,并且客户端也没有发送BeatInfo包,这时会返回给客户端一个实例不存在的错误;如果Instance实例不存在,但客户端发送了BeatInfo包,这时能拿到BeatInfo里的信息,beat方法就会创建Instance对象,并调用ServiceManager类的registerInstance方法注册服务实例。

这个BeatInfo包就是客户端发送心跳时判断的参数:Light_Beat_Enabled,如果这个参数是false就发送,默认值就是false,这个逻辑在讲客户端时讲过一遍了。

我们具体看下InstanceController类beat方法代码:

InstanceController类beat方法-1


InstanceController类beat方法-2


InstanceController类beat方法-3

ServiceManager类getInstance方法涉及到Service、Cluster、Instance的内存数据结构,服务注册就是把数据写到这几个类的关键变量中,服务发现也是从这几个类的变量中查找,所以这几个类的数据结构非常重要。

首先,Service服务是存储在ServiceManager类的serviceMap变量里,类型是:

Map<String, Map<String, Service>> serviceMap = new ConcurrentHashMap<>();

Map里key含义如下:Map(namespace, Map(group::serviceName, Service))

serviceMap是个双层Map结构,先用namespace拿到该名字空间的所有Service,再用serviceName拿到Service对象。

Cluster集群存在Service类的clusterMap变量里,类型是:Map<String, Cluster> clusterMap = new HashMap<>();Map里key含义:Map<clusterName, Cluster>;clusterMap中存储该service所有的集群,使用clustername可以直接拿到Cluster对象实例。

Instance分为临时服务和永久服务,是分开存的,在Cluster类中的2个变量里:

Set<Instance> persistentInstances = new HashSet<>()   //永久服务实例

Set<Instance> ephemeralInstances = new HashSet<>()  //临时服务实例

persistentInstances中是该集群中所有永久服务的Instance的集合;ephemeralInstances 是该集合中所有临时服务的Instance的集合,Instance对象是对应Ip、port、healthy等属性。

ServiceManager类getInstance就是从上面几个变量结构中查找到具体的Instance实例,如果数据结构中没有就创建一个Instance对象,然后调用ServiceManager类的registerInstance方法注册实例,registerInstance注册实例就是向那几个数据结构Map中塞数据,然后把注册数据再同步到nacos服务器集群其他节点。这个registerInstance注册服务逻辑后面会介绍。

接着看InstanceController类beat方法最后一段代码:

InstanceController类beat方法-4

首先组装心跳基本属性到clientBeat对象,传给Service的processClientBeat方法,processClientBeat拿到ip和port就可以找到Instance,然后做该Instance的心跳续期。下面是给客户端设置心跳间隔时间和是否发送心跳BeatInfo对象,这2个属性设置后会覆盖默认属性(心跳间隔默认是5秒,默认发送BeatInfo),设置后返回给客户端后,客户端就按这个最新的属性设置发送心跳。之前在客户端上报心跳逻辑时,也详细讲过这2个属性。上面代码可以看出设置这2个属性的值是从nacos控制台拿到的,用户在控制台上可以设置这2个属性的metadata元数据,这个之后可以看下怎么在控制台设置这些元数据。

好了,InstanceController类beat方法我们说完了。

我们接着看下Service类的处理心跳方法processClientBeat,这个是服务端心跳的核心逻辑,见下图,只剩下最后这一个了:

InstanceController类beat流程

看下processClientBeat代码:

processClientBeat方法

这段代码很简单,创建一个处理心跳的处理器任务ClientBeatProcessor,然后扔到线程池中立即执行,见scheduleNow方法。我们看下ClientBeatProcessor这个线程怎么处理心跳的?

先看第一段,取出该服务的必要属性,主要是取出该服务的所有Instance,后面做遍历找要上报心跳的Instance。

ClientBeatProcessor线程-1

再看最后一段:

ClientBeatProcessor线程-2

这段是心跳服务续约的核心逻辑,先在所有Instance里找到匹配上报心跳的Instance,然后设置该实例的最后上报时间,nacos就是根据这个属性判断15秒心跳超时、30秒删除实例。然后刷新下实例的健康属性,比如上次心跳15超时,这个health属性会被设置成false,这次上报后会重置成健康true。最后调用PushService组件,该组件是通过udp协议向客户端推送服务变更信息,这个后面有详细说明。

©著作权归作者所有,转载或内容合作请联系作者
禁止转载,如需转载请通过简信或评论联系作者。
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 199,902评论 5 468
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 84,037评论 2 377
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 146,978评论 0 332
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 53,867评论 1 272
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 62,763评论 5 360
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,104评论 1 277
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,565评论 3 390
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,236评论 0 254
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,379评论 1 294
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,313评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,363评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,034评论 3 315
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,637评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,719评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,952评论 1 255
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,371评论 2 346
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 41,948评论 2 341

推荐阅读更多精彩内容