微服务架构之均衡组件 Ribbon解析:服务列表

举报
qingting-fly 发表于 2021/08/06 00:15:37 2021/08/06
【摘要】 服务列表DomainExtractingServerList的getInitialListOfServers的实现十分简单,就是直接返回从Eureka中获取的服务器列表。@Overridepublic List<DiscoveryEnabledServer> getInitialListOfServers() { List<DiscoveryEnabledServer> server...

继续上一篇的文章,我们来介绍服务列表是如何获取与实现的。

RibbonClientConfiguration中默认配置的ServerListConfigurationBasedServerList。它是通过配置文件中的listOfServers属性来获取所有的服务器列表的。

DomainExtractingServerList类则是从Eureka服务注册中心中获取所有的server列表。EurekaRibbonClientConfiguration是针对Eureka自定义的Ribbon相关的配置类。包括了DomainExtractingServerList和我们之前讲解的NIWSDiscoveryPing

我们具体看下服务列表的实现。

服务列表

DomainExtractingServerListgetInitialListOfServers的实现十分简单,就是直接返回从Eureka中获取的服务器列表。

@Override
public List<DiscoveryEnabledServer> getInitialListOfServers() {
    List<DiscoveryEnabledServer> servers = setZones(this.list
            .getInitialListOfServers());
    return servers;
}

@Override
public List<DiscoveryEnabledServer> getUpdatedListOfServers() {
    List<DiscoveryEnabledServer> servers = setZones(this.list
            .getUpdatedListOfServers());
    return servers;
}
//添加zone相关的信息
private List<DiscoveryEnabledServer> setZones(List<DiscoveryEnabledServer> servers) {
    List<DiscoveryEnabledServer> result = new ArrayList<>();
    //判断是否secure和是否使用ip地址
    boolean isSecure = this.clientConfig.getPropertyAsBoolean(
            CommonClientConfigKey.IsSecure, Boolean.TRUE);
    boolean shouldUseIpAddr = this.clientConfig.getPropertyAsBoolean(
            CommonClientConfigKey.UseIPAddrForServer, Boolean.FALSE);
    for (DiscoveryEnabledServer server : servers) {
        result.add(new DomainExtractingServer(server, isSecure, shouldUseIpAddr,
                this.approximateZoneFromHostname));
    }
    return result;
}

服务列表过滤

ServerListFilter接口定义了可根据配置去过滤或者根据特性动态获取符合条件的server列表的方法,代码如下:

/**
 * 这个接口运行过滤候选的server
 */
public interface ServerListFilter<T extends Server> {
    public List<T> getFilteredListOfServers(List<T> servers);
}

ZonePreferenceServerListFilter是默认的ServerListFilter实现,它会优先选择本地的zone。

public List<Server> getFilteredListOfServers(List<Server> servers) {
    List<Server> output = super.getFilteredListOfServers(servers);
    if (this.zone != null && output.size() == servers.size()) {
        List<Server> local = new ArrayList<>();
        // 遍历整个server列表,只添加和本地zone相同的server
        for (Server server : output) {
            if (this.zone.equalsIgnoreCase(server.getZone())) {
                local.add(server);
            }
        }
        if (!local.isEmpty()) {
            return local;
        }
    }
    return output;
}

RibbonServerList是定义生成server列表的接口,用来通过各种途径获取负载均衡中的所有server列表。

小结

RibbonClientConfiguration中默认配置的ServerListConfigurationBasedServerList。它是通过配置文件中的listOfServers属性来获取所有的服务器列表的。

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。