public void evict(long additionalLeaseMs) {
        logger.debug("Running the evict task");
 
        //是否允許主動(dòng)摘除故障的服務(wù)實(shí)例
        if (!isLeaseExpirationEnabled()) {
            logger.debug("DS: lease expiration is currently disabled.");
            return;
        }
 
       ....
 }

@Override
    public boolean isLeaseExpirationEnabled() {
        //默認(rèn)是true，關(guān)閉自我保護(hù)機(jī)制的話，這個(gè)方法永遠(yuǎn)返回true，隨時(shí)都可以清除故障的服務(wù)實(shí)例。
        if (!isSelfPreservationModeEnabled()) {
            // The self preservation mode is disabled, hence allowing the instances to expire.
            return true;
        }
        //numberOfRenewsPerMinThreshold  這個(gè)是我期望的一分鐘發(fā)送多少心跳。
        //getNumOfRenewsInLastMin 這個(gè)是上一分鐘一共發(fā)來(lái)多少心跳
        return numberOfRenewsPerMinThreshold > 0 && getNumOfRenewsInLastMin() > numberOfRenewsPerMinThreshold;
    }

// EurekaBootStrap.java
protected void initEurekaServerContext() throws Exception {
 
    // ... 省略其它代碼
 
    // 【2.2.10】從其他 Eureka-Server 拉取注冊(cè)信息
    // Copy registry from neighboring eureka node
    int registryCount = registry.syncUp();
    registry.openForTraffic(applicationInfoManager, registryCount);
    
    // ... 省略其它代碼
}
 
// PeerAwareInstanceRegistryImpl.java
@Override
public void openForTraffic(ApplicationInfoManager applicationInfoManager, int count) {
   // Renewals happen every 30 seconds and for a minute it should be a factor of 2.
   this.expectedNumberOfRenewsPerMin = count * 2;
   this.numberOfRenewsPerMinThreshold =
           (int) (this.expectedNumberOfRenewsPerMin * serverConfig.getRenewalPercentThreshold());

protected void updateRenewsPerMinThreshold() {
        this.numberOfRenewsPerMinThreshold = (int) (this.expectedNumberOfClientsSendingRenews
                * (60.0 / serverConfig.getExpectedClientRenewalIntervalSeconds())
                * serverConfig.getRenewalPercentThreshold());
    }

// PeerAwareInstanceRegistryImpl.java
private void scheduleRenewalThresholdUpdateTask() {
   timer.schedule(new TimerTask() {
                      @Override
                      public void run() {
                          updateRenewalThreshold();
                      }
                  }, serverConfig.getRenewalThresholdUpdateIntervalMs(),
           serverConfig.getRenewalThresholdUpdateIntervalMs());
}
 
// AbstractInstanceRegistry.java
/**
* 自我保護(hù)機(jī)鎖
*
* 當(dāng)計(jì)算如下參數(shù)時(shí)使用：
*  1. {@link #numberOfRenewsPerMinThreshold}
*  2. {@link #expectedNumberOfRenewsPerMin}
*/
protected final Object lock = new Object();
 
private void updateRenewalThreshold() {
   try {
       // 計(jì)算 應(yīng)用實(shí)例數(shù)
       Applications apps = eurekaClient.getApplications();
       int count = 0;
       for (Application app : apps.getRegisteredApplications()) {
           for (InstanceInfo instance : app.getInstances()) {
               if (this.isRegisterable(instance)) {
                   ++count;
               }
           }
       }
       // 計(jì)算 expectedNumberOfRenewsPerMin 、 numberOfRenewsPerMinThreshold 參數(shù)
       synchronized (lock) {
           // Update threshold only if the threshold is greater than the
           // current expected threshold of if the self preservation is disabled.
           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);
   }
}