服务实例关闭时更新服务状态

Question

我使用 Spring Cloud Feign 客户端实现了请求。我试过这个：

Feign 客户端：

@FeignClient(name = "mail-service")
public interface EmailClient {

    @RequestMapping(method = RequestMethod.POST, value = "/register")
    void setUserRegistration(RegisterUserDTO registerUserDTO);

    @RequestMapping(method = RequestMethod.POST, value = "/password_reset")
    void setUserPasswordReset(PasswordResetDTO passwordResetDTO);
}

Feign 配置：

@Configuration
public class LoadBalancerConfiguration {

    @Bean
    public ServiceInstanceListSupplier discoveryClientServiceInstanceListSupplier(ConfigurableApplicationContext context) {
        return ServiceInstanceListSupplier.builder()
                .withBlockingDiscoveryClient()
                .withSameInstancePreference()
                .withHealthChecks()
                .build(context);
    }
}

请求 DTO：

@Getter
@Setter
public class PasswordResetDTO {

    private int id;
}

控制器：

@Autowire
EmailClient emailClient;

@PostMapping("/dummy")
public ResponseEntity<?> test() {

    RegisterUserDTO obj = new RegisterUserDTO();
    obj.setId(12);

    emailClient.setUserRegistration(obj);

    return ok().build();
}

Feign 配置：

spring:
    cloud:
    loadbalancer:
        ribbon:
            enable: false
feign:
    client:
        config:
            default:
                connectTimeout: 5000
                readTimeout: 5000
                loggerLevel: basic
eureka:
    client:
        serviceUrl:
            defaultZone: ${EUREKA_URI:http://localhost:8761/eureka}
    instance:
        preferIpAddress: true

POM.xml

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-netflix-eureka-client</artifactId>
    </dependency>
    <dependency> 
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
    </dependency>

我启动了 3 个端点服务实例，这些服务以循环顺序从 Feign 客户端作为端点使用。到目前为止一切顺利，它按预期工作。但是，例如当我关闭第一个服务实例时，Feign 客户端不会收到此更改的通知，并继续向非活动服务发送请求。 你知道当端点服务关闭并且不在活动服务列表中时如何通知消费者服务吗？我想我需要配置一些健康检查？

你知道我该如何解决这个问题吗？

测试问题的源代码：https://github.com/rcbandit111/eureka-discovery-poc/tree/master

Answer 1

功能区 - 负载均衡器

它为您提供开箱即用的循环负载平衡，但您可以实现自己的@RibbonClient（即使对于特定服务）并设计您的自定义负载平衡，例如基于 eureka 元数据。负载平衡发生在客户端。

Feign - Http 客户端

使用@FeignClient，您可以为您的其他服务（或基础架构之外的服务）快速开发客户端。它与功能区和尤里卡集成，因此您可以参考您的服务@FeignClient(yourServiceNameInEureka)，您最终得到的是一个客户端，它使用您的首选逻辑在注册实例之间进行负载平衡。如果您使用的是 spring，您可以使用熟悉的 @RequestMapping 注解来描述您正在使用的端点。

我在下面提到了RandomRule 的例子。也可以查看 Github here 获取源代码。

@RibbonClient(name = "cloud-provider", configuration = CloudProviderConfiguration.class)
public class ConsumerApplication { 
    /* ... */
}

class CloudProviderConfiguration {
    @Bean
    public IRule ribbonRule(IClientConfig config) {
        return new RandomRule();
    }
}

另外，请参阅使用 Feign 设置 High Availability Load Balancer

Answer 2

根据documentation，当请求失败时，Ribbon 不会做任何事情来将服务器标记为关闭，而是依靠 ping 负载均衡器的服务器或客户端通过调用 markServerDown(Server server) 来通知 Ribbon。

因此，您应该通过提供自己的实现来更改功能区 ping 服务器的时间间隔：

public class CustomLoadBalancer {
  @Bean 
  public ILoadBalancer ribbonLoadBalancer(IClientConfig config,
                                          ServerList<Server> serverList, ServerListFilter<Server> serverListFilter,
                                          IRule rule, IPing ping) {
      return new ZoneAwareLoadBalancer<>(config, rule, ping, serverList, 
                                         serverListFilter, new PollingServerListUpdater(config));
  }
}

然后在你的 SpringBootApplication 配置中使用它，如下所示：

@RibbonClients(defaultConfiguration = CustomLoadBalancer.class)

或者您应该提供一个实现，以便在您认为合适的时候在您的客户端代码中调用功能区的markServerDown(Server) 方法。

我建议你阅读thisstackoverflow 的帖子，我认为与你的问题直接相关。