云中间层服务 - 区域感知负载均衡器 Ribbon-摩杜云开发者社区

Ribbon 简介
Ribbon 是 Netflix 发布的云中间层服务开源项目，其主要功能是提供客户侧软件负载均衡算法，将 Netflix 的中间层服务连接在一起。
Why Ribbon？
Ribbon 的区域感知负载均衡器的功能久经考验。区域感知负载均衡器内置电路跳闸逻辑，可被配置基于区域同源关系（Zone Affinity，也就是更倾向于选择发出调用的服务所在的托管区域内，这样可用降低延迟，节省成本）选择目标服务实例。它监控每个区域中运行的实例的运维行为，而且能够实时快速丢弃一整个区域。在面对整个区域的故障时，这帮我们提升了弹性。简单的来说，在配置文件中列出LB后面所有的机器，ribbon 会自动帮你去连这些机器（基于某种规则，如随机连接、轮流连接，基于响应时间等等）。我们很方便地使用 Ribbon 实现自定义负载均衡算法。
Ribbon 的其他一些特性

发现服务，比如需要增加一些机器，可以实现 Ribbon 的一个接口将这个机器加到列表里(请参考《Ribbon 和 wowza 的集成开发》的动态修改负载节点案例)；
对 Cloud 平台的支持：比如对 AWS 来说，有参数支持只返回同一个 zone 的服务器地址，这样避免跨 zone 调用所引起的网络延时；
故障恢复能力：可以将一些不可用的服务器剔除。

Ribbon 架构图

云中间层服务 - 区域感知负载均衡器 Ribbon_负载均衡

Ribbon 时序图

云中间层服务 - 区域感知负载均衡器 Ribbon_负载均衡_02

如何使用 Ribbon？

Ribbon 提供了框架来支持通用的 LB 机制，同时也提供了对 Netflix eureka 框架的支持。接下来我们来看一下如何在 Java 项目里使用 Ribbon。

配置文件(sample-client.properties)

# Max number of retries on the same server (excluding the first try)
sample-client.ribbon.MaxAutoRetries=1


# Max number of next servers to retry (excluding the first server)
sample-client.ribbon.MaxAutoRetriesNextServer=1


# Whether all operations can be retried for this client
sample-client.ribbon.OkToRetryOnAllOperatinotallow=true


# Interval to refresh the server list from the source
sample-client.ribbon.ServerListRefreshInterval=2000


# Connect timeout used by Apache HttpClient
sample-client.ribbon.Cnotallow=3000


# Read timeout used by Apache HttpClient
sample-client.ribbon.ReadTimeout=3000


# Initial list of servers, can be changed via Archaius dynamic property at runtime
sample-client.ribbon.listOfServers=www.microsoft.com:80,www.yahoo.com:80,www.google.com:80

每个条目的格式是为

<clientName>.<nameSpace>.<propertyName>=<value>

clientName 将被接下来的工厂用于创建客户端。nameSpace 是可配置的，默认是 "ribbon"。常用属性名可以从 CommonClientConfigKey 获取。

这些属性也可以被定义作系统属性进行获取，也可以以 Archaius 加载的任何属性资源进行获取。

Java 代码测试

public static void main(String[] args) throws Exception {
      ConfigurationManager.loadPropertiesFromResources("sample-client.properties");  // 1
      System.out.println(ConfigurationManager.getConfigInstance().getProperty("sample-client.ribbon.listOfServers"));
      RestClient client = (RestClient) ClientFactory.getNamedClient("sample-client");  // 2
      HttpClientRequest request = HttpClientRequest.newBuilder().setUri(new URI("/")).build(); // 3
      for (int i = 0; i < 20; i++)  {
        HttpClientResponse response = client.executeWithLoadBalancer(request); // 4
        System.out.println("Status code for " + response.getRequestedURI() + "  :" + response.getStatus());
      }
      ZoneAwareLoadBalancer lb = (ZoneAwareLoadBalancer) client.getLoadBalancer();
      System.out.println(lb.getLoadBalancerStats());
      ConfigurationManager.getConfigInstance().setProperty(
          "sample-client.ribbon.listOfServers", "www.linkedin.com:80,www.google.com:80"); // 5
      System.out.println("changing servers ...");
      Thread.sleep(3000); // 6
      for (int i = 0; i < 20; i++)  {
        HttpClientResponse response = client.executeWithLoadBalancer(request);
        System.out.println("Status code for " + response.getRequestedURI() + "  : " + response.getStatus());
        response.releaseResources();
      }
      System.out.println(lb.getLoadBalancerStats()); // 7
}

代码解释：

使用 Archaius ConfigurationManager 加载属性；
使用 ClientFactory 创建客户端和负载均衡器；
使用 builder 构建 http 请求。注意我们只支持 URI 的 "/" 部分的路径，一旦服务器被负载均衡器选中，会由客户端计算出完整的 URI；
调用 API client.executeWithLoadBalancer()，不是 exeucte() API；
动态修正配置中的服务器池；
等待服务器列表刷新(配置文件中定义的刷新间隔是为 2 秒钟)；
打印出负载均衡器记录的服务器统计信息。

负载均衡器统计包含了很多用于监控的信息，可以用于负载均衡算法的输入。

关于 Ribbon 客户端使用的小 demo(包括 LB 调用、动态调整负载均衡节点)请参考博客《Ribbon 和 wowza 的集成开发》。

参考资料