{"id":889,"date":"2020-09-29T18:21:44","date_gmt":"2020-09-29T10:21:44","guid":{"rendered":"http:\/\/prayerlaputa.com\/?p=889"},"modified":"2020-09-29T19:35:05","modified_gmt":"2020-09-29T11:35:05","slug":"%e6%ba%90%e7%a0%81%e5%88%86%e6%9e%90%e4%b9%8beureka%e6%9c%8d%e5%8a%a1%e7%ab%af%e6%ba%90%e7%a0%81%e8%a7%a3%e6%9e%90","status":"publish","type":"post","link":"http:\/\/prayerlaputa.com\/?p=889","title":{"rendered":"\u6e90\u7801\u5206\u6790\u4e4bEureka\u670d\u52a1\u7aef\u6e90\u7801\u89e3\u6790"},"content":{"rendered":"

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

\u82e5\u65e0\u7279\u522b\u8bf4\u660e\uff0c\u672c\u6587\u6240\u6d89\u53ca\u7684\u4ee3\u7801\u7248\u672c\u4e3aspring boot\/cloud 2.2.6\u3002<\/span><\/p>\n

eureka server\u57fa\u672c\u529f\u80fd<\/span><\/h2>\n
    \n
  • \n

    \u63a5\u53d7\u670d\u52a1\u6ce8\u518c<\/span><\/p>\n<\/li>\n

  • \n

    \u63a5\u53d7\u670d\u52a1\u5fc3\u8df3<\/span><\/p>\n<\/li>\n

  • \n

    \u670d\u52a1\u5254\u9664<\/span><\/p>\n<\/li>\n

  • \n

    \u670d\u52a1\u4e0b\u7ebf<\/span><\/p>\n<\/li>\n

  • \n

    \u96c6\u7fa4\u540c\u6b65<\/span><\/p>\n<\/li>\n

  • \n

    \u83b7\u53d6\u6ce8\u518c\u8868\u4e2d\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f<\/span><\/p>\n<\/li>\n<\/ul>\n

    <\/p>\n

    \u9700\u8981\u6ce8\u610f\u7684\u662f\uff0cEureka Server\u540c\u65f6\u4e5f\u662f\u4e00\u4e2aEureka Client\uff0c\u5728\u4e0d\u7981\u6b62Eureka Server\u7684\u5ba2\u6237\u7aef\u884c\u4e3a\u65f6\uff0c\u5b83\u4f1a\u5411\u5b83\u914d\u7f6e\u6587\u4ef6\u4e2d\u7684\u5176\u4ed6Eureka Server\u8fdb\u884c\u62c9\u53d6\u6ce8\u518c\u8868\u3001\u670d\u52a1\u6ce8\u518c\u548c\u53d1\u9001\u5fc3\u8df3\u7b49\u64cd\u4f5c<\/span><\/p>\n

    eureka\u67b6\u6784\u653e\u4e00\u5f20\u56fe\uff0c\u9547\u697c<\/span><\/p>\n

    \"\"<\/p>\n

    \u542f\u52a8eureka-server\u6ce8\u518c\u76f8\u5173bean<\/span><\/h3>\n

    \u4e0eeureka-client\u7c7b\u4f3c\uff0ceureka-server\u542f\u52a8\u4e5f\u662f\u4f9d\u8d56spring factories\u673a\u5236\u521d\u59cb\u5316\u3001\u5e76\u5c06\u5bf9\u8c61\u52a0\u8f7d\u5230spring\u5bb9\u5668\u4e2d\u3002<\/span><\/p>\n

    \u4ee5<\/span>spring-cloud-netflix-eureka-server-2.2.2.REALEASE.jar<\/code><\/span>\u4e3a\u4f8b\uff0c\u6253\u5f00\u8be5\u5305\u4e2d\u7684spring.factories\uff0c\u53ef\u4ee5\u770b\u5230<\/span><\/p>\n

    org.springframework.boot.autoconfigure.EnableAutoConfiguration=\\<\/span>\r\n  org.springframework.cloud.netflix.eureka.server.EurekaServerAutoConfiguration<\/span><\/pre>\n
    \u5373\u542f\u52a8\u65f6\u81ea\u52a8\u52a0\u8f7dEurekaServerAutoConfiguration\u7c7b\uff0c\u800c\u8be5\u7c7b\u7684\u529f\u80fd\u662f\u5411spring\u7684bean\u5de5\u5382\u6dfb\u52a0eureka-server\u76f8\u5173\u529f\u80fd\u7684bean\u3002<\/span><\/p>\n
    EurekaServerAutoConfiguration\u4e0a\u6709\u4e00\u4e2a\u6ce8\u89e3\uff1a@ConditionalOnBean(EurekaServerMarkerConfiguration.Marker.class)\uff0c\u610f\u601d\u662f\uff1a\u53ea\u6709\u5728Spring\u5bb9\u5668\u91cc\u6709Marker\u8fd9\u4e2a\u7c7b\u7684\u5b9e\u4f8b\u65f6\uff0c\u624d\u4f1a\u52a0\u8f7dEurekaServerAutoConfiguration\uff0c\u8fd9\u4e2a\u5c31\u662f\u63a7\u5236\u662f\u5426\u5f00\u542fEureka Server\u7684\u5173\u952e\u3002<\/span><\/p>\n
    \u5f00\u542feureka server<\/span><\/h3>\n
    \u5728\u4f7f\u7528eureka-server\u65f6\uff0c\u6211\u4eec\u6240\u52a0\u7684<\/span>@EnableEurekaServer<\/code><\/span>\u6ce8\u89e3\uff0c\u5b9e\u73b0\u5982\u4e0b\uff1a<\/span><\/p>\n
    @Target<\/span>(ElementType<\/span>.TYPE<\/span>)<\/span>\r\n@Retention<\/span>(RetentionPolicy<\/span>.RUNTIME<\/span>)<\/span>\r\n@Documented<\/span><\/span>\r\n@Import<\/span>(EurekaServerMarkerConfiguration<\/span>.class<\/span>)<\/span>\r\npublic<\/span> @interface<\/span> EnableEurekaServer<\/span> {<\/span>\r\n}<\/span><\/pre>\n
    \u6b64\u5904\u5229\u7528spring\u63d0\u4f9b\u7684<\/span>@Import<\/code><\/span>\u6ce8\u89e3\uff0c\u5c06<\/span>EurekaServerMarkerConfiguration<\/code><\/span>\u52a8\u6001\u6ce8\u5165\u5230spring \u5bb9\u5668\u4e2d\uff0c\u8fd9\u4e5f\u521a\u597d\u63d0\u4f9b\u4e86\u4e0a\u9762spring factories\u91cc<\/span>EurekaServerAutoConfiguration<\/code><\/span>\u5b9e\u4f8b\u5316\u7684\u524d\u63d0\uff1a\u5fc5\u987b\u6709<\/span>EurekaServerMarkerConfiguration<\/code><\/span>\u3002<\/span><\/p>\n
    \u5373\u542f\u52a8\u65f6\u521d\u59cb\u5316\u987a\u5e8f\uff1a<\/span><\/p>\n
      \n
    • \n
      \u6dfb\u52a0<\/span>EnableEurekaServer<\/code><\/span>\u6ce8\u89e3\u540e\uff0c\u901a\u8fc7@Import\u5f15\u5165<\/span>EurekaServerMarkerConfiguration<\/code><\/span><\/p>\n<\/li>\n
    • \n
      \u5229\u7528spring factories\uff0c\u52a0\u8f7d<\/span>EurekaServerAutoConfiguration<\/code><\/span><\/p>\n<\/li>\n<\/ul>\n
      \u5f00\u542f\u6ce8\u518c<\/span><\/h3>\n
      \u5728spring-cloud-netflix-eureka-server:2.2.2.RELEASE\u4e2d\uff0c<\/span>EurekaServerAutoConfiguration<\/code><\/span>\u58f0\u660e\u5982\u4e0b\uff1a<\/span><\/p>\n
      @Configuration<\/span>(proxyBeanMethods<\/span> =<\/span> false<\/span>)<\/span>\r\n@Import<\/span>(EurekaServerInitializerConfiguration<\/span>.class<\/span>)<\/span>\r\n@ConditionalOnBean<\/span>(EurekaServerMarkerConfiguration<\/span>.Marker<\/span>.class<\/span>)<\/span>\r\n@EnableConfigurationProperties<\/span>({ EurekaDashboardProperties<\/span>.class<\/span>,<\/span>\r\n        InstanceRegistryProperties<\/span>.class<\/span> })<\/span>\r\n@PropertySource<\/span>(\"classpath:\/eureka\/server.properties\"<\/span>)<\/span>\r\npublic<\/span> class<\/span> EurekaServerAutoConfiguration<\/span> implements<\/span> WebMvcConfigurer<\/span> {<\/span>\r\n \u00a0  ......<\/span>\r\n}<\/span><\/pre>\n
      \u5176\u4e2d\uff0c\u901a\u8fc7@Import\u5f15\u5165\u7684<\/span>EurekaServerInitializerConfiguration<\/code><\/span>\u7c7b\u58f0\u660e\u5982\u4e0b\uff1a<\/span><\/p>\n
      @Configuration<\/span>(proxyBeanMethods<\/span> =<\/span> false<\/span>)<\/span>\r\npublic<\/span> class<\/span> EurekaServerInitializerConfiguration<\/span><\/span>\r\n        implements<\/span> ServletContextAware<\/span>, SmartLifecycle<\/span>, Ordered<\/span> {<\/span>\r\n \u00a0  ......<\/span>\r\n}<\/span>\r\n \u00a0 \u00a0<\/span><\/pre>\n
      SmartLifecycle\u7684\u4f5c\u7528\u662f\uff1a\u521d\u59cb\u5316\u5b8c\u4e4b\u540e\uff0c\u6267\u884cpublic void start()\u65b9\u6cd5\u3002<\/span><\/p>\n
      \u800c<\/span>EurekaServerInitializerConfiguration<\/code><\/span>\u4e2dstart()\u65b9\u6cd5\uff1a<\/span><\/p>\n
        \n
      • \n
        \u542f\u52a8\u4e00\u4e2a\u7ebf\u7a0b\uff1b<\/span><\/p>\n<\/li>\n
      • \n
        \u4e0a\u4e0b\u6587\u521d\u59cb\u5316<\/span><\/p>\n<\/li>\n
      • \n
        \u5229\u7528spring\u7684\u4e8b\u4ef6\u673a\u5236\uff0c\u53d1\u5e03\u4e00\u4e2aEurekaRegistryAvailableEvent\u4e8b\u4ef6<\/span><\/p>\n<\/li>\n
      • \n
        \u66f4\u6539running\u72b6\u6001<\/span><\/p>\n<\/li>\n
      • \n
        \u5229\u7528spring\u7684\u4e8b\u4ef6\u673a\u5236\uff0c\u53d1\u5e03\u4e00\u4e2aEurekaServerStartedEvent\u4e8b\u4ef6<\/span><\/p>\n<\/li>\n<\/ul>\n
        \u5728\u8fd9\u4e2astart() \u4e0a\u4e0b\u6587\u521d\u59cb\u5316\u8fd9\u4e00\u6b65\uff0c\u8fd8\u4f1a\u4ece\u76f8\u90bbeureka\u8282\u70b9\u6ce8\u518c\u8868\uff0c\u65b9\u6cd5\u8c03\u7528\u8def\u5f84\u5982\u4e0b\uff1a<\/span><\/p>\n
        EurekaServerInitializerConfiguration#start()<\/span>\r\n    EurekaServerBoostrap#contextInitialized(ServletContext context)<\/span>\r\n        EurekaServerBoostrap#initEurekaServerContext()<\/span>\r\n            \/\/ Copy registry from neighboring eureka node  \u6b64\u5904\u8fdb\u884c\u590d\u5236\u76f8\u90bbeureka\u6ce8\u518c\u8868\u7684\u64cd\u4f5c<\/span>\r\n            int registryCount = this.registry.syncUp();<\/span><\/pre>\n
        \u5728EurekaServerAutoConfiguration\u4e2d\u4f1a\u5b9e\u4f8b\u5316<\/span>EurekaServerContext<\/code><\/span>\uff0c\u4ee3\u7801\u5982\u4e0b\uff1a<\/span><\/p>\n
            @Bean<\/span><\/span>\r\n    @ConditionalOnMissingBean<\/span><\/span>\r\n    public<\/span> EurekaServerContext<\/span> eurekaServerContext<\/span>(ServerCodecs<\/span> serverCodecs<\/span>,<\/span>\r\n            PeerAwareInstanceRegistry<\/span> registry<\/span>, PeerEurekaNodes<\/span> peerEurekaNodes<\/span>) {<\/span>\r\n        return<\/span> new<\/span> DefaultEurekaServerContext<\/span>(this<\/span>.eurekaServerConfig<\/span>, serverCodecs<\/span>,<\/span>\r\n                registry<\/span>, peerEurekaNodes<\/span>, this<\/span>.applicationInfoManager<\/span>);<\/span>\r\n    }<\/span><\/pre>\n
        DefaultEurekaServerContext<\/code><\/span>\u4e2d\u521d\u59cb\u5316\u4ee3\u7801\u5982\u4e0b\uff1a<\/span><\/p>\n
         \u00a0 \u00a0@PostConstruct<\/span><\/span>\r\n \u00a0 \u00a0@Override<\/span><\/span>\r\n \u00a0 \u00a0public<\/span> void<\/span> initialize<\/span>() {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Initializing ...\"<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/\u542f\u52a8\u4e00\u4e2a\u53ea\u62e5\u6709\u4e00\u4e2a\u7ebf\u7a0b\u7684\u7ebf\u7a0b\u6c60\uff0c\u7b2c\u4e00\u6b21\u8fdb\u53bb\u4f1a\u66f4\u65b0\u4e00\u4e0b\u96c6\u7fa4\u5176\u4ed6\u8282\u70b9\u4fe1\u606f\u3002<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0peerEurekaNodes<\/span>.start<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0try<\/span> {<\/span>\r\n        \/\/\u8c03\u7528PeerAwareInstanceRegistryImpl\u7684init\u65b9\u6cd5<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0registry<\/span>.init<\/span>(peerEurekaNodes<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0  } catch<\/span> (Exception<\/span> e<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0throw<\/span> new<\/span> RuntimeException<\/span>(e<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Initialized\"<\/span>);<\/span>\r\n \u00a0  }<\/span><\/pre>\n
        \u5728spring-cloud-netflix-eureka-server\u4e2d\uff0c<\/span>PeerAwareInstanceRegistryImpl<\/code><\/span>\u7684\u7ee7\u627f\/\u5b9e\u73b0\u5173\u7cfb\u53c2\u89c1\u4e0b\u56fe\uff1a<\/span><\/p>\n
        \"\"<\/span><\/h2>\n
        eureka server\u56f4\u7ed5\u6ce8\u518c\u8868\u7ba1\u7406\u7684\uff0c\u4e5f\u5c31\u662f\u4e0a\u9762\u7684InstanceRegistry\u3002<\/span><\/p>\n
        \u6ce8\u518c\u8868\u7ba1\u7406\u6838\u5fc3\u7c7b InstanceRegistry<\/span><\/h3>\n
        \u53c2\u8003\u4e0a\u56fe\uff0c\u4f9d\u6b21\u8bf4\u660e\u5982\u4e0b\uff1a<\/span><\/p>\n
          \n
        • \n
          InstanceRegistry<\/span><\/p>\n
            \n
          • \n
            \u6709\u4e24\u79cdInstanceRegistry\uff0c\u53c2\u8003\u5982\u4e0b\uff1a<\/span><\/p>\n<\/li>\n
          • \n
            com.netflix.eureka.registry.InstanceRegistry\u662feuraka server\u4e2d\u6ce8\u518c\u8868\u7ba1\u7406\u7684\u6838\u5fc3\u63a5\u53e3\u3002\u804c\u8d23\u662f\u5728\u5185\u5b58\u4e2d\u7ba1\u7406\u6ce8\u518c\u5230Eureka Server\u4e2d\u7684\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f\u3002\u5b9e\u73b0\u7c7b\u6709PeerAwareInstanceRegistryImpl\u3002<\/span><\/p>\n<\/li>\n
          • \n
            org.springframework.cloud.netflix.eureka.server.InstanceRegistry \u5bf9PeerAwareInstanceRegistryImpl\u8fdb\u884c\u4e86\u7ee7\u627f\u548c\u6269\u5c55\uff0c\u4f7f\u5176\u9002\u914dSpring cloud\u7684\u4f7f\u7528\u73af\u5883\uff0c\u4e3b\u8981\u7684\u5b9e\u73b0\u7531PeerAwareInstanceRegistryImpl\u63d0\u4f9b\u3002<\/span><\/p>\n<\/li>\n<\/ul>\n<\/li>\n
          • \n
            LeaseManager<\/span><\/p>\n
              \n
            • \n
              \u5bf9\u6ce8\u518c\u5230Eureka Server\u4e2d\u7684\u670d\u52a1\u5b9e\u4f8b\u79df\u7ea6\u8fdb\u884c\u7ba1\u7406\uff0c\u65b9\u6cd5\u6709\uff1a\u670d\u52a1\u6ce8\u518c\uff0c\u4e0b\u7ebf\uff0c\u7eed\u7ea6\uff0c\u5254\u9664\u3002\u6b64\u63a5\u53e3\u7ba1\u7406\u7684\u7c7b\u76ee\u524d\u662fInstanceInfo\u3002InstanceInfo\u4ee3\u8868\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f\u3002<\/span><\/p>\n<\/li>\n<\/ul>\n<\/li>\n
            • \n
              LookupService<\/span><\/p>\n
                \n
              • \n
                \u63d0\u4f9b\u670d\u52a1\u5b9e\u4f8b\u7684\u68c0\u7d22\u67e5\u8be2\u529f\u80fd\u3002<\/span><\/p>\n<\/li>\n<\/ul>\n<\/li>\n
              • \n
                PeerAwareInstanceRegistryImpl<\/span><\/p>\n
                  \n
                • \n
                  \u589e\u52a0\u4e86\u5bf9peer\u8282\u70b9\u7684\u540c\u6b65\u590d\u5236\u64cd\u4f5c\u3002\u4f7f\u5f97eureka server\u96c6\u7fa4\u4e2d\u6ce8\u518c\u8868\u4fe1\u606f\u4fdd\u6301\u4e00\u81f4\u3002<\/span><\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n
                  \u670d\u52a1\u6ce8\u518c<\/span><\/h3>\n
                  Eureka Client\u5728\u53d1\u8d77\u670d\u52a1\u6ce8\u518c\u65f6\u4f1a\u5c06\u81ea\u8eab\u7684\u670d\u52a1\u5b9e\u4f8b\u5143\u6570\u636e\u5c01\u88c5\u5728InstanceInfo\u4e2d\uff0c\u7136\u540e\u5c06InstanceInfo\u53d1\u9001\u5230Eureka Server\u3002Eureka Server\u5728\u63a5\u6536\u5230Eureka Client\u53d1\u9001\u7684InstanceInfo\u540e\u5c06\u4f1a\u5c1d\u8bd5\u5c06\u5176\u653e\u5230\u672c\u5730\u6ce8\u518c\u8868\u4e2d\u4ee5\u4f9b\u5176\u4ed6Eureka Client\u8fdb\u884c\u670d\u52a1\u53d1\u73b0\u3002<\/span><\/p>\n
                  EurekaServerAutoConfiguration\u4e2d\u5b9a\u4e49\u4e86 public FilterRegistrationBean jerseyFilterRegistration \uff0c\u8868\u660eeureka-server\u4f7f\u7528\u4e86Jersey\u5b9e\u73b0 \u5bf9\u5916\u7684RESTful\u63a5\u53e3\u3002\u6ce8\u518c\u4e00\u4e2a Jersey \u7684 filter \uff0c\u914d\u7f6e\u597d\u76f8\u5e94\u7684Filter \u548c url\u6620\u5c04\u3002<\/span><\/p>\n
                  \u5728com.netflix.eureka.resources\u5305\u4e0b\uff0c\u662fEureka Server\u5bf9\u4e8eEureka client\u7684REST\u8bf7\u6c42\u7684\u5b9a\u4e49\u3002\u770bApplicationResource\u7c7b\uff08\u8fd9\u662f\u4e00\u7c7b\u8bf7\u6c42\uff0c\u5e94\u7528\u7c7b\u7684\u8bf7\u6c42\uff09\uff0c\u7c7b\u4f3c\u4e8e\u5e94\u7528@Controller\u6ce8\u89e3\uff1a@Produces({“application\/xml”, “application\/json”})\uff0c\u63a5\u53d7xml\u548cjson\u3002<\/span><\/p>\n
                  \u4f8b\u5982ApplicationResource\u7c7b\u4e2d\uff0c\u6709\u5982\u4e0b\u65b9\u6cd5\uff08\u6dfb\u52a0\u5b9e\u4f8b\u63a5\u53e3\uff09\uff1a<\/span><\/p>\n
                   \u00a0 \u00a0@POST<\/span><\/span>\r\n \u00a0 \u00a0@Consumes<\/span>({\"application\/json\"<\/span>, \"application\/xml\"<\/span>})<\/span>\r\n \u00a0 \u00a0public<\/span> Response<\/span> addInstance<\/span>(InstanceInfo<\/span> info<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@HeaderParam<\/span>(PeerEurekaNode<\/span>.HEADER_REPLICATION<\/span>) String<\/span> isReplication<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0  ......<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \/\/registry\u662fPeerAwareInstanceRegistry\u7c7b\u578b<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0registry<\/span>.register<\/span>(info<\/span>, \"true\"<\/span>.equals<\/span>(isReplication<\/span>));<\/span>\r\n \u00a0 \u00a0 \u00a0  ......<\/span>\r\n \u00a0  }<\/span><\/pre>\n
                  \u4e0a\u9762\u7684<\/span>registry.register<\/code><\/span>\u65b9\u6cd5\uff0c\u53ef\u4ee5\u8ffd\u6eaf\u5230<\/span>PeerAwareInstanceRegistryImpl<\/code><\/span>\u7684\u65b9\u6cd5\uff1apublic void register(final InstanceInfo info, final boolean isReplication) \uff0c\u4e2d\u6709\u4e00\u53e5\uff1asuper.register(info, leaseDuration, isReplication); <\/span>  \u5c06\u4f1a\u8fdb\u5165\uff1a<\/span>com.netflix.eureka.registry.AbstractInstanceRegistry<\/code><\/span>\u7684 register\u65b9\u6cd5<\/span><\/p>\n
                   \u5728register\u65b9\u6cd5\u4e2d\uff0c\u670d\u52a1\u5b9e\u4f8b\u7684InstanceInfo\u4fdd\u5b58\u5728Lease\u4e2d\uff0cLease\u5728AbstractInstanceRegistry\u4e2d\u7edf\u4e00\u901a\u8fc7ConcurrentHashMap\u4fdd\u5b58\u5728\u5185\u5b58\u4e2d\u3002\u5728\u670d\u52a1\u6ce8\u518c\u8fc7\u7a0b\u4e2d\uff0c\u4f1a\u5148\u83b7\u53d6\u4e00\u4e2a\u8bfb\u9501\uff0c\u9632\u6b62\u5176\u4ed6\u7ebf\u7a0b\u5bf9registry\u6ce8\u518c\u8868\u8fdb\u884c\u6570\u636e\u64cd\u4f5c\uff0c\u907f\u514d\u6570\u636e\u7684\u4e0d\u4e00\u81f4\u3002\u7136\u540e\u4eceresgitry\u67e5\u8be2\u5bf9\u5e94\u7684InstanceInfo\u79df\u7ea6\u662f\u5426\u5df2\u7ecf\u5b58\u5728\u6ce8\u518c\u8868\u4e2d\uff0c\u6839\u636eappName\u5212\u5206\u670d\u52a1\u96c6\u7fa4\uff0c\u4f7f\u7528InstanceId\u552f\u4e00\u6807\u8bb0\u670d\u52a1\u5b9e\u4f8b\u3002<\/span><\/p>\n
                    \n
                  • \n
                    \u5982\u679c\u79df\u7ea6\u5b58\u5728\uff0c\u6bd4\u8f83\u4e24\u4e2a\u79df\u7ea6\u4e2d\u7684InstanceInfo\u7684\u6700\u540e\u66f4\u65b0\u65f6\u95f4lastDirtyTimestamp\uff0c\u4fdd\u7559\u65f6\u95f4\u6233\u5927\u7684\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606fInstanceInfo\u3002<\/span><\/p>\n<\/li>\n
                  • \n
                    \u5982\u679c\u79df\u7ea6\u4e0d\u5b58\u5728\uff0c\u610f\u5473\u8fd9\u662f\u4e00\u6b21\u5168\u65b0\u7684\u670d\u52a1\u6ce8\u518c\uff0c\u5c06\u4f1a\u8fdb\u884c\u81ea\u6211\u4fdd\u62a4\u7684\u7edf\u8ba1\uff0c\u521b\u5efa\u65b0\u7684\u79df\u7ea6\u4fdd\u5b58InstanceInfo\u3002\u63a5\u7740\u5c06\u79df\u7ea6\u653e\u5230resgitry\u6ce8\u518c\u8868\u4e2d\u3002<\/span><\/p>\n<\/li>\n<\/ul>\n
                    \u4e4b\u540e\u5c06\u8fdb\u884c\u4e00\u7cfb\u5217\u7f13\u5b58\u64cd\u4f5c\u5e76\u6839\u636e\u8986\u76d6\u72b6\u6001\u89c4\u5219\u8bbe\u7f6e\u670d\u52a1\u5b9e\u4f8b\u7684\u72b6\u6001\uff0c\u7f13\u5b58\u64cd\u4f5c\u5305\u62ec\u5c06InstanceInfo\u52a0\u5165\u7528\u4e8e\u7edf\u8ba1Eureka Client\u589e\u91cf\u5f0f\u83b7\u53d6\u6ce8\u518c\u8868\u4fe1\u606f\u7684recentlyChangedQueue\u548c\u5931\u6548responseCache\u4e2d\u5bf9\u5e94\u7684\u7f13\u5b58\u3002\u6700\u540e\u8bbe\u7f6e\u670d\u52a1\u5b9e\u4f8b\u79df\u7ea6\u7684\u4e0a\u7ebf\u65f6\u95f4\u7528\u4e8e\u8ba1\u7b97\u79df\u7ea6\u7684\u6709\u6548\u65f6\u95f4\uff0c\u91ca\u653e\u8bfb\u9501\u5e76\u5b8c\u6210\u670d\u52a1\u6ce8\u518c\u3002<\/span><\/p>\n
                    \u6d41\u7a0b\u56fe\u5982\u4e0b\uff1a<\/span><\/p>\n
                    \"\"<\/p>\n
                    \u63a5\u6536\u670d\u52a1\u5fc3\u8df3\u8bf7\u6c42<\/span><\/h3>\n
                    \u5728Eureka Client\u5b8c\u6210\u670d\u52a1\u6ce8\u518c\u4e4b\u540e\uff0c\u5b83\u9700\u8981\u5b9a\u65f6\u5411Eureka Server\u53d1\u9001\u5fc3\u8df3\u8bf7\u6c42(\u9ed8\u8ba430\u79d2\u4e00\u6b21)\uff0c\u7ef4\u6301\u81ea\u5df1\u5728Eureka Server\u4e2d\u79df\u7ea6\u7684\u6709\u6548\u6027\u3002<\/span><\/p>\n
                    \u6b64\u4ee3\u7801\u5b9e\u73b0\u5728com.netflix.eureka.resources.InstanceResource\u4e2d\uff0c\u53c2\u89c1\u6b64\u65b9\u6cd5\uff1a<\/span><\/p>\n
                    @PUT<\/span><\/span>\r\npublic<\/span> Response<\/span> renewLease<\/span>(<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@HeaderParam<\/span>(PeerEurekaNode<\/span>.HEADER_REPLICATION<\/span>) String<\/span> isReplication<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@QueryParam<\/span>(\"overriddenstatus\"<\/span>) String<\/span> overriddenStatus<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@QueryParam<\/span>(\"status\"<\/span>) String<\/span> status<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@QueryParam<\/span>(\"lastDirtyTimestamp\"<\/span>) String<\/span> lastDirtyTimestamp<\/span>) {<\/span>\r\n \u00a0  ......<\/span>\r\n \u00a0 \u00a0boolean<\/span> isSuccess<\/span> =<\/span> registry<\/span>.renew<\/span>(app<\/span>.getName<\/span>(), id<\/span>, isFromReplicaNode<\/span>);<\/span>\r\n \u00a0  ......<\/span>\r\n}<\/span><\/pre>\n
                    registry\u7c7b\u578b\u4e3a<\/span>PeerAwareInstanceRegistry<\/code><\/span>\uff0c\u8ffd\u6eaf\u540e\u4f1a\u53d1\u73b0\u6700\u7ec8\u5b9e\u73b0\u662f\u5728<\/span>AbstractInstanceRegistry<\/code><\/span>#renew\u65b9\u6cd5\u3002<\/span><\/p>\n
                    renew\u65b9\u6cd5\u662f\u5bf9Eureka Client\u4f4d\u4e8e\u6ce8\u518c\u8868\u4e2d\u7684\u79df\u7ea6\u7684\u7eed\u79df\u64cd\u4f5c\uff0c\u4e0d\u50cfregister\u65b9\u6cd5\u9700\u8981\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f\uff0c\u4ec5\u6839\u636e\u670d\u52a1\u5b9e\u4f8b\u7684\u670d\u52a1\u540d\u548c\u670d\u52a1\u5b9e\u4f8bid\u5373\u53ef\u66f4\u65b0\u5bf9\u5e94\u79df\u7ea6\u7684\u6709\u6548\u65f6\u95f4\u3002<\/span><\/p>\n
                    public<\/span> boolean<\/span> renew<\/span>(String<\/span> appName<\/span>, String<\/span> id<\/span>, boolean<\/span> isReplication<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0RENEW<\/span>.increment<\/span>(isReplication<\/span>);<\/span>\r\n \u00a0 \u00a0 \/\/\u6839\u636eappName\u83b7\u53d6\u670d\u52a1\u96c6\u7fa4\u7684\u79df\u7ea6\u96c6\u5408<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0Map<\/span><<\/span>String<\/span>, Lease<\/span><<\/span>InstanceInfo<\/span>>><\/span> gMap<\/span> =<\/span> registry<\/span>.get<\/span>(appName<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0Lease<\/span><<\/span>InstanceInfo<\/span>><\/span> leaseToRenew<\/span> =<\/span> null<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (gMap<\/span> !=<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0leaseToRenew<\/span> =<\/span> gMap<\/span>.get<\/span>(id<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (leaseToRenew<\/span> ==<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0RENEW_NOT_FOUND<\/span>.increment<\/span>(isReplication<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.warn<\/span>(\"DS: Registry: lease doesn't exist, registering resource: {} - {}\"<\/span>, appName<\/span>, id<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0return<\/span> false<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0  } else<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0InstanceInfo<\/span> instanceInfo<\/span> =<\/span> leaseToRenew<\/span>.getHolder<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (instanceInfo<\/span> !=<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/ touchASGCache(instanceInfo.getASGName());<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/\u67e5\u770b\u670d\u52a1\u5b9e\u4f8b\u72b6\u6001<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0InstanceStatus<\/span> overriddenInstanceStatus<\/span> =<\/span> this<\/span>.getOverriddenInstanceStatus<\/span>(<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0instanceInfo<\/span>, leaseToRenew<\/span>, isReplication<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (overriddenInstanceStatus<\/span> ==<\/span> InstanceStatus<\/span>.UNKNOWN<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Instance status UNKNOWN possibly due to deleted override for instance {}\"<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0+<\/span> \"; re-register required\"<\/span>, instanceInfo<\/span>.getId<\/span>());<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0RENEW_NOT_FOUND<\/span>.increment<\/span>(isReplication<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0return<\/span> false<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (!<\/span>instanceInfo<\/span>.getStatus<\/span>().equals<\/span>(overriddenInstanceStatus<\/span>)) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\"The instance status {} is different from overridden instance status {} for instance {}. \"<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0+<\/span> \"Hence setting the status to overridden status\"<\/span>, instanceInfo<\/span>.getStatus<\/span>().name<\/span>(),<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0instanceInfo<\/span>.getOverriddenStatus<\/span>().name<\/span>(),<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0instanceInfo<\/span>.getId<\/span>());<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0instanceInfo<\/span>.setStatusWithoutDirty<\/span>(overriddenInstanceStatus<\/span>);<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \/\/\u7edf\u8ba1\u6bcf\u5206\u949f\u7eed\u79df\u6b21\u6570<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0renewsLastMin<\/span>.increment<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \/\/\u66f4\u65b0\u79df\u7ea6<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0leaseToRenew<\/span>.renew<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0return<\/span> true<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0  }<\/span><\/pre>\n
                     \u6b64\u65b9\u6cd5\u4e2d\u4e0d\u5173\u6ce8InstanceInfo\uff0c\u4ec5\u5173\u6ce8\u4e8e\u79df\u7ea6\u672c\u8eab\u4ee5\u53ca\u79df\u7ea6\u7684\u670d\u52a1\u5b9e\u4f8b\u72b6\u6001\u3002\u5982\u679c\u6839\u636e\u670d\u52a1\u5b9e\u4f8b\u7684appName\u548cinstanceInfoId\u67e5\u8be2\u51fa\u670d\u52a1\u5b9e\u4f8b\u7684\u79df\u7ea6\uff0c\u5e76\u4e14\u6839\u636e#getOverriddenInstanceStatus\u65b9\u6cd5\u5f97\u5230\u7684instanceStatus\u4e0d\u4e3aInstanceStatus.UNKNOWN\uff0c\u90a3\u4e48\u66f4\u65b0\u79df\u7ea6\u4e2d\u7684\u6709\u6548\u65f6\u95f4\uff0c\u5373\u66f4\u65b0\u79df\u7ea6Lease\u4e2d\u7684lastUpdateTimestamp\uff0c\u8fbe\u5230\u7eed\u7ea6\u7684\u76ee\u7684\uff1b\u5982\u679c\u79df\u7ea6\u4e0d\u5b58\u5728\uff0c\u90a3\u4e48\u8fd4\u56de\u7eed\u79df\u5931\u8d25\u7684\u7ed3\u679c\u3002<\/span><\/p>\n
                    \u4e0b\u56fe\u7ed9\u51fa\u4e86eureka\u670d\u52a1\u7aef\u63a5\u6536\u5fc3\u8df3\u3001\u79df\u7ea6\u66f4\u65b0\u6d41\u7a0b\u3002<\/span><\/p>\n
                    \"\"<\/span><\/h2>\n
                    \u670d\u52a1\u5254\u9664<\/span><\/h3>\n
                    \u5982\u679cEureka Client\u5728\u6ce8\u518c\u540e\uff0c\u65e2\u6ca1\u6709\u7eed\u7ea6\uff0c\u4e5f\u6ca1\u6709\u4e0b\u7ebf(\u670d\u52a1\u5d29\u6e83\u6216\u8005\u7f51\u7edc\u5f02\u5e38\u7b49\u539f\u56e0)\uff0c\u90a3\u4e48\u670d\u52a1\u7684\u72b6\u6001\u5c31\u5904\u4e8e\u4e0d\u53ef\u77e5\u7684\u72b6\u6001\uff0c\u4e0d\u80fd\u4fdd\u8bc1\u80fd\u591f\u4ece\u8be5\u670d\u52a1\u5b9e\u4f8b\u4e2d\u83b7\u53d6\u5230\u56de\u9988\uff0c\u6240\u4ee5\u9700\u8981\u670d\u52a1\u5254\u9664\u6b64\u65b9\u6cd5\u5b9a\u65f6\u6e05\u7406\u8fd9\u4e9b\u4e0d\u7a33\u5b9a\u7684\u670d\u52a1\uff0c\u8be5\u65b9\u6cd5\u4f1a\u6279\u91cf\u5c06\u6ce8\u518c\u8868\u4e2d\u6240\u6709\u8fc7\u671f\u79df\u7ea6\u5254\u9664\u3002<\/span><\/p>\n
                     \u5254\u9664\u662f\u5b9a\u65f6\u4efb\u52a1\uff0c\u9ed8\u8ba460\u79d2\u6267\u884c\u4e00\u6b21\u3002\u5ef6\u65f660\u79d2\uff0c\u95f4\u969460\u79d2<\/span>  evictionTimer.schedule(evictionTaskRef.get(),<\/span>  serverConfig.getEvictionIntervalTimerInMs(),<\/span>  serverConfig.getEvictionIntervalTimerInMs());<\/span>  \u4ece\u4e0a\u9762eureka server\u542f\u52a8\u6765\u770b\uff0c\u5254\u9664\u7684\u4efb\u52a1\uff0c\u662f\u7ebf\u7a0b\u542f\u52a8\u7684\uff0c\u6267\u884c\u7684\u662f\u4e0b\u9762\u7684\u65b9\u6cd5\u3002<\/span> com.netflix.eureka.registry.AbstractInstanceRegistry<\/code><\/span>#evict<\/span><\/p>\n
                    \u200b<\/span>\r\n\/\/isLeaseExpirationEnabled\u5728<\/span><\/span>\r\npublic<\/span> boolean<\/span> isLeaseExpirationEnabled\u5728<\/span>() {<\/span>\r\n \u00a0 \u00a0if<\/span> (!<\/span>isSelfPreservationModeEnabled<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/\u6b64\u5904\u83b7\u53d6\u81ea\u6211\u4fdd\u62a4\u6a21\u5f0f\u5f00\u5173\u72b6\u6001\uff0c\u6700\u7ec8\u5bf9\u5e94\u4e8eEurekaServerConfigBean\u7c7b\u4e2d\u7684enableSelfPreservation\u914d\u7f6e\u9879\uff0c<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/ The self preservation mode is disabled, hence allowing the instances to expire.<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0return<\/span> true<\/span>;<\/span>\r\n \u00a0  }<\/span>\r\n \u00a0 \u00a0return<\/span> numberOfRenewsPerMinThreshold<\/span> ><\/span> 0<\/span> &&<\/span> getNumOfRenewsInLastMin<\/span>() ><\/span> numberOfRenewsPerMinThreshold<\/span>;<\/span>\r\n}<\/span>\r\n\u200b<\/span>\r\npublic<\/span> void<\/span> evict<\/span>(long<\/span> additionalLeaseMs<\/span>) {<\/span>\r\n \u00a0 \u00a0logger<\/span>.debug<\/span>(\"Running the evict task\"<\/span>);<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0if<\/span> (!<\/span>isLeaseExpirationEnabled<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.debug<\/span>(\"DS: lease expiration is currently disabled.\"<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0return<\/span>;<\/span>\r\n \u00a0  }<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0\/\/ We collect first all expired items, to evict them in random order. For large eviction sets,<\/span><\/span>\r\n \u00a0 \u00a0\/\/ if we do not that, we might wipe out whole apps before self preservation kicks in. By randomizing it,<\/span><\/span>\r\n \u00a0 \u00a0\/\/ the impact should be evenly distributed across all applications.<\/span><\/span>\r\n \u00a0 \u00a0List<\/span><<\/span>Lease<\/span><<\/span>InstanceInfo<\/span>>><\/span> expiredLeases<\/span> =<\/span> new<\/span> ArrayList<\/span><><\/span>();<\/span>\r\n \u00a0 \u00a0\/*<\/span><\/span>\r\n \u00a0 \u00a0\u904d\u5386\u6ce8\u518c\u8868register\uff0c\u4f9d\u6b21\u5224\u65ad\u79df\u7ea6\u662f\u5426\u8fc7\u671f\u3002\u4e00\u6b21\u6027\u83b7\u53d6\u6240\u6709\u7684\u8fc7\u671f\u79df\u7ea6\u3002<\/span><\/span>\r\n \u00a0 \u00a0*\/<\/span><\/span>\r\n \u00a0 \u00a0for<\/span> (Entry<\/span><<\/span>String<\/span>, Map<\/span><<\/span>String<\/span>, Lease<\/span><<\/span>InstanceInfo<\/span>>>><\/span> groupEntry<\/span> : registry<\/span>.entrySet<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0Map<\/span><<\/span>String<\/span>, Lease<\/span><<\/span>InstanceInfo<\/span>>><\/span> leaseMap<\/span> =<\/span> groupEntry<\/span>.getValue<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (leaseMap<\/span> !=<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0for<\/span> (Entry<\/span><<\/span>String<\/span>, Lease<\/span><<\/span>InstanceInfo<\/span>>><\/span> leaseEntry<\/span> : leaseMap<\/span>.entrySet<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0Lease<\/span><<\/span>InstanceInfo<\/span>><\/span> lease<\/span> =<\/span> leaseEntry<\/span>.getValue<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (lease<\/span>.isExpired<\/span>(additionalLeaseMs<\/span>) &&<\/span> lease<\/span>.getHolder<\/span>() !=<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0expiredLeases<\/span>.add<\/span>(lease<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0  }<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0\/\/ To compensate for GC pauses or drifting local time, we need to use current registry size as a base for<\/span><\/span>\r\n \u00a0 \u00a0\/\/ triggering self-preservation. Without that we would wipe out full registry.<\/span><\/span>\r\n \u00a0 \u00a0\/\/\u83b7\u53d6\u6ce8\u518c\u8868\u79df\u7ea6\u603b\u6570<\/span><\/span>\r\n \u00a0 \u00a0int<\/span> registrySize<\/span> =<\/span> (int<\/span>) getLocalRegistrySize<\/span>();<\/span>\r\n \u00a0 \u00a0\/\/\u8ba1\u7b97\u6ce8\u518c\u8868\u79df\u7ea6\u7684\u9608\u503c \uff08\u603b\u6570\u4e58\u4ee5 \u7eed\u79df\u767e\u5206\u6bd4\uff09\uff0c\u5f97\u51fa\u8981\u7eed\u79df\u7684\u6570\u91cf<\/span><\/span>\r\n \u00a0 \u00a0int<\/span> registrySizeThreshold<\/span> =<\/span> (int<\/span>) (registrySize<\/span> *<\/span> serverConfig<\/span>.getRenewalPercentThreshold<\/span>());<\/span>\r\n \u00a0 \u00a0\/\/\u603b\u6570\u51cf\u53bb\u8981\u7eed\u79df\u7684\u6570\u91cf\uff0c\u5c31\u662f\u7406\u8bba\u8981\u5254\u9664\u7684\u6570\u91cf \u00a0 \u00a0 \u00a0 \u00a0<\/span><\/span>\r\n \u00a0 \u00a0int<\/span> evictionLimit<\/span> =<\/span> registrySize<\/span> -<\/span> registrySizeThreshold<\/span>;<\/span>\r\n    \/\/\u6c42 \u4e0a\u9762\u7406\u8bba\u5254\u9664\u6570\u91cf\uff0c\u548c\u8fc7\u671f\u79df\u7ea6\u603b\u6570\u7684\u6700\u5c0f\u503c\u3002\u5c31\u662f\u6700\u7ec8\u8981\u63d0\u51fa\u7684\u6570\u91cf\u3002<\/span><\/span>\r\n \u00a0 \u00a0int<\/span> toEvict<\/span> =<\/span> Math<\/span>.min<\/span>(expiredLeases<\/span>.size<\/span>(), evictionLimit<\/span>);<\/span>\r\n \u00a0 \u00a0if<\/span> (toEvict<\/span> ><\/span> 0<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Evicting {} items (expired={}, evictionLimit={})\"<\/span>, toEvict<\/span>, expiredLeases<\/span>.size<\/span>(), evictionLimit<\/span>);<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0Random<\/span> random<\/span> =<\/span> new<\/span> Random<\/span>(System<\/span>.currentTimeMillis<\/span>());<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0for<\/span> (int<\/span> i<\/span> =<\/span> 0<\/span>; i<\/span> <<\/span> toEvict<\/span>; i<\/span>++<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/ Pick a random item (Knuth shuffle algorithm)<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0int<\/span> next<\/span> =<\/span> i<\/span> +<\/span> random<\/span>.nextInt<\/span>(expiredLeases<\/span>.size<\/span>() -<\/span> i<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0Collections<\/span>.swap<\/span>(expiredLeases<\/span>, i<\/span>, next<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0Lease<\/span><<\/span>InstanceInfo<\/span>><\/span> lease<\/span> =<\/span> expiredLeases<\/span>.get<\/span>(i<\/span>);<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0String<\/span> appName<\/span> =<\/span> lease<\/span>.getHolder<\/span>().getAppName<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0String<\/span> id<\/span> =<\/span> lease<\/span>.getHolder<\/span>().getId<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0EXPIRED<\/span>.increment<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.warn<\/span>(\"DS: Registry: expired lease for {}\/{}\"<\/span>, appName<\/span>, id<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/\u6267\u884c \u670d\u52a1\u4e0b\u7ebf\u5c06\u670d\u52a1\u4ece\u6ce8\u518c\u8868\u6e05\u9664\u6389\u3002<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0internalCancel<\/span>(appName<\/span>, id<\/span>, false<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0  }<\/span>\r\n}<\/span>\r\n\u200b<\/span><\/pre>\n
                    \u5254\u9664\u7684\u9650\u5236<\/span><\/h4>\n
                     1.\u81ea\u6211\u4fdd\u62a4\u671f\u95f4\u4e0d\u6e05\u9664\u3002<\/span>  2.\u5206\u6279\u6b21\u6e05\u9664\u3002<\/span>  3.\u670d\u52a1\u662f\u9010\u4e2a\u968f\u673a\u5254\u9664\uff0c\u5254\u9664\u5747\u5300\u5206\u5e03\u5728\u6240\u6709\u5e94\u7528\u4e2d\uff0c\u9632\u6b62\u5728\u540c\u4e00\u65f6\u95f4\u5185\u540c\u4e00\u670d\u52a1\u96c6\u7fa4\u4e2d\u7684\u670d\u52a1\u5168\u90e8\u8fc7\u671f\u88ab\u5254\u9664\uff0c\u9020\u6210\u5728\u5927\u91cf\u5254\u9664\u670d\u52a1\u65f6\uff0c\u5e76\u5728\u8fdb\u884c\u81ea\u6211\u4fdd\u62a4\u65f6\uff0c\u4fc3\u4f7f\u7a0b\u5e8f\u5d29\u6e83\u3002<\/span><\/p>\n
                    \u5254\u9664\u670d\u52a1\u7684\u5b9a\u65f6\u4efb\u52a1<\/span><\/h4>\n
                     \u5254\u9664\u670d\u52a1\u662f\u4e2a\u5b9a\u65f6\u4efb\u52a1\uff0c\u7528EvictionTask\u6267\u884c\uff0c\u9ed8\u8ba460\u79d2\u6267\u884c\u4e00\u6b21\uff0c\u5ef6\u65f660\u79d2\u6267\u884c\u3002\u5b9a\u65f6\u5254\u9664\u8fc7\u671f\u670d\u52a1\u3002<\/span><\/p>\n
                    \u4ee3\u7801\uff1a<\/span><\/p>\n
                    EurekaServerInitializerConfiguration#start()<\/span>\r\n    eurekaServerBootstrap.contextInitialized(EurekaServerInitializerConfiguration.this.servletContext);<\/span>\r\n        EurekaServerBoostrap#initEurekaServerContext()<\/span>\r\n            registry.openForTraffic(this.applicationInfoManager, registryCount);<\/span>\r\n                PeerAwareInstanceRegistryImpl#openForTraffic<\/span>\r\n                    AbstractInstanceRegistry#postInit()<\/span><\/pre>\n
                    \u670d\u52a1\u5254\u9664\u5c06\u4f1a\u904d\u5386registry\u6ce8\u518c\u8868\uff0c\u627e\u51fa\u5176\u4e2d\u6240\u6709\u7684\u8fc7\u671f\u79df\u7ea6\uff0c\u7136\u540e\u6839\u636e\u914d\u7f6e\u6587\u4ef6\u4e2d\u7eed\u79df\u767e\u5206\u6bd4\u9600\u503c\u548c\u5f53\u524d\u6ce8\u518c\u8868\u7684\u79df\u7ea6\u603b\u6570\u91cf\u8ba1\u7b97\u51fa\u6700\u5927\u5141\u8bb8\u7684\u5254\u9664\u79df\u7ea6\u7684\u6570\u91cf(\u5f53\u524d\u6ce8\u518c\u8868\u4e2d\u79df\u7ea6\u603b\u6570\u91cf\u51cf\u53bb\u5f53\u524d\u6ce8\u518c\u8868\u79df\u7ea6\u9600\u503c)\uff0c\u5206\u6279\u6b21\u5254\u9664\u8fc7\u671f\u7684\u670d\u52a1\u5b9e\u4f8b\u79df\u7ea6\u3002\u5bf9\u8fc7\u671f\u7684\u670d\u52a1\u5b9e\u4f8b\u79df\u7ea6\u8c03\u7528AbstractInstanceRegistry#internalCancel\u670d\u52a1\u4e0b\u7ebf\u7684\u65b9\u6cd5\u5c06\u5176\u4ece\u6ce8\u518c\u8868\u4e2d\u6e05\u9664\u6389\u3002<\/span><\/p>\n
                    \u81ea\u6211\u4fdd\u62a4\u673a\u5236<\/span><\/h4>\n
                    \u81ea\u6211\u4fdd\u62a4\u673a\u5236\u4e3b\u8981\u5728Eureka Client\u548cEureka Server\u4e4b\u95f4\u5b58\u5728\u7f51\u7edc\u5206\u533a\u7684\u60c5\u51b5\u4e0b\u53d1\u6325\u4fdd\u62a4\u4f5c\u7528\uff0c\u5728\u670d\u52a1\u5668\u7aef\u548c\u5ba2\u6237\u7aef\u90fd\u6709\u5bf9\u5e94\u5b9e\u73b0\u3002\u5047\u8bbe\u5728\u67d0\u79cd\u7279\u5b9a\u7684\u60c5\u51b5\u4e0b(\u5982\u7f51\u7edc\u6545\u969c)\uff0cEureka Client\u548cEureka Server\u65e0\u6cd5\u8fdb\u884c\u901a\u4fe1\uff0c\u6b64\u65f6Eureka Client\u65e0\u6cd5\u5411Eureka Server\u53d1\u8d77\u6ce8\u518c\u548c\u7eed\u7ea6\u8bf7\u6c42\uff0cEureka Server\u4e2d\u5c31\u53ef\u80fd\u56e0\u6ce8\u518c\u8868\u4e2d\u7684\u670d\u52a1\u5b9e\u4f8b\u79df\u7ea6\u51fa\u73b0\u5927\u91cf\u8fc7\u671f\u800c\u9762\u4e34\u88ab\u5254\u9664\u7684\u5371\u9669\uff0c\u7136\u800c\u6b64\u65f6\u7684Eureka Client\u53ef\u80fd\u662f\u5904\u4e8e\u5065\u5eb7\u72b6\u6001\u7684(\u53ef\u63a5\u53d7\u670d\u52a1\u8bbf\u95ee)\uff0c\u5982\u679c\u76f4\u63a5\u5c06\u6ce8\u518c\u8868\u4e2d\u5927\u91cf\u8fc7\u671f\u7684\u670d\u52a1\u5b9e\u4f8b\u79df\u7ea6\u5254\u9664\u663e\u7136\u662f\u4e0d\u5408\u7406\u7684\u3002<\/span><\/p>\n
                    \u9488\u5bf9\u8fd9\u79cd\u60c5\u51b5\uff0cEureka\u8bbe\u8ba1\u4e86\u201c\u81ea\u6211\u4fdd\u62a4\u673a\u5236\u201d\u3002\u5728Eureka Server\u5904\uff0c\u5982\u679c\u51fa\u73b0\u5927\u91cf\u7684\u670d\u52a1\u5b9e\u4f8b\u8fc7\u671f\u88ab\u5254\u9664\u7684\u73b0\u8c61\uff0c\u90a3\u4e48\u8be5Server\u8282\u70b9\u5c06\u8fdb\u5165\u81ea\u6211\u4fdd\u62a4\u6a21\u5f0f\uff0c\u4fdd\u62a4\u6ce8\u518c\u8868\u4e2d\u7684\u4fe1\u606f\u4e0d\u518d\u88ab\u5254\u9664\uff0c\u5728\u901a\u4fe1\u7a33\u5b9a\u540e\u518d\u9000\u51fa\u8be5\u6a21\u5f0f\uff1b\u5728Eureka Client\u5904\uff0c\u5982\u679c\u5411Eureka Server\u6ce8\u518c\u5931\u8d25\uff0c\u5c06\u5feb\u901f\u8d85\u65f6\u5e76\u5c1d\u8bd5\u4e0e\u5176\u4ed6\u7684Eureka Server\u8fdb\u884c\u901a\u4fe1\u3002\u201c\u81ea\u6211\u4fdd\u62a4\u673a\u5236\u201d\u7684\u8bbe\u8ba1\u5927\u5927\u63d0\u9ad8\u4e86Eureka\u7684\u53ef\u7528\u6027\u3002<\/span><\/p>\n
                    \u6709\u5173\u81ea\u6211\u4fdd\u62a4\u673a\u5236\u7684\u6d41\u7a0b\u56fe\uff1a<\/span><\/p>\n
                    \"\"<\/span><\/h2>\n
                    \u670d\u52a1\u4e0b\u7ebf<\/span><\/h3>\n
                     Eureka Client\u5728\u5e94\u7528\u9500\u6bc1\u65f6\uff0c\u4f1a\u5411Eureka Server\u53d1\u9001\u670d\u52a1\u4e0b\u7ebf\u8bf7\u6c42\uff0c\u6e05\u9664\u6ce8\u518c\u8868\u4e2d\u5173\u4e8e\u672c\u5e94\u7528\u7684\u79df\u7ea6\uff0c\u907f\u514d\u65e0\u6548\u7684\u670d\u52a1\u8c03\u7528\u3002\u5728\u670d\u52a1\u5254\u9664\u7684\u8fc7\u7a0b\u4e2d\uff0c\u4e5f\u662f\u901a\u8fc7\u670d\u52a1\u4e0b\u7ebf\u7684\u903b\u8f91\u5b8c\u6210\u5bf9\u5355\u4e2a\u670d\u52a1\u5b9e\u4f8b\u8fc7\u671f\u79df\u7ea6\u7684\u6e05\u9664\u5de5\u4f5c\u3002<\/span><\/p>\n
                    \u5bf9\u5e94\u4ee3\u7801\uff1acom.netflix.eureka.resources.InstanceResource \u7684<\/span><\/p>\n
                     \u00a0 \u00a0@DELETE<\/span><\/span>\r\n \u00a0 \u00a0public<\/span> Response<\/span> cancelLease<\/span>(<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@HeaderParam<\/span>(PeerEurekaNode<\/span>.HEADER_REPLICATION<\/span>) String<\/span> isReplication<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0  ......<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0boolean<\/span> isSuccess<\/span> =<\/span> registry<\/span>.cancel<\/span>(app<\/span>.getName<\/span>(), id<\/span>, \"true\"<\/span>.equals<\/span>(isReplication<\/span>));<\/span>\r\n \u00a0 \u00a0 \u00a0  ......<\/span>\r\n \u00a0  }<\/span><\/pre>\n
                    \u7ee7\u7eed\u8ffd\u8e2a\uff1a<\/span><\/p>\n
                    InstanceResource#cancelLease<\/span>\r\n    PeerAwareInstanceRegistryImpl#cancel \/\/\u6b64\u65b9\u6cd5\u4e2d\u8fd8\u6709\u5c06\u53d6\u6d88\u64cd\u4f5c\u590d\u5236\u7ed9\u5176\u4ed6eureka\u8282\u70b9\u7684\u903b\u8f91<\/span>\r\n        AbstractInstanceRegistry#cancel<\/span>\r\n            AbstractInstanceRegistry#internalCancel<\/span><\/pre>\n
                    \u6700\u7ec8\u5b9e\u73b0\u4ee3\u7801\u5982\u4e0b\uff1a<\/span><\/p>\n
                    protected<\/span> boolean<\/span> internalCancel<\/span>(String<\/span> appName<\/span>, String<\/span> id<\/span>, boolean<\/span> isReplication<\/span>) {<\/span>\r\n \u00a0 \u00a0try<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/\u5148\u83b7\u53d6\u8bfb\u9501\uff0c\u9632\u6b62\u88ab\u5176\u4ed6\u7ebf\u7a0b\u4fee\u6539<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0read<\/span>.lock<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0CANCEL<\/span>.increment<\/span>(isReplication<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/\u6839\u636eappName\u83b7\u53d6\u670d\u52a1\u5b9e\u4f8b\u96c6\u7fa4\u3002<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0Map<\/span><<\/span>String<\/span>, Lease<\/span><<\/span>InstanceInfo<\/span>>><\/span> gMap<\/span> =<\/span> registry<\/span>.get<\/span>(appName<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0Lease<\/span><<\/span>InstanceInfo<\/span>><\/span> leaseToCancel<\/span> =<\/span> null<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/  \u5728\u5185\u5b58\u4e2d\u53d6\u6d88\u5b9e\u4f8b id\u7684\u670d\u52a1<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (gMap<\/span> !=<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0leaseToCancel<\/span> =<\/span> gMap<\/span>.remove<\/span>(id<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/\u6dfb\u52a0\u5230\u6700\u8fd1\u4e0b\u7ebf\u670d\u52a1\u7684\u7edf\u8ba1\u961f\u5217<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0recentCanceledQueue<\/span>.add<\/span>(new<\/span> Pair<\/span><<\/span>Long<\/span>, String<\/span>><\/span>(System<\/span>.currentTimeMillis<\/span>(), appName<\/span> +<\/span> \"(\"<\/span> +<\/span> id<\/span> +<\/span> \")\"<\/span>));<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0InstanceStatus<\/span> instanceStatus<\/span> =<\/span> overriddenInstanceStatusMap<\/span>.remove<\/span>(id<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (instanceStatus<\/span> !=<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.debug<\/span>(\"Removed instance id {} from the overridden map which has value {}\"<\/span>, id<\/span>, instanceStatus<\/span>.name<\/span>());<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/ \u5f80\u4e0b\u5224\u65adleaseToCancel\u662f\u5426\u4e3a\u7a7a\uff0c\u79df\u7ea6\u4e0d\u5b58\u5728\uff0c\u8fd4\u56defalse<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (leaseToCancel<\/span> ==<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0CANCEL_NOT_FOUND<\/span>.increment<\/span>(isReplication<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.warn<\/span>(\"DS: Registry: cancel failed because Lease is not registered for: {}\/{}\"<\/span>, appName<\/span>, id<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0return<\/span> false<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0  } else<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/\u82e5\u5b58\u5728\uff0c\u8bbe\u7f6e\u79df\u7ea6\u4e0b\u7ebf\u65f6\u95f4<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0leaseToCancel<\/span>.cancel<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0InstanceInfo<\/span> instanceInfo<\/span> =<\/span> leaseToCancel<\/span>.getHolder<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0String<\/span> vip<\/span> =<\/span> null<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0String<\/span> svip<\/span> =<\/span> null<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (instanceInfo<\/span> !=<\/span> null<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/\u83b7\u53d6\u6301\u6709\u79df\u7ea6\u7684\u670d\u52a1\u4fe1\u606f\uff0c\u6807\u8bb0\u670d\u52a1\u5b9e\u4f8b\u4e3ainstanceInfo.setActionType(ActionType.DELETED);<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0instanceInfo<\/span>.setActionType<\/span>(ActionType<\/span>.DELETED<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/\u6dfb\u52a0\u5230\u79df\u7ea6\u53d8\u66f4\u8bb0\u5f55\u961f\u5217<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0recentlyChangedQueue<\/span>.add<\/span>(new<\/span> RecentlyChangedItem<\/span>(leaseToCancel<\/span>));\/\/\u7528\u4e8eeureka client\u7684\u589e\u91cf\u62c9\u53d6\u6ce8\u518c\u8868\u4fe1\u606f\u3002<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0instanceInfo<\/span>.setLastUpdatedTimestamp<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0vip<\/span> =<\/span> instanceInfo<\/span>.getVIPAddress<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0svip<\/span> =<\/span> instanceInfo<\/span>.getSecureVipAddress<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0invalidateCache<\/span>(appName<\/span>, vip<\/span>, svip<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Cancelled instance {}\/{} (replication={})\"<\/span>, appName<\/span>, id<\/span>, isReplication<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0  } finally<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0read<\/span>.unlock<\/span>();<\/span>\r\n \u00a0  }<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0synchronized<\/span> (lock<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (this<\/span>.expectedNumberOfClientsSendingRenews<\/span> ><\/span> 0<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/ Since the client wants to cancel it, reduce the number of clients to send renews.<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0this<\/span>.expectedNumberOfClientsSendingRenews<\/span> =<\/span> this<\/span>.expectedNumberOfClientsSendingRenews<\/span> -<\/span> 1<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0updateRenewsPerMinThreshold<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0  }<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0return<\/span> true<\/span>;<\/span>\r\n}<\/span><\/pre>\n
                    \u4e0a\u8ff0\u4ee3\u7801\u4e3b\u8981\u529f\u80fd\uff1a \u9996\u5148\u901a\u8fc7registry\u6839\u636e\u670d\u52a1\u540d\u548c\u670d\u52a1\u5b9e\u4f8bid\u67e5\u8be2\u5173\u4e8e\u670d\u52a1\u5b9e\u4f8b\u7684\u79df\u7ea6Lease\u662f\u5426\u5b58\u5728\uff0c\u7edf\u8ba1\u6700\u8fd1\u8bf7\u6c42\u4e0b\u7ebf\u7684\u670d\u52a1\u5b9e\u4f8b\u7528\u4e8eEureka Server\u4e3b\u9875\u5c55\u793a\u3002\u5982\u679c\u79df\u7ea6\u4e0d\u5b58\u5728\uff0c\u8fd4\u56de\u4e0b\u7ebf\u5931\u8d25\uff1b\u5982\u679c\u79df\u7ea6\u5b58\u5728\uff0c\u4eceregistry\u6ce8\u518c\u8868\u4e2d\u79fb\u9664\uff0c\u8bbe\u7f6e\u79df\u7ea6\u7684\u4e0b\u7ebf\u65f6\u95f4\uff0c\u540c\u65f6\u5728\u6700\u8fd1\u79df\u7ea6\u53d8\u66f4\u8bb0\u5f55\u961f\u5217\u4e2d\u6dfb\u52a0\u65b0\u7684\u4e0b\u7ebf\u8bb0\u5f55\uff0c\u4ee5\u7528\u4e8eEureka Client\u7684\u589e\u91cf\u5f0f\u83b7\u53d6\u6ce8\u518c\u8868\u4fe1\u606f\u3002<\/span><\/p>\n
                    \"\"<\/p>\n
                    \u96c6\u7fa4\u540c\u6b65 <\/span><\/h3>\n
                     \u5982\u679cEureka Server\u662f\u901a\u8fc7\u96c6\u7fa4\u7684\u65b9\u5f0f\u8fdb\u884c\u90e8\u7f72\uff0c\u90a3\u4e48\u4e3a\u4e86\u7ef4\u62a4\u6574\u4e2a\u96c6\u7fa4\u4e2dEureka Server\u6ce8\u518c\u8868\u6570\u636e\u7684\u4e00\u81f4\u6027\uff0c\u52bf\u5fc5\u9700\u8981\u4e00\u4e2a\u673a\u5236\u540c\u6b65Eureka Server\u96c6\u7fa4\u4e2d\u7684\u6ce8\u518c\u8868\u6570\u636e\u3002<\/span><\/p>\n
                    Eureka Server\u96c6\u7fa4\u540c\u6b65\u5305\u542b\u4e24\u4e2a\u90e8\u5206\uff1a<\/span><\/p>\n
                      \n
                    • \n
                      Eureka Server\u5728\u542f\u52a8\u8fc7\u7a0b\u4e2d\u4ece\u5b83\u7684peer\u8282\u70b9\u4e2d\u62c9\u53d6\u6ce8\u518c\u8868\u4fe1\u606f\uff0c\u5e76\u5c06\u8fd9\u4e9b\u670d\u52a1\u5b9e\u4f8b\u7684\u4fe1\u606f\u6ce8\u518c\u5230\u672c\u5730\u6ce8\u518c\u8868\u4e2d\uff1b<\/span><\/p>\n<\/li>\n
                    • \n
                      Eureka Server\u6bcf\u6b21\u5bf9\u672c\u5730\u6ce8\u518c\u8868\u8fdb\u884c\u64cd\u4f5c\u65f6\uff0c\u540c\u65f6\u4f1a\u5c06\u64cd\u4f5c\u540c\u6b65\u5230\u5b83\u7684peer\u8282\u70b9\u4e2d\uff0c\u8fbe\u5230\u96c6\u7fa4\u6ce8\u518c\u8868\u6570\u636e\u7edf\u4e00\u7684\u76ee\u7684\u3002<\/span><\/p>\n<\/li>\n<\/ul>\n
                      \u542f\u52a8\u62c9\u53d6\u522b\u7684peer<\/span><\/h4>\n
                      Eureka Server\u542f\u52a8\u7c7b\u4e2d\uff0c<\/span>EurekaServerAutoConfiguration<\/code><\/span>\u901a\u8fc7@Import\u6ce8\u89e3\u52a0\u8f7d<\/span>EurekaServerInitializerConfiguration<\/code><\/span><\/p>\n
                      EurekaServerInitializerConfiguration#start()<\/span>\r\n    eurekaServerBootstrap.contextInitialized(...)<\/span>\r\n        EurekaServerBootstrap#initEurekaServerContext()<\/span>\r\n            PeerAwareInstanceRegistryImpl#syncUp();<\/span><\/pre>\n
                      \u4ee3\u7801\u5b9e\u73b0\uff1a<\/span><\/p>\n
                      public<\/span> int<\/span> syncUp<\/span>() {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/ Copy entire entry from neighboring DS node<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0int<\/span> count<\/span> =<\/span> 0<\/span>;<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0for<\/span> (int<\/span> i<\/span> =<\/span> 0<\/span>; ((i<\/span> <<\/span> serverConfig<\/span>.getRegistrySyncRetries<\/span>()) &&<\/span> (count<\/span> ==<\/span> 0<\/span>)); i<\/span>++<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (i<\/span> ><\/span> 0<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0try<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0Thread<\/span>.sleep<\/span>(serverConfig<\/span>.getRegistrySyncRetryWaitMs<\/span>());<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  } catch<\/span> (InterruptedException<\/span> e<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.warn<\/span>(\"Interrupted during registry transfer..\"<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0break<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0Applications<\/span> apps<\/span> =<\/span> eurekaClient<\/span>.getApplications<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0for<\/span> (Application<\/span> app<\/span> : apps<\/span>.getRegisteredApplications<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0for<\/span> (InstanceInfo<\/span> instance<\/span> : app<\/span>.getInstances<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0try<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (isRegisterable<\/span>(instance<\/span>)) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0register<\/span>(instance<\/span>, instance<\/span>.getLeaseInfo<\/span>().getDurationInSecs<\/span>(), true<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0count<\/span>++<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  } catch<\/span> (Throwable<\/span> t<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.error<\/span>(\"During DS init copy\"<\/span>, t<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0return<\/span> count<\/span>;<\/span>\r\n \u00a0  }<\/span><\/pre>\n
                       \u770b\u5faa\u73af\uff1a\u610f\u601d\u662f\uff0c\u5982\u679c\u662fi\u7b2c\u4e00\u6b21\u8fdb\u6765\uff0c\u4e3a0\uff0c\u4e0d\u591f\u7b49\u5f85\u7684\u4ee3\u7801\uff0c\u76f4\u63a5\u6267\u884c\u4e0b\u9762\u7684\u62c9\u53d6\u670d\u52a1\u5b9e\u4f8b\u3002<\/span>  \u5c06\u81ea\u5df1\u4f5c\u4e3a\u4e00\u4e2aeureka client\uff0c\u62c9\u53d6\u6ce8\u518c\u8868\u3002\u5e76\u901a\u8fc7register(instance, instance.getLeaseInfo().getDurationInSecs(), true)\u6ce8\u518c\u5230\u81ea\u8eab\u7684\u6ce8\u518c\u8868\u4e2d\u3002<\/span><\/p>\n
                      Eureka Server\u4e5f\u662f\u4e00\u4e2aEureka Client\uff0c\u5728\u542f\u52a8\u7684\u65f6\u5019\u4e5f\u4f1a\u8fdb\u884cDiscoveryClient\u7684\u521d\u59cb\u5316\uff0c\u4f1a\u4ece\u5176\u5bf9\u5e94\u7684Eureka Server\u4e2d\u62c9\u53d6\u5168\u91cf\u7684\u6ce8\u518c\u8868\u4fe1\u606f\u3002\u5728Eureka Server\u96c6\u7fa4\u90e8\u7f72\u7684\u60c5\u51b5\u4e0b\uff0cEureka Server\u4ece\u5b83\u7684peer\u8282\u70b9\u4e2d\u62c9\u53d6\u5230\u6ce8\u518c\u8868\u4fe1\u606f\u540e\uff0c\u5c06\u904d\u5386\u8fd9\u4e2aApplications\uff0c\u5c06\u6240\u6709\u7684\u670d\u52a1\u5b9e\u4f8b\u901a\u8fc7AbstractRegistry#register\u65b9\u6cd5\u6ce8\u518c\u5230\u81ea\u8eab\u6ce8\u518c\u8868\u4e2d\u3002<\/span><\/p>\n
                      EurekaServerBootstrap#initEurekaServerContext()\u4e2d\u6709\u5982\u4e0b\u4ee3\u7801\uff1a<\/span><\/p>\n
                              \u3002\u3002\u3002<\/span>\r\n        \/\/ Copy registry from neighboring eureka node<\/span>\r\n        int registryCount = this.registry.syncUp();<\/span>\r\n        this.registry.openForTraffic(this.applicationInfoManager, registryCount);<\/span>\r\n        \u3002\u3002\u3002<\/span><\/pre>\n
                      \u5f53\u6267\u884c\u5b8c\u4e0a\u9762\u7684syncUp\u903b\u8f91\u540e\uff0c\u5728\u4e0b\u9762\u7684openForTraffic\uff0c<\/span>\u5f00\u542f\u6b64server\u63a5\u53d7\u522b\u7684client\u6ce8\u518c\uff0c\u62c9\u53d6\u6ce8\u518c\u8868\u7b49\u64cd\u4f5c\u3002\u800c\u5728\u5b83\u9996\u6b21\u62c9\u53d6\u5176\u4ed6peer\u8282\u70b9\u65f6\uff0c\u662f\u4e0d\u5141\u8bb8client\u7684\u901a\u4fe1\u8bf7\u6c42\u7684\u3002<\/span><\/strong><\/span><\/p>\n
                       \u00a0 \u00a0public<\/span> void<\/span> openForTraffic<\/span>(ApplicationInfoManager<\/span> applicationInfoManager<\/span>, int<\/span> count<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/ Renewals happen every 30 seconds and for a minute it should be a factor of 2.<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0this<\/span>.expectedNumberOfClientsSendingRenews<\/span> =<\/span> count<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0updateRenewsPerMinThreshold<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Got {} instances from neighboring DS node\"<\/span>, count<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Renew threshold is: {}\"<\/span>, numberOfRenewsPerMinThreshold<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0this<\/span>.startupTime<\/span> =<\/span> System<\/span>.currentTimeMillis<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0\/\/\u5982\u679ccount=0\uff0c\u6ca1\u6709\u62c9\u53d6\u5230\u6ce8\u518c\u8868\u4fe1\u606f\uff0c\u5c06\u6b64\u503c\u8bbe\u4e3atrue\uff0c\u8868\u793a\u5176\u4ed6peer\u6765\u53d6\u7a7a\u7684\u5b9e\u4f8b\u4fe1\u606f\uff0c\u610f\u5473\u7740\uff0c\u5c06\u4e0d\u5141\u8bb8client\u4ece\u6b64server\u83b7\u53d6\u6ce8\u518c\u8868\u4fe1\u606f\u3002\u5982\u679ccount>0\uff0c\u5c06\u6b64\u503c\u8bbe\u7f6e\u4e3afalse\uff0c\u5141\u8bb8client\u6765\u83b7\u53d6\u6ce8\u518c\u8868\u3002   <\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (count<\/span> ><\/span> 0<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0this<\/span>.peerInstancesTransferEmptyOnStartup<\/span> =<\/span> false<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0DataCenterInfo<\/span>.Name<\/span> selfName<\/span> =<\/span> applicationInfoManager<\/span>.getInfo<\/span>().getDataCenterInfo<\/span>().getName<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0boolean<\/span> isAws<\/span> =<\/span> Name<\/span>.Amazon<\/span> ==<\/span> selfName<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (isAws<\/span> &&<\/span> serverConfig<\/span>.shouldPrimeAwsReplicaConnections<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Priming AWS connections for all replicas..\"<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0primeAwsReplicas<\/span>(applicationInfoManager<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.info<\/span>(\"Changing status to UP\"<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0applicationInfoManager<\/span>.setInstanceStatus<\/span>(InstanceStatus<\/span>.UP<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0super<\/span>.postInit<\/span>();<\/span>\r\n \u00a0  }<\/span><\/pre>\n
                      Server\u4e4b\u95f4\u6ce8\u518c\u8868\u4fe1\u606f\u7684\u540c\u6b65\u590d\u5236<\/span><\/h4>\n
                      \u4e3a\u4e86\u4fdd\u8bc1Eureka Server\u96c6\u7fa4\u8fd0\u884c\u65f6\u6ce8\u518c\u8868\u4fe1\u606f\u7684\u4e00\u81f4\u6027\uff0c\u6bcf\u4e2aEureka Server\u5728\u5bf9\u672c\u5730\u6ce8\u518c\u8868\u8fdb\u884c\u7ba1\u7406\u64cd\u4f5c\u65f6\uff0c\u4f1a\u5c06\u76f8\u5e94\u7684\u64cd\u4f5c\u540c\u6b65\u5230\u6240\u6709peer\u8282\u70b9\u4e2d\u3002<\/span><\/strong><\/span><\/p>\n
                      \u5728\u5916\u90e8\u8c03\u7528server\u7684restful\u65b9\u6cd5\u65f6\uff0c\u5728com.netflix.eureka.resources\u5305\u4e0b\u7684ApplicationResource\u8d44\u6e90\u4e2d\uff0c\u67e5\u770b\u6bcf\u4e2a\u670d\u52a1\u7684\u64cd\u4f5c\u3002\u6bd4\u5982\u670d\u52a1\u6ce8\u518cpublic Response addInstance(\uff0c\u6b64\u65b9\u6cd5\u4e2d\u6709<\/span>  registry.register(info, “true”.equals(isReplication));\u70b9\u8fdb\u53bb\u5b9e\u73b0\u7c7b\uff1areplicateToPeers(Action.Register, info.getAppName(), info.getId(), info, null, isReplication);\u8fd9\u662f\u4e00\u79cd\u60c5\u51b5\u3002<\/span><\/p>\n
                      \u5728PeerAwareInstanceRegistryImpl\u7c7b\u4e2d\uff0c\u5176\u4ed6\u64cd\u4f5c\uff0c\u5982cancel\uff0crenew\u7b49\u4e2d\u90fd\u6709replicateToPeers\uff0c<\/span>  \u6b64\u65b9\u6cd5\u4e2d\u6709\u4e2apeerEurekaNodes\uff0c\u4ee3\u8868\u4e00\u4e2a\u53ef\u540c\u6b65\u6570\u636e\u7684eureka Server\u7684\u96c6\u5408\uff0c\u5982\u679c\u6ce8\u518c\u8868\u6709\u53d8\u5316\uff0c\u5411\u6b64\u4e2d\u7684peer\u8282\u70b9\u540c\u6b65\u3002<\/span><\/p>\n
                       replicateToPeers\u65b9\u6cd5\uff0c\u5b83\u5c06\u904d\u5386Eureka Server\u4e2dpeer\u8282\u70b9\uff0c\u5411\u6bcf\u4e2apeer\u8282\u70b9\u53d1\u9001\u540c\u6b65\u8bf7\u6c42\u3002<\/span><\/p>\n
                      private<\/span> void<\/span> replicateToPeers<\/span>(Action<\/span> action<\/span>, String<\/span> appName<\/span>, String<\/span> id<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0InstanceInfo<\/span> info<\/span> \/* optional *\/<\/span>,<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0InstanceStatus<\/span> newStatus<\/span> \/* optional *\/<\/span>, boolean<\/span> isReplication<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0Stopwatch<\/span> tracer<\/span> =<\/span> action<\/span>.getTimer<\/span>().start<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0try<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (isReplication<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0numberOfReplicationsLastMin<\/span>.increment<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/ If it is a replication already, do not replicate again as this will create a poison replication<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (peerEurekaNodes<\/span> ==<\/span> Collections<\/span>.EMPTY_LIST<\/span> ||<\/span> isReplication<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0return<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0for<\/span> (final<\/span> PeerEurekaNode<\/span> node<\/span> : peerEurekaNodes<\/span>.getPeerEurekaNodes<\/span>()) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\/\/ If the url represents this host, do not replicate to yourself.<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (peerEurekaNodes<\/span>.isThisMyUrl<\/span>(node<\/span>.getServiceUrl<\/span>())) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0continue<\/span>;<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0replicateInstanceActionsToPeers<\/span>(action<\/span>, appName<\/span>, id<\/span>, info<\/span>, newStatus<\/span>, node<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0  } finally<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0tracer<\/span>.stop<\/span>();<\/span>\r\n \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0  }<\/span><\/pre>\n
                       \u6b64replicateInstanceActionsToPeers\u65b9\u6cd5\u4e2d\uff0c\u7c7bPeerEurekaNode\u7684\u5b9e\u4f8bnode\u7684\u5404\u79cd\u65b9\u6cd5\uff0ccancel\uff0cregister\uff0c\u7b49\uff0c\u7528\u4e86batchingDispatcher.process(\uff0c\u4f5c\u7528\u662f\u5c06\u540c\u4e00\u65f6\u95f4\u6bb5\u5185\uff0c\u76f8\u540c\u670d\u52a1\u5b9e\u4f8b\u7684\u76f8\u540c\u64cd\u4f5c\u5c06\u4f7f\u7528\u76f8\u540c\u7684\u4efb\u52a1\u7f16\u53f7\uff0c\u5728\u8fdb\u884c\u540c\u6b65\u590d\u5236\u7684\u65f6\u5019\uff0c\u5c06\u6839\u636e\u4efb\u52a1\u7f16\u53f7\u5408\u5e76\u64cd\u4f5c\uff0c<\/span>\u51cf\u5c11\u540c\u6b65\u64cd\u4f5c\u7684\u6570\u91cf\u548c\u7f51\u7edc\u6d88\u8017\uff0c\u4f46\u662f\u540c\u65f6\u4e5f\u9020\u6210\u4e86\u540c\u6b65\u590d\u5236\u7684\u5ef6\u65f6\u6027\uff0c\u4e0d\u6ee1\u8db3CAP\u4e2d\u7684C\uff08\u5f3a\u4e00\u81f4\u6027\uff09\u3002<\/span>  \u6240\u4ee5Eureka\uff0c\u53ea\u6ee1\u8db3AP\u3002<\/span><\/strong><\/span><\/p>\n
                      \/\/\u793a\u4f8b\uff1aPeerEurekaNode<\/span><\/span>\r\npublic<\/span> void<\/span> cancel<\/span>(final<\/span> String<\/span> appName<\/span>, final<\/span> String<\/span> id<\/span>) throws<\/span> Exception<\/span> {<\/span>\r\n \u00a0 \u00a0long<\/span> expiryTime<\/span> =<\/span> System<\/span>.currentTimeMillis<\/span>() +<\/span> maxProcessingDelayMs<\/span>;<\/span>\r\n \u00a0 \u00a0batchingDispatcher<\/span>.process<\/span>(<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0taskId<\/span>(\"cancel\"<\/span>, appName<\/span>, id<\/span>),<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0new<\/span> InstanceReplicationTask<\/span>(targetHost<\/span>, Action<\/span>.Cancel<\/span>, appName<\/span>, id<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@Override<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0public<\/span> EurekaHttpResponse<\/span><<\/span>Void<\/span>><\/span> execute<\/span>() {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0return<\/span> replicationClient<\/span>.cancel<\/span>(appName<\/span>, id<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n\u200b<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0@Override<\/span><\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0public<\/span> void<\/span> handleFailure<\/span>(int<\/span> statusCode<\/span>, Object<\/span> responseEntity<\/span>) throws<\/span> Throwable<\/span> {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0super<\/span>.handleFailure<\/span>(statusCode<\/span>, responseEntity<\/span>);<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0if<\/span> (statusCode<\/span> ==<\/span> 404<\/span>) {<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0logger<\/span>.warn<\/span>(\"{}: missing entry.\"<\/span>, getTaskName<\/span>());<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0 \u00a0  }<\/span>\r\n \u00a0 \u00a0 \u00a0  },<\/span>\r\n \u00a0 \u00a0 \u00a0 \u00a0expiryTime<\/span><\/span>\r\n \u00a0  );<\/span>\r\n}<\/span><\/pre>\n
                       \u901a\u8fc7Eureka Server\u5728\u542f\u52a8\u8fc7\u7a0b\u4e2d\u521d\u59cb\u5316\u672c\u5730\u6ce8\u518c\u8868\u4fe1\u606f\u548cEureka Server\u96c6\u7fa4\u95f4\u7684\u540c\u6b65\u590d\u5236\u64cd\u4f5c\uff0c\u6700\u7ec8\u8fbe\u5230\u4e86\u96c6\u7fa4\u4e2dEureka Server\u6ce8\u518c\u8868\u4fe1\u606f\u4e00\u81f4\u7684\u76ee\u7684\u3002<\/span><\/p>\n
                      \u83b7\u53d6\u6ce8\u518c\u8868\u4e2d\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f<\/span><\/h3>\n
                      Eureka Server\u4e2d\u83b7\u53d6\u6ce8\u518c\u8868\u7684\u670d\u52a1\u5b9e\u4f8b\u4fe1\u606f\u4e3b\u8981\u901a\u8fc7\u4e24\u4e2a\u65b9\u6cd5\u5b9e\u73b0\uff1a<\/span><\/p>\n