Eureka自我保护机制源码解析
默认情况下,当eurekaserver在一定时间内(默认90秒)没有接收到某个客户端实例的心跳,eurekaserver将会注销该实例。但是当网络分区故障发生时,客户端与eurekaserver之间无法正常通信,此时不应该注销客户端。eureka通过“自我保护机制”来解决这个问题:当eurekaserver短时间内丢失过多客户端时,这个节点就会进入自我保护模式。在自我保护模式下,eurekaserver不会剔除任何客户端。当网络故障恢复后,该节点会自动退出自我保护模式
自我保护机制的实现是基于维护服务注册表的类abstractinstanceregistry
中的2个变量来维护的
/** * 期望最小每分钟续租次数 */ protected volatile int numberofrenewsperminthreshold; /** * 期望最大每分钟续租次数 */ protected volatile int expectednumberofrenewspermin;
服务端初始化
服务端的启动文章可以看这篇文章:eurekaserver自动装配及启动流程解析
在服务端启动、从其他集群同步完信息后执行了一个方法:openfortraffic
public void openfortraffic(applicationinfomanager applicationinfomanager, int count) { this.expectednumberofrenewspermin = count * 2; this.numberofrenewsperminthreshold = (int) (this.expectednumberofrenewspermin * serverconfig.getrenewalpercentthreshold()); }
期望每分钟最大续租次数为:当前服务端已经注册的客户端的数量乘2,为啥呢,因为默认eureka的续约是30秒
期望每分钟最小续租次数为:最大续租次数乘续租百分比,默认续租百分比是0.85,也就是说当某个时间窗内如果存在超过百分之十五的客户端没有再续租的话则开启自我保护模式
自我保护模式的定时任务
defaulteurekaservercontext
类中有一个initialize
方法,这个方法在执行过程中会启动一个定时任务
@postconstruct @override public void initialize() { logger.info("initializing ..."); peereurekanodes.start(); try { registry.init(peereurekanodes); } catch (exception e) { throw new runtimeexception(e); } logger.info("initialized"); } public void init(peereurekanodes peereurekanodes) throws exception { this.numberofreplicationslastmin.start(); this.peereurekanodes = peereurekanodes; initializedresponsecache(); schedulerenewalthresholdupdatetask(); initremoteregionregistry(); try { monitors.registerobject(this); } catch (throwable e) { logger.warn("cannot register the jmx monitor for the instanceregistry :", e); } }
schedulerenewalthresholdupdatetask
这个定时任务就是跟自我保护模式相关的了
private void schedulerenewalthresholdupdatetask() { timer.schedule(new timertask() { @override public void run() { updaterenewalthreshold(); } }, serverconfig.getrenewalthresholdupdateintervalms(), serverconfig.getrenewalthresholdupdateintervalms()); }
其中getrenewalthresholdupdateintervalms
默认值是15分钟
private void updaterenewalthreshold() { try { // 1. 计算应用实例数 applications apps = eurekaclient.getapplications(); int count = 0; for (application app : apps.getregisteredapplications()) { for (instanceinfo instance : app.getinstances()) { if (this.isregisterable(instance)) { ++count; } } } // 2. 计算expectednumberofrenewspermin 、 numberofrenewsperminthreshold 参数 synchronized (lock) { if ((count * 2) > (serverconfig.getrenewalpercentthreshold() * numberofrenewsperminthreshold) || (!this.isselfpreservationmodeenabled())) { this.expectednumberofrenewspermin = count * 2; this.numberofrenewsperminthreshold = (int) ((count * 2) * serverconfig.getrenewalpercentthreshold()); } } logger.info("current renewal threshold is : {}", numberofrenewsperminthreshold); } catch (throwable e) { logger.error("cannot update renewal threshold", e); } }
分为2步,第一步就不说了,看第二步
当最大续租数量大于最小续租数量时或者没有开启自我保护模式时可以重新计算两个值,否则不能重新计算
客户端注册
public void register(instanceinfo registrant, int leaseduration, boolean isreplication) { synchronized (lock) { if (this.expectednumberofrenewspermin > 0) { this.expectednumberofrenewspermin = this.expectednumberofrenewspermin + 2; this.numberofrenewsperminthreshold = (int) (this.expectednumberofrenewspermin * serverconfig.getrenewalpercentthreshold()); } } }
每当有一个实例注册上来时,两个参数都要重新计算,最大期望续租数量+2同样是因为默认1分钟续租2次
客户端下线
public boolean cancel(final string appname, final string id, final boolean isreplication) { synchronized (lock) { if (this.expectednumberofrenewspermin > 0) { this.expectednumberofrenewspermin = this.expectednumberofrenewspermin - 2; this.numberofrenewsperminthreshold = (int) (this.expectednumberofrenewspermin * serverconfig.getrenewalpercentthreshold()); } } }
于注册的处理逻辑恰好相反
开启自我保护模式
之前在eureka客户端续约及服务端过期租约清理源码解析一文的租约过期清理解析过程中省略了关于自我保护模式的判断,现在再看一下。这个判断在租约过期处理方法的开头:
public void evict(long additionalleasems) { logger.debug("running the evict task"); if (!isleaseexpirationenabled()) { logger.debug("ds: lease expiration is currently disabled."); return; } //.... }
详细内容在isleaseexpirationenabled
中
public boolean isleaseexpirationenabled() { if (!isselfpreservationmodeenabled()) { return true; } return numberofrenewsperminthreshold > 0 && getnumofrenewsinlastmin() > numberofrenewsperminthreshold; } public boolean isselfpreservationmodeenabled() { return serverconfig.shouldenableselfpreservation(); } public long getnumofrenewsinlastmin() { return renewslastmin.getcount(); }
第一个if是判断是否开启自我保护模式
最后的return则是如果当前最小续租次数大于0,并且最近续约实例数量大于最小期待续租数量
推荐阅读
-
Eureka获取服务列表源码解析
-
Eureka自我保护机制源码解析
-
Android事件分发机制源码解析
-
vue源码解析之事件机制原理
-
Eureka的初理解【服务注册与发现、高可用集群、自我保护机制、与Zookeeper的比较】
-
Handler异步消息传递机制(四)Handler发送消息流程,源码(Android 9.0)彻底解析
-
Android消息通信机制Handler详解,Handler,Looper,MessageQueue,源码解析,讲解这几个类怎么配合工作的
-
Android消息机制原理,仿写Handler Looper源码解析跨线程通信原理--之仿写模拟Handler(四)
-
Android Handler机制(三)----Looper源码解析
-
Android多线程(二)消息处理机制---Handler、Message、Looper源码原理解析