本篇文章給大家分享的是有關(guān)怎么在SpringCloud中將Eureka注冊為服務，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

成都創(chuàng)新互聯(lián)2013年至今，先為門頭溝等服務建站，門頭溝等地企業(yè)，進行企業(yè)商務咨詢服務。為門頭溝企業(yè)網(wǎng)站制作PC+手機+微官網(wǎng)三網(wǎng)同步一站式服務解決您的所有建站問題。

一、將服務注冊到Eureka

一個SpringBoot應用如果要注冊到Spring Cloud環(huán)境(Greenwich.SR3版本)，步驟很簡單：

pom.xml中添加啟動器：spring-cloud-starter-netflix-eureka-client；

增加配置：eureka.client.serviceUrl.defaultZone: http://localhost:8100/eureka/；

啟動應用；

如果注冊中心正常，此時就能在注冊中心發(fā)現(xiàn)這個應用了，如下圖紅框所示：

按照spring.factories中的配置，EurekaClientAutoConfiguration中的配置都會生效，包括下面這段代碼返回的bean：

@Bean
public DiscoveryClient discoveryClient(EurekaInstanceConfig config, EurekaClient client) {
  return new EurekaDiscoveryClient(config, client);
}

spring容器初始化時會實例化所有單例bean，就會執(zhí)行EurekaClientAutoConfiguration的discoveryClient方法獲取這個bean實例，于是就構(gòu)造了一個EurekaDiscoveryClient對象；

注意EurekaDiscoveryClient的構(gòu)造方法，第二個入?yún)⑹莄om.netflix.discovery.EurekaClient類型，此對象同樣來自EurekaClientAutoConfiguration類，如下方法：

@Bean(destroyMethod = "shutdown")
@ConditionalOnMissingBean(value = EurekaClient.class, search = SearchStrategy.CURRENT)
@org.springframework.cloud.context.config.annotation.RefreshScope
@Lazy
public EurekaClient eurekaClient(ApplicationInfoManager manager, EurekaClientConfig config, EurekaInstanceConfig instance) {
  manager.getInfo(); // force initialization
  return new CloudEurekaClient(manager, config, this.optionalArgs,this.context);
}

CloudEurekaClient的父類com.netflix.discovery.DiscoveryClient來自netflix發(fā)布的eureka-client包中，所以可以這么理解：EurekaDiscoveryClient類是個代理身份，真正的服務注冊發(fā)現(xiàn)是委托給netflix的開源包來完成的，我們可以專心的使用SpringCloud提供的服務注冊發(fā)現(xiàn)功能，只需要知道EurekaDiscoveryClient即可，真正的服務是eureka-client來完成的；

接下來需要關(guān)注com.netflix.discovery.DiscoveryClient的構(gòu)造方法，因為這里面有服務注冊的邏輯，整個構(gòu)造方法內(nèi)容太多，無需都細看，只看關(guān)鍵代碼即可；

DiscoveryClient的構(gòu)造方法中，最熟悉的應該是下圖紅框中這段日志輸出的了：

對應的應用啟動日志中就有這段日志輸出，如下圖紅框：

紅框中的”us-east-1”，是默認的region，來自配置類EurekaClientConfigBean，這里面有各種eureka相關(guān)的配置信息，以及默認配置，如下圖：

繼續(xù)看DiscoveryClient的構(gòu)造方法，服務注冊相關(guān)的initScheduledTasks方法在此被調(diào)用，如下圖：

initScheduledTasks方法的內(nèi)容如下，請注意中文注釋：

  private void initScheduledTasks() {
    //獲取服務注冊列表信息
    if (clientConfig.shouldFetchRegistry()) {
      //服務注冊列表更新的周期時間
      int registryFetchIntervalSeconds = clientConfig.getRegistryFetchIntervalSeconds();
      int expBackOffBound = clientConfig.getCacheRefreshExecutorExponentialBackOffBound();
      //定時更新服務注冊列表
      scheduler.schedule(
          new TimedSupervisorTask(
              "cacheRefresh",
              scheduler,
              cacheRefreshExecutor,
              registryFetchIntervalSeconds,
              TimeUnit.SECONDS,
              expBackOffBound,
              new CacheRefreshThread() //該線程執(zhí)行更新的具體邏輯
          ),
          registryFetchIntervalSeconds, TimeUnit.SECONDS);
    }
    if (clientConfig.shouldRegisterWithEureka()) {
      //服務續(xù)約的周期時間
      int renewalIntervalInSecs = instanceInfo.getLeaseInfo().getRenewalIntervalInSecs();
      int expBackOffBound = clientConfig.getHeartbeatExecutorExponentialBackOffBound();
      //應用啟動可見此日志，內(nèi)容是：Starting heartbeat executor: renew interval is: 30
      logger.info("Starting heartbeat executor: " + "renew interval is: " + renewalIntervalInSecs);
      // 定時續(xù)約
      scheduler.schedule(
          new TimedSupervisorTask(
              "heartbeat",
              scheduler,
              heartbeatExecutor,
              renewalIntervalInSecs,
              TimeUnit.SECONDS,
              expBackOffBound,
              new HeartbeatThread() //該線程執(zhí)行續(xù)約的具體邏輯
          ),
          renewalIntervalInSecs, TimeUnit.SECONDS);

      //這個Runable中含有服務注冊的邏輯
      instanceInfoReplicator = new InstanceInfoReplicator(
          this,
          instanceInfo,
          clientConfig.getInstanceInfoReplicationIntervalSeconds(),
          2); // burstSize

      statusChangeListener = new ApplicationInfoManager.StatusChangeListener() {
        @Override
        public String getId() {
          return "statusChangeListener";
        }

        @Override
        public void notify(StatusChangeEvent statusChangeEvent) {
          if (InstanceStatus.DOWN == statusChangeEvent.getStatus() ||
              InstanceStatus.DOWN == statusChangeEvent.getPreviousStatus()) {
            // log at warn level if DOWN was involved
            logger.warn("Saw local status change event {}", statusChangeEvent);
          } else {
            logger.info("Saw local status change event {}", statusChangeEvent);
          }
          instanceInfoReplicator.onDemandUpdate();
        }
      };

      if (clientConfig.shouldOnDemandUpdateStatusChange()) {
        applicationInfoManager.registerStatusChangeListener(statusChangeListener);
      }
      //服務注冊
      instanceInfoReplicator.start(clientConfig.getInitialInstanceInfoReplicationIntervalSeconds());
    } else {
      logger.info("Not registering with Eureka server per configuration");
    }
  }

以上就是怎么在SpringCloud中將Eureka注冊為服務，小編相信有部分知識點可能是我們?nèi)粘９ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學到更多知識。更多詳情敬請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。