netflix-eureka - 在 Eureka 中设置接受区域列表

Question

他们是在 Eureka 中忽略区域或定义可接受区域列表的方法，例如，如果我们有 3 个区域(office、shahbour、joe )

我希望区域 shahbour 中的服务仅使用 shahbour 中定义的主要服务和 office 中的次要服务，并忽略此区域中的所有其他区域示例 joe。

我尝试如下所示，它正在努力选择相同的区域，但如果它们在同一区域没有服务，它会在所有其他区域进行负载平衡

spring:
  profiles: shahbour
eureka:
  instance:
    metadataMap:
      zone: shahbour
  client:
    region: lebanon
    serviceUrl:
      defaultZone: http://office:8761/eureka/
    preferSameZoneEureka: true
    availabilityZones:
      lebanon: shahbour,office

我以为设置 availabilityZones 会设置这个，但事实并非如此。

这是针对开发环境的，我试图将每个开发人员设置为使用他的机器作为区域，如果服务不存在，则使用办公室服务器作为备份，但不要使用其他开发人员。

Answer 1

我没有在 eureka 中找到任何地方设置可接受的区域列表，但我发现我们可以在 Ribbon 中创建我们的自定义 ServerListFilter 用于Feign 和 Zuul 所以下面是代码

public class DevServerListFilter extends ZonePreferenceServerListFilter {

    private final List<String> acceptedZone = new ArrayList<>();

    public DevServerListFilter(String[] acceptedZones) {
        for (String zone: acceptedZones) {
            this.acceptedZone.add(zone);
        }
    }

    @Override
    public void initWithNiwsConfig(IClientConfig niwsClientConfig) {
        super.initWithNiwsConfig(niwsClientConfig);
    }

    @Override
    public List<Server> getFilteredListOfServers(List<Server> servers) {
        List<Server> zoneAffinityFiltered = super.getFilteredListOfServers(servers);
        Set<Server> candidates = Sets.newHashSet(zoneAffinityFiltered);
        Iterator serverIterator = candidates.iterator();
        while (serverIterator.hasNext()) {
            Server server = (Server)serverIterator.next();
            if(!acceptedZone.contains(server.getZone())) {
                zoneAffinityFiltered.remove(server);
            }

        }
        return zoneAffinityFiltered;
    }


} 

上面的过滤器扩展了 ZonePreferenceServerListFilter 以检查接受区域列表，任何不在此列表中的服务器都将被忽略。

@Configuration
@RibbonClients(defaultConfiguration = MyDefaultRibbonConfiguration.class)
public class MyRibbonConfiguration {
}

我所有客户端的默认配置

@Configuration
public class MyDefaultRibbonConfiguration {

//    @Bean
//    public IPing ribbonPing(IClientConfig config) {
//        return new PingUrl();
//    }

    @Bean
    public ServerListFilter<Server> ribbonServerListFilter(IClientConfig config,EurekaClientConfigBean eurekaClientConfigBean) {
        String[] availabilityZones = eurekaClientConfigBean.getAvailabilityZones(eurekaClientConfigBean.getRegion());

        DevServerListFilter filter = new DevServerListFilter(availabilityZones);
        filter.initWithNiwsConfig(config);
        return filter;
    }

}

配置代码，请注意，这必须位于 @ComponentScan 的排除路径中，作为 documents 中的请求，并且我使用了可用性区域属性，但可以使用任何列表。

github sample