http://blog.csdn.net/lululove19870526/article/details/53101490

http://colobu.com/2016/12/04/smooth-weighted-round-robin-algorithm/


                                                          负载均衡之权重轮询调度算法

一、负载均衡

    nginx不单可以作为强大的web服务器，也可以作为一个反向***服务器。如果nginx是以反向***的形式配置运行，那么对请求的实际处理需要转发到后端服务器运行，如果后端服务器有多台，如何选择一台合适的后端服务器来处理当前请求，这就是负载均衡

二、nginx负载均衡策略之round_robin

    round_robin策略做为默认策略：每个请求按时间顺序逐一分配到不同的后端服务器，如果后端服务器down掉，能自动剔除。

   例如 

[html]  view plain  copy
  1. upstream tomcats {  
  2. server 10.1.1.107:88  max_fails=3 fail_timeout=3s weight=1;  
  3. server 10.1.1.132:80  max_fails=3 fail_timeout=3s weight=2;  
  4. }  

   功能：nginx在用作反向***服务器时，对于后端的服务器可以采用两种分流策略：加权分流和ip hash。nginx默认采用round_robin加权算法:对于权重较高的机器，被选中的概率大，对于权重相同的机器，则采用轮询方式。上面的这个配置，如果的3个请求，则会有1个请求分发到10.1.1.107服务器上，2个请求分发到10.1.1.132服务器上。

三、轮询调度算法(Round-Robin Scheduling)

       轮询调度算法的原理是每一次把来自用户的请求轮流分配给内部中的服务器，从1开始，直到N(内部服务器个数)，然后重新开始循环。
      轮询调度算法假设所有服务器的处理性能都相同，不关心每台服务器的当前连接数和响应速度。当请求服务间隔时间变化比较大时，轮询调度算法容易导致服务器间的负载不平衡。所以此种均衡算法适合于服务器组中的所有服务器都有相同的软硬件配置并且平均服务请求相对均衡的情况。

四、权重轮询调度算法(Weighted Round-Robin Scheduling)

        上面所讲的轮询调度算法并没有考虑每台服务器的处理能力，在实际情况中，可能并不是这种情况。由于每台服务器的配置、安装的业务应用等不同，其处理能力会不一样。所以，我们根据服务器的不同处理能力，给每个服务器分配不同的权值，使其能够接受相应权值数的服务请求。

      1.权重轮询调度算法流程

         假设有一组服务器S = {S0, S1, …, Sn-1}，W(Si)表示服务器Si的权值，一个指示变量i表示上一次选择的服务器，指示变量cw表示当前调度的权值，max(S)表示集合S中所有服务器的最大权值，gcd(S)表示集合S中所有服务器权值的最大公约数。变量i初始化为-1，cw初始化为零。其算法如下

         

[java]  view plain  copy
  1. while (true) {  
  2.   
  3.   i = (i + 1) mod n;  
  4.   
  5.   if (i == 0) {  
  6.   
  7.      cw = cw - gcd(S);  
  8.   
  9.      if (cw <= 0) {  
  10.   
  11.        cw = max(S);  
  12.   
  13.        if (cw == 0)  
  14.   
  15.          return NULL;  
  16.   
  17.      }  
  18.   
  19.   }  
  20.   
  21.   if (W(Si) >= cw)  
  22.   
  23.     return Si;  
  24.   
  25. }  

    2.Java代码实现

       

