Nginxポーリングアルゴリズムの基本的な実装方法の詳細な説明

パブリッククラスSimplePolling {

  /**
   * キーはip
   */
  パブリック静的リスト <String> ipService = 新しい LinkedList <>();
  静的{
    ipService.add("192.168.1.1");
    ipService.add("192.168.1.2");
    ipService.add("192.168.1.3");
  }
  パブリック静的int pos = 0;
  パブリック静的文字列 getIp(){
    if(pos >= ipService.size()){
      //インデックスが範囲外にならないようにする pos = 0;
    }
    文字列 ip = ipService.get(pos);
    位置++;
    IP を返します。

  }

  パブリック静的voidメイン(String[] args) {
    (int i = 0; i < 4; i++) の場合 {
      System.out.println(getIp());

    }
  }
}

パブリッククラス WeightPolling {

  /**
   * キーは ip、値は weight*/
  パブリック静的 Map<String, Integer> ipService = new LinkedHashMap<>();
  静的{
    ipService.put("192.168.1.1", 5);
    ipService.put("192.168.1.2", 1);
    ipService.put("192.168.1.3", 1);
  }
  パブリック静的intリクエストId = 0;
  パブリック静的int getAndIncrement() {
    requestId++ を返します。
  }

  パブリック静的文字列 getIp(){
    // 総重量を取得します int totalWeight =0;
    (整数値: ipService.values()) {
      合計重量+=値;
    }
    //現在のポーリング値を取得します int andIncrement = getAndIncrement();
    int pos = andIncrement% totalWeight;
    (文字列ip:ipService.keySet()) {
      ipService.get(ip) が pos より小さい場合
        IP を返します。
      }
      pos -= ipService.get(ip);
    }
    null を返します。
  }

  パブリック静的voidメイン(String[] args) {
    (int i = 0; i < 7; i++) の場合 {
      System.out.println(getIp());
    }
  }

}

パブリッククラスポーリング{

  /**
   * キーは ip、値は weight*/
  パブリック静的 Map<String,Integer> ipService = new LinkedHashMap<>();
  静的{
    ipService.put("192.168.1.1",5);
    ipService.put("192.168.1.2",1);
    ipService.put("192.168.1.3",1);
  }
  プライベート静的 Map<String,Weight> weightMap = new LinkedHashMap <>();

  パブリック静的文字列 getIp(){
    // 総重量を計算します int totalWeight = 0;
    (整数値: ipService.values()) {
      合計重量+=値;
    }
    //まずweightMapが空かどうかを判定します。if (weightMap.isEmpty()) {
      ipService.forEach((ip,weight)->{
        重み weights = new Weight(ip, weight,0);
        weightMap.put(ip,weights);
      });
    }
    //マップ内のオブジェクトの現在の重みを設定します weightMap.forEach((ip,weight)->{
      weight.setCurrentWeight(weight.getWeight() + weight.getCurrentWeight());
    });

    // 最大重量が現在の重量より大きいかどうかを判断します。空または現在の重量より小さい場合は、現在の重量を最大重量に割り当てます。 Weight maxWeight = null;
    (重量 weight : weightMap.values()) の場合 {
      if(maxWeight == null || weight.getCurrentWeight() > maxWeight.getCurrentWeight()){
        maxWeight = 重量;
      }
    }
    //最後に、現在の最大重量から合計重量を減算します。maxWeight.setCurrentWeight(maxWeight.getCurrentWeight() - totalWeight);
    //戻り値 maxWeight.getIp();
  }

  パブリック静的voidメイン(String[] args) {
    //IPを取得するために7回のポーリングをシミュレートする
    (int i = 0; i < 7; i++) の場合 {
      System.out.println(getIp());
    }
  }

}

クラス ウェイト{
  /**
   * IPアドレス
   */
  プライベート文字列 ip;
  /**
   * 重量を設定する */
  プライベート int 重み;
  /**
   * 現在の体重 */
  プライベート int 現在の重量;

  パブリックウェイト(文字列ip、intウェイト、int現在のウェイト) {
    ip は ip です。
    this.weight = 重量;
    this.currentWeight = 現在の重量;
  }

  パブリック文字列 getIp() {
    IP を返します。
  }

  パブリック void setIp(String ip) {
    ip は ip です。
  }

  パブリック int getWeight() {
    重量を返します。
  }

  パブリック void setWeight(int 重量) {
    this.weight = 重量;
  }

  パブリック int getCurrentWeight() {
    現在の重量を返します。
  }

  パブリック void setCurrentWeight(int currentWeight) {
    this.currentWeight = 現在の重量;
  }
}