17站長網(wǎng) › 首頁 ›網(wǎng)站› 服務(wù)器 › 查看內(nèi)容

Nginx輪詢算法底層實(shí)現(xiàn)的方法

2022-10-17 13:07| 查看: 1428 |來源: 互聯(lián)網(wǎng)

輪詢算法簡介在工作中很多人都使用到了nginx，對(duì)nginx得配置也是爛熟于心，今天我主要想介紹一下nginx輪詢算法得幾種底層實(shí)現(xiàn)方式。簡單輪詢算法這種算法 ...

輪詢算法簡介

在工作中很多人都使用到了nginx，對(duì)nginx得配置也是爛熟于心，今天我主要想介紹一下nginx輪詢算法得幾種底層實(shí)現(xiàn)方式。

簡單輪詢算法

這種算法比較簡單，舉個(gè)例子就是你有三臺(tái)服務(wù)器

第一臺(tái)服務(wù)器	192.168.1.1
第二臺(tái)服務(wù)器	192.168.1.2
第三臺(tái)服務(wù)器	192.168.1.3

第一個(gè)請(qǐng)求過來之后默認(rèn)訪問第一臺(tái)，第二個(gè)請(qǐng)求過來訪問第二臺(tái)，第三次請(qǐng)求過來訪問第三臺(tái)，第四次請(qǐng)求過來訪問第一臺(tái)，以此類推。以下是我代碼實(shí)現(xiàn)簡單得算法：

public class SimplePolling {

  /**
   * key是ip
   */
  public static List
ipService = new LinkedList <>();
  static {
    ipService.add("192.168.1.1");
    ipService.add("192.168.1.2");
    ipService.add("192.168.1.3");
  }
  public static int pos = 0;
  public static String getIp(){
    if(pos >= ipService.size()){
      //防止索引越界
      pos = 0;
    }
    String ip = ipService.get(pos);
    pos ++;
    return ip;

  }

  public static void main(String[] args) {
    for (int i = 0; i < 4; i++) {
      System.out.println(getIp());

    }
  }
}

模擬執(zhí)行4次執(zhí)行結(jié)果是

在這里插入圖片描述

此時(shí)如果我有一臺(tái)服務(wù)器性能比較好（比如192.168.1.1），我想讓這臺(tái)服務(wù)器處理多一點(diǎn)請(qǐng)求，此時(shí)就涉及到了權(quán)重得概率，這種算法就不能實(shí)現(xiàn)，請(qǐng)看我后面描述的輪詢升級(jí)版算法。

加權(quán)輪詢算法

此時(shí)我需要把我前面3臺(tái)服務(wù)器都設(shè)置權(quán)重，比如第一臺(tái)設(shè)置5，第二臺(tái)設(shè)置1，第三臺(tái)設(shè)置1

第一臺(tái)服務(wù)器	192.168.1.1	5
第二臺(tái)服務(wù)器	192.168.1.2	1
第三臺(tái)服務(wù)器	192.168.1.3	1

此時(shí)前5個(gè)請(qǐng)求都會(huì)訪問到第一臺(tái)服務(wù)器，第六個(gè)請(qǐng)求會(huì)訪問到第二臺(tái)服務(wù)器，第七個(gè)請(qǐng)求會(huì)訪問到第三臺(tái)服務(wù)器。

以下是我給出的代碼案例：

public class WeightPolling {

  /**
   * key是ip,value是權(quán)重
   */
  public static Map
ipService = new LinkedHashMap<>();
  static {
    ipService.put("192.168.1.1", 5);
    ipService.put("192.168.1.2", 1);
    ipService.put("192.168.1.3", 1);
  }
  public static int requestId = 0;
  public static int getAndIncrement() {
    return requestId++;
  }

  public static String getIp(){
    //獲取總的權(quán)重
    int totalWeight =0;
    for (Integer value : ipService.values()) {
      totalWeight+= value;
    }
    //獲取當(dāng)前輪詢的值
    int andIncrement = getAndIncrement();
    int pos = andIncrement% totalWeight;
    for (String ip : ipService.keySet()) {
      if(pos < ipService.get(ip)){
        return ip;
      }
      pos -= ipService.get(ip);
    }
    return null;
  }

  public static void main(String[] args) {
    for (int i = 0; i < 7; i++) {
      System.out.println(getIp());
    }
  }

}

此時(shí)運(yùn)行結(jié)果是

在這里插入圖片描述