[java]  view plain  copy
  1. import java.util.ArrayList;  
  2. import java.util.List;  
  3.   
  4. public class WeightRoundRobin {  
  5.       
  6.     /**上次选择的服务器*/    
  7.     private int currentIndex = -1;    
  8.     /**当前调度的权值*/    
  9.     private int currentWeight = 0;    
  10.     /**最大权重*/    
  11.     private int maxWeight;    
  12.     /**权重的最大公约数*/    
  13.     private int gcdWeight;    
  14.     /**服务器数*/    
  15.     private int serverCount;    
  16.     private List<Server> servers = new ArrayList<Server>();   
  17.       
  18.     /* 
  19.      * 得到两值的最大公约数 
  20.      */  
  21.     public int greaterCommonDivisor(int a, int b){    
  22.         if(a % b == 0){  
  23.             return b;  
  24.         }else{  
  25.             return greaterCommonDivisor(b,a % b);  
  26.         }  
  27.     }  
  28.     /* 
  29.      * 得到list中所有权重的最大公约数，实际上是两两取最大公约数d，然后得到的d 
  30.      * 与下一个权重取最大公约数，直至遍历完 
  31.      */  
  32.     public int greatestCommonDivisor(List<Server> servers){    
  33.         int divisor = 0;    
  34.         for(int index = 0, len = servers.size(); index < len - 1; index++){    
  35.             if(index ==0){    
  36.                 divisor = greaterCommonDivisor(    
  37.                             servers.get(index).getWeight(), servers.get(index + 1).getWeight());    
  38.             }else{    
  39.                 divisor = greaterCommonDivisor(divisor, servers.get(index).getWeight());    
  40.             }    
  41.         }    
  42.         return divisor;    
  43.     }  
  44.       
  45.     /* 
  46.      * 得到list中的最大的权重 
  47.      */  
  48.     public int greatestWeight(List<Server> servers){    
  49.         int weight = 0;    
  50.         for(Server server : servers){    
  51.             if(weight < server.getWeight()){    
  52.                 weight = server.getWeight();    
  53.             }    
  54.         }    
  55.         return weight;    
  56.     }  
  57.       
  58.     /**  
  59.      *  算法流程：   
  60.      *  假设有一组服务器 S = {S0, S1, …, Sn-1}  
  61.      *  有相应的权重，变量currentIndex表示上次选择的服务器  
  62.      *  权值currentWeight初始化为0，currentIndex初始化为-1 ，当第一次的时候返回 权值取最大的那个服务器，  
  63.      *  通过权重的不断递减 寻找 适合的服务器返回 
  64.      */    
  65.      public Server getServer(){    
  66.          while(true){    
  67.              currentIndex = (currentIndex + 1) % serverCount;    
  68.              if(currentIndex == 0){    
  69.                  currentWeight = currentWeight - gcdWeight;    
  70.                  if(currentWeight <= 0){    
  71.                      currentWeight = maxWeight;    
  72.                      if(currentWeight == 0){    
  73.                          return null;    
  74.                      }    
  75.                  }    
  76.              }    
  77.              if(servers.get(currentIndex).getWeight() >= currentWeight){    
  78.                  return servers.get(currentIndex);    
  79.              }    
  80.          }    
  81.      }   
  82.        
  83.      public void init(){    
  84.          servers.add(new Server("192.168.191.1", 1));    
  85.          servers.add(new Server("192.168.191.2", 2));    
  86.          servers.add(new Server("192.168.191.4", 4));    
  87.          servers.add(new Server("192.168.191.8", 8));    
  88.           
  89.              
  90.          maxWeight = greatestWeight(servers);    
  91.          gcdWeight = greatestCommonDivisor(servers);    
  92.          serverCount = servers.size();    
  93.      }    
  94.        
  95.      public static void main(String args[]){  
  96.           WeightRoundRobin weightRoundRobin = new WeightRoundRobin();    
  97.           weightRoundRobin.init();    
  98.               
  99.           for(int i = 0; i < 15; i++){    
  100.               Server server = weightRoundRobin.getServer();    
  101.               System.out.println("server " + server.getIp() + " weight=" + server.getWeight());    
  102.           }    
  103.      }  
  104.   
  105. }  
  106.   
  107. class Server{    
  108.      private String ip;    
  109.      private int weight;    
  110.        
  111.      public Server(String ip, int weight) {    
  112.          this.ip = ip;    
  113.          this.weight = weight;    
  114.      }  
  115.   
  116.     public String getIp() {  
  117.         return ip;  
  118.     }  
  119.   
  120.     public void setIp(String ip) {  
  121.         this.ip = ip;  
  122.     }  
  123.   
  124.     public int getWeight() {  
  125.         return weight;  
  126.     }  
  127.   
  128.     public void setWeight(int weight) {  
  129.         this.weight = weight;  
  130.     }    
  131.        
  132. }  
运行结果：

server 192.168.191.8 weight=8
server 192.168.191.8 weight=8
server 192.168.191.8 weight=8
server 192.168.191.8 weight=8
server 192.168.191.4 weight=4
server 192.168.191.8 weight=8
server 192.168.191.4 weight=4
server 192.168.191.8 weight=8
server 192.168.191.2 weight=2
server 192.168.191.4 weight=4
server 192.168.191.8 weight=8
server 192.168.191.1 weight=1
server 192.168.191.2 weight=2
server 192.168.191.4 weight=4
server 192.168.191.8 weight=8