问题描述
我想通过 spring-cloud-starter-loadbalancer
使用 Eureka 客户端。但是当我添加配置时出现错误。当我删除 @LoadBalancerClient(name = "mail-service",configuration = LoadBalancerConfiguration.class)
和 LoadBalancerConfiguration
类配置时,它工作正常。我试过这个代码:
@FeignClient(name = "mail-service")
@LoadBalancerClient(name = "mail-service",configuration = LoadBalancerConfiguration.class)
public interface EmailClient {
@RequestMapping(method = RequestMethod.POST,value = "/engine/emails/register")
void setUserRegistration(createuserDTO createuserDTO);
}
@Configuration
public class LoadBalancerConfiguration {
@Bean
public ServiceInstanceListsupplier discoveryClientServiceInstanceListsupplier(ConfigurableApplicationContext context) {
return ServiceInstanceListsupplier.builder()
.withBlockingdiscoveryClient()
.withSameInstancePreference()
.withHealthChecks()
.build(context);
}
}
application.yml:
feign:
client:
config:
default:
connectTimeout: 5000
readTimeout: 5000
loggerLevel: basic
eureka:
client:
serviceUrl:
defaultZone: ${EUREKA_URI:http://localhost:8761/eureka}
fetchRegistry: true
healthcheck:
enabled: true
instance:
preferIpAddress: true
leaserenewalIntervalInSeconds: 10
POM.xml 依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>com.netflix.eureka</groupId>
<artifactId>eureka-core</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
[503] during [POST] to [http://mail-service/engine/emails/register] [EmailClient#setUserRegistration(createuserDTO)]: [Load balancer does not contain an instance for the service mail-service]
我使用 Release Train 版本:2020.0.3
你知道可能是什么问题吗?
解决方法
任何使用负载均衡器的应用程序都应遵循以下顺序
- 启动 Eureka 服务器
- 一一启动有依赖的Service实例
任何应用程序都依赖于来自服务注册中心(即 Eureka)的信息。在应用程序通过 serviceId 向其实例注册之前,Eureka 服务器将无法在负载平衡时选择该实例。
在您共享的代码中,bean ServiceInstanceListSupplier 与健康检查 ( .withHealthChecks() ) 一起在配置类中创建。这会导致应用程序失败,因为服务尚未注册。
此外,LoadBalancer 配置不应该在@Configuration 注释的类中,而应该是通过@LoadBalancerClient 或@LoadBalancerClients 注释传递给配置的类,如here 所述。
唯一需要实例化的 bean 是 ServiceInstanceListSupplier(如果添加 spring-cloud-starter-loadbalancer,LoadBalancerClientFactory 等将由 starter 本身实例化)。
所以你的 LoadBalancer 配置类应该看起来像下面的代码。 它不应该在 @Configuration 类中:
public class LoadBalancerConfiguration {
@Bean
public ServiceInstanceListSupplier instanceSupplier(ConfigurableApplicationContext context) {
return ServiceInstanceListSupplier.builder()
.withDiscoveryClient()
.withHealthChecks()
.build(context);
}
}
如本 link 中所述,实际的 @Configuration 类将具有以下注释:@LoadBalancerClients(defaultConfiguration = LoadBalancerConfiguration .class).
然后,如果您在实例中启用健康检查,它应该可以正常工作。