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

标签：集群   ribbon   wowza   负载均衡   架构   

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

# 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.OkToRetryOnAllOperations=true


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


# Connect timeout used by Apache HttpClient
sample-client.ribbon.ConnectTimeout=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

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
}

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

• https://github.com/netflix/ribbon/wiki
• https://github.com/Netflix/ribbon/wiki/Getting-Started
• https://github.com/Netflix/ribbon/wiki/Programmers-Guide

云中间层服务 - 区域感知负载负载均衡器 Ribbon,布布扣,bubuko.com

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

标签：集群   ribbon   wowza   负载均衡   架构   

原文地址：http://blog.csdn.net/defonds/article/details/32729155