可以看的第一臺(tái)服務(wù)器執(zhí)行了5次，后面2臺(tái)依次執(zhí)行一次，依次類推�？赡苣阌X得這種算法還不錯(cuò)。其實(shí)這種算法有一個(gè)缺點(diǎn)是，如果我第一臺(tái)服務(wù)器設(shè)置權(quán)重過大可能我需要很多次請(qǐng)求都執(zhí)行到第一臺(tái)服務(wù)器上去，這樣的情況分布是不均勻的，會(huì)造成某一臺(tái)服務(wù)器壓力過大導(dǎo)致崩潰。所以我后面要引入第三種算法來解決這個(gè)問題

平滑加權(quán)輪詢算法

這種算法可能比較復(fù)雜，我第一次看也有點(diǎn)不太明白，后面看過相關(guān)資料在結(jié)合我自己的理解給大家圖文解釋一下，這里我舉例的服務(wù)器配置和權(quán)重還是和上面一樣

請(qǐng)求	當(dāng)前權(quán)重 = 自身權(quán)重+選中后當(dāng)前權(quán)重	總權(quán)重	當(dāng)前最大權(quán)重	返回的ip	選中后當(dāng)前權(quán)重=當(dāng)前最大權(quán)重-總權(quán)重
1	{5,1,1}	7	5	192.168.1.1	{-2,1,1}
2	{3,2,2}	7	3	192.168.1.1	{-4,2,2}
3	{1,3,3}	7	3	192.168.1.2	{1,-4,3}
4	{6,-3,4}	7	6	192.168.1.1	{-1,-3,4}
5	{4,-2,5}	7	5	192.168.1.3	{4,-2,-2}
6	{9,-1,-1}	7	9	192.168.1.1	{2,-1,-1}
7	{7,0,0}	7	7	192.168.1.1	{0,0,0}

由上圖可以看出第一臺(tái)服務(wù)器雖然權(quán)重設(shè)置的是5，但并不是第五次請(qǐng)求過來都是第一臺(tái)服務(wù)器執(zhí)行，而是分散執(zhí)行，調(diào)度序列是非常均勻的，且第 7 次調(diào)度時(shí)選中后當(dāng)前權(quán)重又回到 {0, 0, 0}，實(shí)例的狀態(tài)同初始狀態(tài)一致，所以后續(xù)可以一直重復(fù)調(diào)度操作。

可能有的人還不能清楚的明白上一張圖表示的含義，我這里大概描述一下：

1.首先總權(quán)重不會(huì)變，默認(rèn)就是當(dāng)前設(shè)置的權(quán)重之和

2.在第一次請(qǐng)求進(jìn)來的時(shí)候我默認(rèn)初始化當(dāng)前權(quán)重選中值是{0,0,0},所以當(dāng)前權(quán)重的值就是{5+0,1+0,1+0},這里的5,1,1就是我們前面每臺(tái)服務(wù)器設(shè)置的權(quán)重。

3.這里我們可以得出第一次請(qǐng)求過來的最大權(quán)重是5。然后返回第一臺(tái)服務(wù)器ip

4.然后我們?cè)O(shè)置選中后當(dāng)前權(quán)重，這里就是當(dāng)前最大權(quán)重減去總權(quán)重(5-7)，沒有選中的權(quán)重不變，這時(shí)候得到當(dāng)前權(quán)重選中權(quán)重的值{5-7,1,1}

5.在第二次請(qǐng)求過來的時(shí)候我們延續(xù)上面的2,3,4步驟執(zhí)行.

如果這里還有不懂得我下面會(huì)提供我自己用java代碼實(shí)現(xiàn)的算法：

public class Polling {

  /**
   * key是ip,value是權(quán)重
   */
  public static Map
ipService = new LinkedHashMap <>();
  static {
    ipService.put("192.168.1.1",5);
    ipService.put("192.168.1.2",1);
    ipService.put("192.168.1.3",1);
  }
  private static Map
weightMap = new LinkedHashMap <>();

