EurekaInstanceConfig & EurekaClientConfig

Instance 是實例的意思， EurekaInstanceConfig 就是 eureka client 的配置文件中的服務實例信息。

EurekaInstanceConfig instanceConfig = isCloud(ConfigurationManager.getDeploymentContext())? new CloudInstanceConfig(): new MyDataCenterInstanceConfig();applicationInfoManager = new ApplicationInfoManager(instanceConfig, new EurekaConfigBasedInstanceInfoProvider(instanceConfig).get());EurekaClientConfig eurekaClientConfig = new DefaultEurekaClientConfig();

EurekaInstanceConfig 就是將 eureka-client.properties 文件中的服務實例信息加載到 ConfigManager 中，然后基于 EurekaInstanceConfig 對外暴露接口，并且提供配置項的默認值。

ApplicationInfoManager，包含了服務實例的信息、配置，作為服務實例管理的一個組件，由 EurekaInstanceConfig 和 InstanceInfo 構建完成，InstanceInfo 的創建是在?new EurekaConfigBasedInstanceInfoProvider(instanceConfig).get()?中，用了構造器模式 LeaseInfo.Builder.newBuilder() 構造了一個復雜的代表一個服務實例的 InstanceInfo 對象。核心思想就是在 EurekaInstanceConfig 中讀取各種實例相關的配置信息，再構造了一些其他的對象，最終完成 InstanceInfo 對象的構建。

public synchronized InstanceInfo get() {if (instanceInfo == null) {// Build the lease information to be passed to the server based on configLeaseInfo.Builder leaseInfoBuilder = LeaseInfo.Builder.newBuilder().setRenewalIntervalInSecs(config.getLeaseRenewalIntervalInSeconds()).setDurationInSecs(config.getLeaseExpirationDurationInSeconds());if (vipAddressResolver == null) {vipAddressResolver = new Archaius1VipAddressResolver();}//代碼太長，省略其他代碼} }

DefaultEurekaClientConfig 就是和 DefaultEurekaServerConfig 一樣，讀取 erueka-client.properties 配置文件的內容。具體方法在 com.netflix.discovery.internal.util.initConfig() 中。最后都是交給 ConfigurationManager 管理。

EurekaInstanceConfig 和 EurekaClientConfig 雖然都是讀取的 erueka-client.propeties ，但是讀取的內容是不一樣的。

EurekaInstanceConfig 接口

EurekaClientConfig 接口

DiscoveryClient

DiscoveryClient 是創建 Erueka Client 的類，由 ApplicationInfoManager 和 EurekaClientConfig 組成。

eurekaClient = new DiscoveryClient(applicationInfoManager, eurekaClientConfig);

DiscoveryClient 代碼很長。

appPathIdentifier，服務實例的標識符， appName，代表了一個服務名稱，但是一個服務可能部署多臺機器，每臺機器上部署的就是一個服務實例，如：serviceABC/001

appPathIdentifier = instanceInfo.getAppName() + "/" + instanceInfo.getId();

是否需要注冊到別的注冊中心。eurekaServer 有個配置：eureka.client.fetchRegistry，單機情況下為 false。false 表示自己就是注冊中心。職責就是維護服務實例，并不需要去檢索服務。

if (!config.shouldRegisterWithEureka() && !config.shouldFetchRegistry()) {}

支持調度的線程池。

scheduler = Executors.newScheduledThreadPool(2,new ThreadFactoryBuilder().setNameFormat("DiscoveryClient-%d").setDaemon(true).build());

支持心跳的線程池。

heartbeatExecutor = new ThreadPoolExecutor(1, clientConfig.getHeartbeatExecutorThreadPoolSize(), 0, TimeUnit.SECONDS,new SynchronousQueue<Runnable>(),new ThreadFactoryBuilder().setNameFormat("DiscoveryClient-HeartbeatExecutor-%d").setDaemon(true).build());

支持緩存刷新的線程池。

cacheRefreshExecutor = new ThreadPoolExecutor(1, clientConfig.getCacheRefreshExecutorThreadPoolSize(), 0, TimeUnit.SECONDS,new SynchronousQueue<Runnable>(),new ThreadFactoryBuilder().setNameFormat("DiscoveryClient-CacheRefreshExecutor-%d").setDaemon(true).build());

支持底層的 eureka client 和 eureka server 進行通信的組件。

eurekaTransport = new EurekaTransport();

初始化調度任務。

initScheduledTasks();

總結

先創建了 EurekaInstanceConfig，基于 EurekaInstanceConfig 和 InstanceInfo 創建 ApplicationInfoManager，之后才創建 DiscoveryClient。

總結

以上是生活随笔為你收集整理的如何创建一个Eureka Client？的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。