Spring Cloud Eureka原理--续期/自我保护

落日映苍穹つ 2023-10-02 15:48 1阅读 0赞

原文网址：[Spring Cloud Eureka原理--续期/自我保护\_IT利刃出鞘的博客-CSDN博客][Spring Cloud Eureka_--_IT_-CSDN]

## 简介 ##

本文介绍SpringCloud的Eureka是如何进行续期和自我保护的。

本内容也是Java后端面试常见的问题。

## 续期 ##

服务续期和服务注册非常相似，服务注册在Eureka Client程序启动之后开启，并**同时开启服务续期的定时任务**。

在eureka-client-1.6.2.jar的DiscoveryClient类下有renew()方法，其代码如下：

/**
    * Renew with the eureka service by making the appropriate REST call
    */
    boolean renew() {
    	EurekaHttpResponse<InstanceInfo> httpResponse;
    	try {
    		httpResponse = eurekaTransport.registrationClient.sendHeartBeat(instanceInfo.getAppName(), 
    			instanceInfo.getId(), instanceInfo, null);
                
    		logger.debug("{} - Heartbeat status: {}", 
                PREFIX + appPathIdentifier,
                httpResponse.getStatusCode());
                
    		if (httpResponse.getStatusCode() == 404) {
    			REREGISTER_COUNTER.increment();
    			logger.info("{} - Re-registering apps/{}", 
                    PREFIX + appPathIdentifier,
    				instanceInfo.getAppName());
    			return register();
    		}
            
    		return httpResponse.getStatusCode() == 200;
    	} catch (Throwable e) {
    		logger.error("{} - was unable to send heartbeat!", PREFIX + appPathIdentifier, e);
    		return false;
    	}
    }

另外，EurekaServer的续约接口在eureka-core:1.6.2.jar的com.netflix.eureka包下的InstanceResource类下，接口方法为renewLease()，它是一个RESTfulAPI接口。为了减少本章的篇幅，省略了大部分代码的展示。其中有一个registry.renew()方法，即服务续约，代码如下：

@PUT
    public Response renewLease(...参数省略）{
    	// 代码省略
    	boolean isSuccess=registry.renew(app.getName(),id, isFromReplicaNode);
    	// 代码省略
    }

可以跟踪 registry.renew 的代码继续深入研究，和追踪服务注册的源码类似，在此不再赘述。服务续约有两个参数是可以配置的（官方建议不要修改）：

1.  Eureka Client 发送续约心跳的间隔。（默认为30秒）
2.  Eureka Server 在多长时间内没有收到心跳将实例剔除的时间参数。（默认为90秒）

上边只是部分内容，为便于维护，本文已迁移到此地址：[Spring Cloud Eureka原理-续期/自我保护 - 自学精灵][Spring Cloud Eureka_-_ -]

[Spring Cloud Eureka_--_IT_-CSDN]: https://knife.blog.csdn.net/article/details/121390558
[Spring Cloud Eureka_-_ -]: https://learn.skyofit.com/archives/1146