{"id":881,"date":"2020-09-22T17:07:34","date_gmt":"2020-09-22T09:07:34","guid":{"rendered":"http:\/\/prayerlaputa.com\/?p=881"},"modified":"2020-09-22T17:07:34","modified_gmt":"2020-09-22T09:07:34","slug":"%e6%ba%90%e7%a0%81%e5%88%86%e6%9e%90%e4%b9%8beureka%e5%ae%a2%e6%88%b7%e7%ab%af%e6%ba%90%e7%a0%81%e8%a7%a3%e6%9e%90","status":"publish","type":"post","link":"http:\/\/prayerlaputa.com\/?p=881","title":{"rendered":"\u6e90\u7801\u5206\u6790\u4e4bEureka\u5ba2\u6237\u7aef\u6e90\u7801\u89e3\u6790"},"content":{"rendered":"

\u8bf4\u660e<\/span><\/h2>\n

\u672c\u6587\u6240\u5206\u6790\u4ee3\u7801\u7248\u672c\u4e3aspring boot\/cloud 2.2.6\u3002<\/span><\/p>\n

\u9884\u5907\u77e5\u8bc6<\/span><\/h3>\n

\u4e00\u4e9b\u6ce8\u89e3\u7684\u8bf4\u660e<\/span><\/h4>\n

eureka\u4e2d\u7528\u5230\u51e0\u4e2a\u6bd4\u8f83\u6709\u610f\u601d\u7684\u6ce8\u89e3\uff0c\u7b80\u5316\u7a0b\u5e8f\u5b9e\u73b0\u3002<\/span><\/p>\n

@ConfigurationProperties(“eureka.instance”)<\/span><\/h5>\n

\u8868\u793a\u4ece\u5916\u90e8\u914d\u7f6e\u6587\u4ef6\u4e2d\uff08properties\u6216\u662fyml\u6587\u4ef6\uff09\u8bfb\u53d6”eureka.instance”\u5bf9\u5e94\u7684\u914d\u7f6e\u3002<\/span><\/p>\n

@ConditionalOnBean\/@ConditionalOnClass<\/span><\/h5>\n

<\/p>\n

@ConditionalOnBean \u00a0 \u00a0 \u00a0 \u00a0 \/\/   \u5f53\u7ed9\u5b9a\u7684\u5728bean\u5b58\u5728\u65f6,\u5219\u5b9e\u4f8b\u5316\u5f53\u524dBean<\/span>\r\n@ConditionalOnMissingBean  \/\/   \u5f53\u7ed9\u5b9a\u7684\u5728bean\u4e0d\u5b58\u5728\u65f6,\u5219\u5b9e\u4f8b\u5316\u5f53\u524dBean<\/span>\r\n@ConditionalOnClass \u00a0 \u00a0 \u00a0  \/\/   \u5f53\u7ed9\u5b9a\u7684\u7c7b\u540d\u5728\u7c7b\u8def\u5f84\u4e0a\u5b58\u5728\uff0c\u5219\u5b9e\u4f8b\u5316\u5f53\u524dBean<\/span>\r\n@ConditionalOnMissingClass \/\/   \u5f53\u7ed9\u5b9a\u7684\u7c7b\u540d\u5728\u7c7b\u8def\u5f84\u4e0a\u4e0d\u5b58\u5728\uff0c\u5219\u5b9e\u4f8b\u5316\u5f53\u524dBean<\/span><\/pre>\n
\u53ef\u4ee5\u53c2\u8003\u8fd9\u7bc7\u6587\u7ae0\uff1a<\/span>SpringBoot(16)\u2014@ConditionalOnBean\u4e0e@ConditionalOnClass<\/span><\/a><\/span><\/p>\n
\u6bd4\u5982<\/span>EurekaClientAutoConfiguration<\/code><\/span>\u7c7b\u5b9a\u4e49\u4e2d\uff0c\u7c7b\u4e0a\u9762\u6ce8\u89e3\u4e86<\/span>@ConditionalOnClass(EurekaClientConfig.class)<\/code><\/span>,\u8868\u793a\u5f53\u5728\u7c7b\u8def\u5f84\u4e2d\u5b58\u5728EurekaClientConfig.class\uff0c\u5219\u5b9e\u4f8b\u5316\u5f53\u524d<\/span>EurekaClientAutoConfiguration<\/code><\/span>\u3002<\/span><\/p>\n
@ImplementedBy<\/span><\/h5>\n
google guice\u6ce8\u89e3\uff0c\u6307\u5b9a\u63a5\u53e3\u9ed8\u8ba4\u7684\u5b9e\u73b0\u7c7b\u3002<\/span><\/p>\n
@Singleton<\/span><\/h5>\n
jdk \u63d0\u4f9b\u7684\u6ce8\u89e3\uff0c\u5c06\u5f53\u524d\u7c7b\u5b9e\u73b0\u4e3a\u5355\u4f8b\u6a21\u5f0f\u3002<\/span><\/p>\n
\n
eureka\u67b6\u6784<\/span><\/h4>\n
\"\"<\/p>\n
eureka\u5ba2\u6237\u7aef\u6e90\u7801<\/span><\/h2>\n
eureka\u5ba2\u6237\u7aef\u5de5\u4f5c\u6d41\u7a0b<\/span><\/h3>\n
\"\"
\n<\/span><\/p>\n
\u4e0b\u9762\u5c06\u7b80\u8981\u8bf4\u660e\u4e0a\u56fe\u7684\u8fc7\u7a0b\u3002<\/span><\/p>\n
eureka\u5ba2\u6237\u7aef\u6bd4\u8f83\u5173\u952e\u7684\u7c7b\u5982\u4e0b\uff1a<\/span><\/p>\n
\"\"<\/span><\/p>\n
\u5176\u4e2d\uff0cDiscoveryClient\u662f\u6838\u5fc3\uff0c\u5b83\u5b9e\u73b0\u4e86EurekaClient\u63a5\u53e3\uff0c\u662f\u8be5\u63a5\u53e3\u7684\u9ed8\u8ba4\u5b9e\u73b0\uff08@ImplementedBy\u4f20\u5165\u7684\u662fDiscoveryClient.class\uff09\u3002\u53e6\u5916\uff0c@Singleton\u6ce8\u89e3\u58f0\u660e\u4e86DiscoveryClient\u662f\u5355\u4f8b\u3002<\/span><\/p>\n
\n
DiscoverClient<\/span><\/h4>\n
\u8be5\u7c7b\u7684\u5173\u952e\u65b9\u6cd5\u5982\u4e0b\uff1a<\/span><\/p>\n
\/\/\u670d\u52a1\u6ce8\u518c\u76f8\u5173<\/span>\r\nboolean register()<\/span>\r\nvoid unregister()<\/span>\r\n\u200b<\/span>\r\n\/\/\u670d\u52a1\u7eed\u7ea6<\/span>\r\nboolean renew()<\/span>\r\n\u200b<\/span>\r\n\/\/\u5173\u95edeureka client<\/span>\r\npublic synchronized void shutdown()<\/span>\r\n\u200b<\/span>\r\n\/\/\u68c0\u67e5\u5f53\u524dclient\u72b6\u6001\uff0c\u5f53client\u72b6\u6001\u53d1\u751f\u53d8\u5316\u65f6\uff0c\u5c06\u4f1a\u89e6\u53d1\u65b0\u7684\u6ce8\u518c\u4e8b\u4ef6\uff0c\u53bb\u66f4\u65b0eureka server\u7684\u6ce8\u518c\u8868\u4e2d\u7684\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f\u3002<\/span>\r\npublic void registerHealthCheck(HealthCheckHandler healthCheckHandler)<\/span>\r\n\u200b<\/span>\r\n\/\/\u6ce8\u518c\u4e8b\u4ef6\u76d1\u542c\u5668\uff0c\u5f53\u5b9e\u4f8b\u4fe1\u606f\u6709\u53d8\u65f6\uff0c\u89e6\u53d1\u5bf9\u5e94\u7684\u5904\u7406\u4e8b\u4ef6\u3002<\/span>\r\npublic void registerEventListener(EurekaEventListener eventListener)<\/span><\/pre>\n
\n
\u5176\u6784\u9020\u65b9\u6cd5<\/span>DiscoveryClient(ApplicationInfoManager applicationInfoManager, EurekaClientConfig config, AbstractDiscoveryClientOptionalArgs args, Provider<BackupRegistry> backupRegistryProvider, EndpointRandomizer endpointRandomizer)<\/code><\/span>\u4e2d\uff0c\u6b64\u65b9\u6cd5\u4e2d\u4f9d\u6b21\u6267\u884c\u4e86 \u4eceeureka server\u4e2d\u62c9\u53d6\u6ce8\u518c\u8868\uff0c\u670d\u52a1\u6ce8\u518c\uff0c\u521d\u59cb\u5316\u53d1\u9001\u5fc3\u8df3\uff0c\u7f13\u5b58\u5237\u65b0\uff08\u5b9a\u65f6\u62c9\u53d6\u6ce8\u518c\u8868\u4fe1\u606f\uff09\uff0c\u6309\u9700\u6ce8\u518c\u5b9a\u65f6\u4efb\u52a1\u7b49\uff0c\u8d2f\u7a7f\u4e86Eureka Client\u542f\u52a8\u9636\u6bb5\u7684\u5404\u9879\u5de5\u4f5c\u3002<\/span><\/p>\n
\u6b64\u5904\u7ed9\u51fa\u4e00\u4e9b\u7b80\u5355\u7684\u5206\u6790\uff1a<\/span><\/p>\n
DiscoveryClient<\/span>(ApplicationInfoManager<\/span> applicationInfoManager<\/span>, EurekaClientConfig<\/span> config<\/span>, AbstractDiscoveryClientOptionalArgs<\/span> args<\/span>, Provider<\/span><<\/span>BackupRegistry<\/span>><\/span> backupRegistryProvider<\/span>, EndpointRandomizer<\/span> endpointRandomizer<\/span>) {<\/span>\r\n \u00a0 \u00a0  ......<\/span>\r\n \u00a0 \u00a0 \u00a0\/\/shouldFetchRegistry\uff0c\u5176\u5b9e\u73b0\u7c7b\u4e3aEurekaClientConfigBean\uff0c\u627e\u5230\u5b83\u5176\u5b9e\u5bf9\u5e94\u4e8e\uff1aeureka.client.fetch-register\uff0ctrue\uff1a\u8868\u793aclient\u4eceserver\u62c9\u53d6\u6ce8\u518c\u8868\u4fe1\u606f\u3002<\/span><\/span>\r\n \u00a0 \u00a0 if<\/span> (config<\/span>.shouldFetchRegistry<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 this<\/span>.registryStalenessMonitor<\/span> =<\/span> new<\/span> ThresholdLevelsMetric<\/span>(this<\/span>, METRIC_REGISTRY_PREFIX<\/span> +<\/span> \"lastUpdateSec_\"<\/span>, new<\/span> long<\/span>[]{15L<\/span>, 30L<\/span>, 60L<\/span>, 120L<\/span>, 240L<\/span>, 480L<\/span>});<\/span>\r\n \u00a0 \u00a0 } else<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 this<\/span>.registryStalenessMonitor<\/span> =<\/span> ThresholdLevelsMetric<\/span>.NO_OP_METRIC<\/span>;<\/span>\r\n \u00a0 \u00a0 }<\/span>\r\n \u00a0 \u00a0<\/span>\r\n \u00a0 \u00a0\/\/shouldRegisterWithEureka\uff0c\u70b9\u5176\u5b9e\u73b0\u7c7bEurekaClientConfigBean\uff0c\u627e\u5230\u5b83\u5176\u5b9e\u5bf9\u5e94\u4e8e\uff1aeureka.client.register-with-eureka\uff1atrue\uff1a\u8868\u793aclient\u5c06\u6ce8\u518c\u5230server\u3002<\/span><\/span>\r\n \u00a0 \u00a0if<\/span> (config<\/span>.shouldRegisterWithEureka<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0this<\/span>.heartbeatStalenessMonitor<\/span> =<\/span> new<\/span> ThresholdLevelsMetric<\/span>(this<\/span>, METRIC_REGISTRATION_PREFIX<\/span> +<\/span> \"lastHeartbeatSec_\"<\/span>, new<\/span> long<\/span>[]{15L<\/span>, 30L<\/span>, 60L<\/span>, 120L<\/span>, 240L<\/span>, 480L<\/span>});<\/span>\r\n \u00a0  } else<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0this<\/span>.heartbeatStalenessMonitor<\/span> =<\/span> ThresholdLevelsMetric<\/span>.NO_OP_METRIC<\/span>;<\/span>\r\n \u00a0  }<\/span>\r\n \u00a0  ......<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0<\/span>\r\n\/\/ default size of 2 - 1 each for heartbeat and cacheRefresh<\/span><\/span>\r\n \u00a0 \u00a0scheduler<\/span> =<\/span> Executors<\/span>.newScheduledThreadPool<\/span>(2<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 new<\/span> ThreadFactoryBuilder<\/span>()<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 .setNameFormat<\/span>(\"DiscoveryClient-%d\"<\/span>)<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 .setDaemon<\/span>(true<\/span>)<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 .build<\/span>());<\/span>\r\n \u00a0 \u00a0\/\/\u7528\u4e8e\u53d1\u9001\u5fc3\u8df3<\/span><\/span>\r\n \u00a0 \u00a0heartbeatExecutor<\/span> =<\/span> new<\/span> ThreadPoolExecutor<\/span>(<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a01<\/span>, clientConfig<\/span>.getHeartbeatExecutorThreadPoolSize<\/span>(), 0<\/span>, TimeUnit<\/span>.SECONDS<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0new<\/span> SynchronousQueue<\/span><<\/span>Runnable<\/span>><\/span>(),<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0new<\/span> ThreadFactoryBuilder<\/span>()<\/span>\r\n \u00a0 \u00a0 \u00a0  .setNameFormat<\/span>(\"DiscoveryClient-HeartbeatExecutor-%d\"<\/span>)<\/span>\r\n \u00a0 \u00a0 \u00a0  .setDaemon<\/span>(true<\/span>)<\/span>\r\n \u00a0 \u00a0 \u00a0  .build<\/span>()<\/span>\r\n \u00a0  ); \u00a0\/\/ use direct handoff<\/span><\/span>\r\n \u00a0 \u00a0\/\/\u7528\u4e8e\u5237\u65b0\u7f13\u5b58<\/span><\/span>\r\n \u00a0 \u00a0cacheRefreshExecutor<\/span> =<\/span> new<\/span> ThreadPoolExecutor<\/span>(<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a01<\/span>, clientConfig<\/span>.getCacheRefreshExecutorThreadPoolSize<\/span>(), 0<\/span>, TimeUnit<\/span>.SECONDS<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0new<\/span> SynchronousQueue<\/span><<\/span>Runnable<\/span>><\/span>(),<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0new<\/span> ThreadFactoryBuilder<\/span>()<\/span>\r\n \u00a0 \u00a0 \u00a0  .setNameFormat<\/span>(\"DiscoveryClient-CacheRefreshExecutor-%d\"<\/span>)<\/span>\r\n \u00a0 \u00a0 \u00a0  .setDaemon<\/span>(true<\/span>)<\/span>\r\n \u00a0 \u00a0 \u00a0  .build<\/span>()<\/span>\r\n \u00a0  ); \u00a0\/\/ use direct handoff<\/span><\/span>\r\n \u00a0 \u00a0<\/span>\r\n \u00a0 \u00a0\/\/eurekaTransport\u662feureka Client\u548ceureka server\u8fdb\u884chttp\u4ea4\u4e92jersey\u5ba2\u6237\u7aef\u3002\u70b9\u5f00EurekaTransport\uff0c\u770b\u5230\u8bb8\u591ahttpclient\u76f8\u5173\u7684\u5c5e\u6027\u3002<\/span><\/span>\r\n \u00a0 \u00a0eurekaTransport<\/span> =<\/span> new<\/span> EurekaTransport<\/span>();<\/span>\r\n \u00a0 \u00a0<\/span>\r\n \u00a0 \u00a0if<\/span> (clientConfig<\/span>.shouldFetchRegistry<\/span>()) {<\/span>\r\n        ....<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/\u4eceeureka server\u62c9\u53d6\u6ce8\u518c\u8868\u4e2d\u7684\u4fe1\u606f\uff0c\u5c06\u6ce8\u518c\u8868\u7f13\u5b58\u5230\u672c\u5730\uff0c\u53ef\u4ee5\u5c31\u8fd1\u83b7\u53d6\u5176\u4ed6\u670d\u52a1\u4fe1\u606f\uff0c\u51cf\u5c11\u4e8eserver\u7684\u4ea4\u4e92\u3002<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 boolean<\/span> primaryFetchRegistryResult<\/span> =<\/span> fetchRegistry<\/span>(false<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 ......<\/span>\r\n \u00a0  }<\/span>\r\n \u00a0 \u00a0<\/span>\r\n \u00a0 \u00a0\/\/register()\u8fdb\u884c\u6ce8\u518c\uff0c\u82e5\u6ce8\u518c\u5931\u8d25\u5219\u629b\u51fa\u5f02\u5e38<\/span><\/span>\r\n \u00a0 \u00a0if<\/span> (clientConfig<\/span>.shouldRegisterWithEureka<\/span>() &&<\/span> clientConfig<\/span>.shouldEnforceRegistrationAtInit<\/span>()) {<\/span>\r\n \u00a0      try<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (!<\/span>register<\/span>() ) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0      throw<\/span> new<\/span> IllegalStateException<\/span>(\"Registration error at startup. Invalid server response.\"<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0      } catch<\/span> (Throwable<\/span> th<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.error<\/span>(\"Registration error at startup: {}\"<\/span>, th<\/span>.getMessage<\/span>());<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0throw<\/span> new<\/span> IllegalStateException<\/span>(th<\/span>);<\/span>\r\n \u00a0      }<\/span>\r\n \u00a0  }<\/span>\r\n \u00a0 \u00a0<\/span>\r\n \u00a0 \u00a0\/\/\u542f\u52a8\u8c03\u5ea6\u4efb\u52a1<\/span><\/span>\r\n \u00a0 \u00a0initScheduledTasks<\/span>();<\/span>\r\n}<\/span>\r\n\u200b<\/span><\/pre>\n
DiscoveryClient\u6784\u9020\u65b9\u6cd5\u5c0f\u7ed3<\/span><\/h4>\n
\u6784\u9020\u65b9\u6cd5\u4e2d\u4e3b\u8981\u8fdb\u884c\u5982\u4e0b\u5de5\u4f5c\uff1a<\/span><\/p>\n