  public static String getIp(){
    //計(jì)算總的權(quán)重
     int totalWeight = 0;
    for (Integer value : ipService.values()) {
      totalWeight+=value;
    }
    //首先判斷weightMap是否為空
    if(weightMap.isEmpty()){
      ipService.forEach((ip,weight)->{
        Weight weights = new Weight(ip, weight,0);
        weightMap.put(ip,weights);
      });
    }
    //給map中得對(duì)象設(shè)置當(dāng)前權(quán)重
    weightMap.forEach((ip,weight)->{
      weight.setCurrentWeight(weight.getWeight() + weight.getCurrentWeight());
    });

    //判斷最大權(quán)重是否大于當(dāng)前權(quán)重,如果為空或者小于當(dāng)前權(quán)重，則把當(dāng)前權(quán)重賦值給最大權(quán)重
    Weight maxWeight = null;
    for (Weight weight : weightMap.values()) {
      if(maxWeight ==null || weight.getCurrentWeight() > maxWeight.getCurrentWeight()){
        maxWeight = weight;
      }
    }
    //最后把當(dāng)前最大權(quán)重減去總的權(quán)重
    maxWeight.setCurrentWeight(maxWeight.getCurrentWeight() - totalWeight);
    //返回
    return maxWeight.getIp();
  }

  public static void main(String[] args) {
    //模擬輪詢7次取ip
    for (int i = 0; i < 7; i++) {
      System.out.println(getIp());
    }
  }

}

class Weight{
  /**
   * ip
   */
  private String ip;
  /**
   * 設(shè)置得權(quán)重
   */
  private int weight;
  /**
   * 當(dāng)前權(quán)重
   */
  private int currentWeight;

  public Weight(String ip, int weight,int currentWeight) {
    this.ip = ip;
    this.weight = weight;
    this.currentWeight = currentWeight;
  }

  public String getIp() {
    return ip;
  }

  public void setIp(String ip) {
    this.ip = ip;
  }

  public int getWeight() {
    return weight;
  }

  public void setWeight(int weight) {
    this.weight = weight;
  }

  public int getCurrentWeight() {
    return currentWeight;
  }

  public void setCurrentWeight(int currentWeight) {
    this.currentWeight = currentWeight;
  }
}

這里代碼得執(zhí)行結(jié)果是：

在這里插入圖片描述

可以看出此處執(zhí)行結(jié)果和表格里描述得結(jié)果一致。

總結(jié)

可能第三種算法理解起來有點(diǎn)復(fù)雜，如果看不懂圖表得意思可以先執(zhí)行下代碼，debugger一步步調(diào)試后還是很好理解。

以上Nginx輪詢算法底層實(shí)現(xiàn)的方法就是小編為大家收集整理的全部內(nèi)容了，希望對(duì)大家有所幫助。如果您喜歡這篇文章，可以收藏或分享給您的小伙伴們吧！歡迎持續(xù)關(guān)注我們的后續(xù)更新。

本文最后更新于 2022-10-17 13:07，某些文章具有時(shí)效性，若有錯(cuò)誤或已失效，請(qǐng)?jiān)诰W(wǎng)站留言或聯(lián)系站長：17tui@17tui.com

·END·

站長網(wǎng)微信號(hào)：w17tui，關(guān)注站長、創(chuàng)業(yè)、關(guān)注互聯(lián)網(wǎng)人 - 互聯(lián)網(wǎng)創(chuàng)業(yè)者營銷服務(wù)中心

免責(zé)聲明：本站部分文章和圖片均來自用戶投稿和網(wǎng)絡(luò)收集，旨在傳播知識(shí)，文章和圖片版權(quán)歸原作者及原出處所有，僅供學(xué)習(xí)與參考，請(qǐng)勿用于商業(yè)用途，如果損害了您的權(quán)利，請(qǐng)聯(lián)系我們及時(shí)修正或刪除。謝謝！

下一篇：Docker Volumn容器間共享數(shù)據(jù)的實(shí)現(xiàn)上一篇：linux環(huán)境下時(shí)區(qū)無法設(shè)置問題如何解決

17站長網(wǎng)微信二維碼

始終以前瞻性的眼光聚焦站長、創(chuàng)業(yè)、互聯(lián)網(wǎng)等領(lǐng)域，為您提供最新最全的互聯(lián)網(wǎng)資訊，幫助站長轉(zhuǎn)型升級(jí)，為互聯(lián)網(wǎng)創(chuàng)業(yè)者提供更加優(yōu)質(zhì)的創(chuàng)業(yè)信息和品牌營銷服務(wù)，與站長一起進(jìn)步！讓互聯(lián)網(wǎng)創(chuàng)業(yè)者不再孤獨(dú)！

掃一掃，關(guān)注站長網(wǎng)微信

亚洲国产精品人久久,亚洲va国产日韩欧美精品色婷婷,久久久久88色偷偷,免费人成黄页在线观看国际

Nginx輪詢算法底層實(shí)現(xiàn)的方法

大家都在看

相關(guān)分類

熱門排行

最近更新