SpringCloud从零开始-微服务客户端-DiscoveryClient[EurekaClient]

科技2024-05-28 70

文章目录

说明遇到的问题项目结构POM内容application.yml访问http://127.0.0.1:8762/访问http://127.0.0.1:8761/ 试着跟踪一下客户端的心跳机制

说明

SpringBoot版本：2.3.4.RELEASE SpringCloud版本： Hoxton.SR8

遇到的问题

没有引入spring-boot-starter-web导致 com.netflix.discovery.DiscoveryClient : Completed shut down of DiscoveryClient 客户端启动失败

项目结构

POM内容

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>cn.xerbeauty</groupId> <artifactId>spring-cloud</artifactId> <version>0.0.1-SNAPSHOT</version> </parent> <artifactId>spring-cloud-eureka-client</artifactId> <version>0.0.1-SNAPSHOT</version> <name>spring-cloud-eureka-client</name> <description>SpringCloud 客户端</description> <properties> <java.version>1.8</java.version> <spring-cloud.version>Hoxton.SR8</spring-cloud.version> </properties> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency>      <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> <exclusions> <exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId> </exclusion> </exclusions> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>

application.yml

server: port: 10001 spring: application: name: EurekaClient-10001 profiles: active: 10001 cloud: loadbalancer: ribbon: enabled: false eureka: instance: appname: EurekaClient-10001 app-group-name: EurekaClientGroup_1 client: # register-with-eureka: true # 同时向两个注册中心去注册自己，但是我觉得这样有点问题，如果注册中心有不止两个，三个或者更多，这里岂不是要爆炸 # 如果有大佬知道这里怎么解决这个问题，请留言或者私聊我，感激不尽 //TODO: service-url: defaultZero: http://localhost:8761/eureka/,http://localhost:8762/eureka/

访问http://127.0.0.1:8762/

访问http://127.0.0.1:8761/

试着跟踪一下客户端的心跳机制

/Users/${user}/.m2/repository/org/springframework/cloud/spring-cloud-netflix-eureka-client/2.2.5.RELEASE/spring-cloud-netflix-eureka-client-2.2.5.RELEASE.jar!/META-INF/spring.factories org.springframework.boot.autoconfigure.EnableAutoConfiguration=\ org.springframework.cloud.netflix.eureka.config.EurekaClientConfigServerAutoConfiguration,\ org.springframework.cloud.netflix.eureka.config.DiscoveryClientOptionalArgsConfiguration,\ org.springframework.cloud.netflix.eureka.EurekaClientAutoConfiguration,\ org.springframework.cloud.netflix.ribbon.eureka.RibbonEurekaAutoConfiguration,\ org.springframework.cloud.netflix.eureka.EurekaDiscoveryClientConfiguration,\ org.springframework.cloud.netflix.eureka.reactive.EurekaReactiveDiscoveryClientConfiguration,\ org.springframework.cloud.netflix.eureka.loadbalancer.LoadBalancerEurekaAutoConfiguration org.springframework.cloud.bootstrap.BootstrapConfiguration=\ org.springframework.cloud.netflix.eureka.config.EurekaConfigServerBootstrapConfiguration

挨个儿点进去看实现，EurekaClientAutoConfiguration这个配置类好像是那么回事儿控制台出现最多的一个字眼 DiscoveryClient，再联系一下EurekaClientAutoConfiguration的内容

@EurekaClientAutoConfiguration.RefreshableEurekaClientConfiguration#eurekaClient @Configuration(proxyBeanMethods = false) @ConditionalOnRefreshScope protected static class RefreshableEurekaClientConfiguration { @Autowired private ApplicationContext context; @Autowired private AbstractDiscoveryClientOptionalArgs<?> optionalArgs; @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, @Autowired(required = false) HealthCheckHandler healthCheckHandler) { // If we use the proxy of the ApplicationInfoManager we could run into a // problem // when shutdown is called on the CloudEurekaClient where the // ApplicationInfoManager bean is // requested but wont be allowed because we are shutting down. To avoid this // we use the // object directly. ApplicationInfoManager appManager; if (AopUtils.isAopProxy(manager)) { appManager = ProxyUtils.getTargetObject(manager); } else { appManager = manager; } CloudEurekaClient cloudEurekaClient = new CloudEurekaClient(appManager, config, this.optionalArgs, this.context); // 注册健康检测语义化的命名真是太重要了 cloudEurekaClient.registerHealthCheck(healthCheckHandler); return cloudEurekaClient; } @Bean @ConditionalOnMissingBean(value = ApplicationInfoManager.class, search = SearchStrategy.CURRENT) @org.springframework.cloud.context.config.annotation.RefreshScope @Lazy public ApplicationInfoManager eurekaApplicationInfoManager( EurekaInstanceConfig config) { InstanceInfo instanceInfo = new InstanceInfoFactory().create(config); return new ApplicationInfoManager(config, instanceInfo); } @Bean @org.springframework.cloud.context.config.annotation.RefreshScope @ConditionalOnBean(AutoServiceRegistrationProperties.class) @ConditionalOnProperty( value = "spring.cloud.service-registry.auto-registration.enabled", matchIfMissing = true) public EurekaRegistration eurekaRegistration(EurekaClient eurekaClient, CloudEurekaInstanceConfig instanceConfig, ApplicationInfoManager applicationInfoManager, @Autowired( required = false) ObjectProvider<HealthCheckHandler> healthCheckHandler) { return EurekaRegistration.builder(instanceConfig).with(applicationInfoManager) .with(eurekaClient).with(healthCheckHandler).build(); } }

其实看到这里已经知道接下来的代码该怎么去看了。具体的详细的步骤，我也不是很清楚，慢慢看咯，这里给大家一个寻找工具核心代码的方法。请大佬点赞，谢谢！！！！！！！！！

Processed: 0.011, SQL: 8