首頁 Java java教程 Java實作負載平衡的幾種演算法

Java實作負載平衡的幾種演算法

Feb 27, 2017 pm 04:13 PM
負載平衡

這篇文章主要介紹了詳解Java實現負載平衡的幾種演算法程式碼 ,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟著小編過來看看吧

這篇文章主要介紹Java實作負載平衡的幾個演算法,具體如下:

輪詢:


package class2.zookeeper.loadbalance;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;

/**
 * 負載均衡算法,輪詢法
 * @author guoy
 *
 */
public class TestRoundRobin {

  
  static Map<String,Integer> serverWeigthMap = new HashMap<String,Integer>();

   static{
    serverWeigthMap.put("192.168.1.12", 1);
    serverWeigthMap.put("192.168.1.13", 1);
    serverWeigthMap.put("192.168.1.14", 2);
    serverWeigthMap.put("192.168.1.15", 2);
    serverWeigthMap.put("192.168.1.16", 3);
    serverWeigthMap.put("192.168.1.17", 3);
    serverWeigthMap.put("192.168.1.18", 1);
    serverWeigthMap.put("192.168.1.19", 2);
  }
   Integer pos = 0;
   public String roundRobin()
    {
      //重新建立一個map,避免出現由於服務器上線和下線導致的並發問題
      Map<String,Integer> serverMap = new HashMap<String,Integer>();
      serverMap.putAll(serverWeigthMap);
      //獲取ip列表list
      Set<String> keySet = serverMap.keySet();
      ArrayList<String> keyList = new ArrayList<String>();
      keyList.addAll(keySet);
      
      String server = null;
      
      synchronized (pos) {
        if(pos >=keySet.size()){
          pos = 0;
        }
        server = keyList.get(pos);
        pos ++;
      }
      return server;
    }
    
    public static void main(String[] args) {
      TestRoundRobin robin = new TestRoundRobin();
      for (int i = 0; i < 20; i++) {
        String serverIp = robin.roundRobin();
        System.out.println(serverIp);
      }
    }
}
登入後複製


加權輪詢:


package class2.zookeeper.loadbalance;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.Set;

/**
 * 加權隨機载均衡算法
 * @author guoy
 *
 */
public class TestWeightRandom {
  
  static Map<String,Integer> serverWeigthMap = new HashMap<String,Integer>();

   static{
    serverWeigthMap.put("192.168.1.12", 1);
    serverWeigthMap.put("192.168.1.13", 1);
    serverWeigthMap.put("192.168.1.14", 2);
    serverWeigthMap.put("192.168.1.15", 2);
    serverWeigthMap.put("192.168.1.16", 3);
    serverWeigthMap.put("192.168.1.17", 3);
    serverWeigthMap.put("192.168.1.18", 1);
    serverWeigthMap.put("192.168.1.19", 2);
  }

  public static String weightRandom()
  {
    //重新建立一個map,避免出現由於服務器上線和下線導致的並發問題
    Map<String,Integer> serverMap = new HashMap<String,Integer>();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set<String> keySet = serverMap.keySet();
    Iterator<String> it = keySet.iterator();

    List<String> serverList = new ArrayList<String>();

    while (it.hasNext()) {
      String server = it.next();
      Integer weight = serverMap.get(server);
      for (int i = 0; i < weight; i++) {
        serverList.add(server);
      }
    }    
    Random random = new Random();
    int randomPos = random.nextInt(serverList.size());
    
    String server = serverList.get(randomPos);
    return server;
  }
  
  public static void main(String[] args) {
    String serverIp = weightRandom();
    System.out.println(serverIp);
  }
}
登入後複製
登入後複製







##隨機:



package class2.zookeeper.loadbalance;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import java.util.Set;

/**
 * 隨機负载均衡算法
 * @author guoy
 *
 */
public class TestRandom {
  
  static Map<String,Integer> serverWeigthMap = new HashMap<String,Integer>();

   static{
    serverWeigthMap.put("192.168.1.12", 1);
    serverWeigthMap.put("192.168.1.13", 1);
    serverWeigthMap.put("192.168.1.14", 2);
    serverWeigthMap.put("192.168.1.15", 2);
    serverWeigthMap.put("192.168.1.16", 3);
    serverWeigthMap.put("192.168.1.17", 3);
    serverWeigthMap.put("192.168.1.18", 1);
    serverWeigthMap.put("192.168.1.19", 2);
  }

  public static String random()
  {
    //重新建立一個map,避免出現由於服務器上線和下線導致的並發問題
    Map<String,Integer> serverMap = new HashMap<String,Integer>();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set<String> keySet = serverMap.keySet();
    ArrayList<String> keyList = new ArrayList<String>();
    keyList.addAll(keySet);
    
    Random random = new Random();
    int randomPos = random.nextInt(keyList.size());
    
    String server = keyList.get(randomPos);
    return server;
  }
  
  public static void main(String[] args) {
    String serverIp = random();
    System.out.println(serverIp);
  }
}
登入後複製


#加權隨機:


##

package class2.zookeeper.loadbalance;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.Set;

/**
 * 加權隨機载均衡算法
 * @author guoy
 *
 */
public class TestWeightRandom {
  
  static Map<String,Integer> serverWeigthMap = new HashMap<String,Integer>();

   static{
    serverWeigthMap.put("192.168.1.12", 1);
    serverWeigthMap.put("192.168.1.13", 1);
    serverWeigthMap.put("192.168.1.14", 2);
    serverWeigthMap.put("192.168.1.15", 2);
    serverWeigthMap.put("192.168.1.16", 3);
    serverWeigthMap.put("192.168.1.17", 3);
    serverWeigthMap.put("192.168.1.18", 1);
    serverWeigthMap.put("192.168.1.19", 2);
  }

  public static String weightRandom()
  {
    //重新建立一個map,避免出現由於服務器上線和下線導致的並發問題
    Map<String,Integer> serverMap = new HashMap<String,Integer>();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set<String> keySet = serverMap.keySet();
    Iterator<String> it = keySet.iterator();

    List<String> serverList = new ArrayList<String>();

    while (it.hasNext()) {
      String server = it.next();
      Integer weight = serverMap.get(server);
      for (int i = 0; i < weight; i++) {
        serverList.add(server);
      }
    }    
    Random random = new Random();
    int randomPos = random.nextInt(serverList.size());
    
    String server = serverList.get(randomPos);
    return server;
  }
  
  public static void main(String[] args) {
    String serverIp = weightRandom();
    System.out.println(serverIp);
  }
}
登入後複製
登入後複製

ip hash:

##########
package class2.zookeeper.loadbalance;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;

/**
 * 负载均衡 ip_hash算法
 * @author guoy
 *
 */
public class TestIpHash {

  
  static Map<String,Integer> serverWeigthMap = new HashMap<String,Integer>();

   static{
    serverWeigthMap.put("192.168.1.12", 1);
    serverWeigthMap.put("192.168.1.13", 1);
    serverWeigthMap.put("192.168.1.14", 2);
    serverWeigthMap.put("192.168.1.15", 2);
    serverWeigthMap.put("192.168.1.16", 3);
    serverWeigthMap.put("192.168.1.17", 3);
    serverWeigthMap.put("192.168.1.18", 1);
    serverWeigthMap.put("192.168.1.19", 2);
  }

   /**
   * 获取请求服务器地址
   * @param remoteIp 负载均衡服务器ip
   * @return
   */
  public static String ipHash(String remoteIp)
  {
    //重新建立一個map,避免出現由於服務器上線和下線導致的並發問題
    Map<String,Integer> serverMap = new HashMap<String,Integer>();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set<String> keySet = serverMap.keySet();
    ArrayList<String> keyList = new ArrayList<String>();
    keyList.addAll(keySet);
    
    int hashCode =remoteIp.hashCode();
    int serverListSize = keyList.size();
    int serverPos = hashCode % serverListSize;
    
    return keyList.get(serverPos);
  }
  
  public static void main(String[] args) {
    String serverIp = ipHash("192.168.1.12");
    System.out.println(serverIp);
  }

}
登入後複製
############以上就是本文的全部內容,希望對大家的學習有幫助,也希望大家多多支持PHP中文網。 ######更多Java實作負載平衡的幾種演算法相關文章請關注PHP中文網! ############
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
1 個月前 By 尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
1 個月前 By 尊渡假赌尊渡假赌尊渡假赌
威爾R.E.P.O.有交叉遊戲嗎?
1 個月前 By 尊渡假赌尊渡假赌尊渡假赌

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

如何優化Linux系統的TCP/IP效能與網路效能 如何優化Linux系統的TCP/IP效能與網路效能 Nov 07, 2023 am 11:15 AM

在現代電腦領域,TCP/IP協定是實現網路通訊的基礎。 Linux作為開放原始碼作業系統,已成為許多企業和組織使用的首選作業系統。然而,隨著網路應用程式和服務越來越成為業務的關鍵組成部分,管理員往往需要優化網路效能,以確保快速和可靠的資料傳輸。本文將介紹如何透過對Linux系統進行TCP/IP效能和網路效能最佳化來提高Linux系統的網路傳輸速度。本文將探討一

Nginx負載平衡方案中的故障轉移與復原機制 Nginx負載平衡方案中的故障轉移與復原機制 Oct 15, 2023 am 11:14 AM

Nginx負載平衡方案中的故障轉移與復原機制引言:對於高負載網站來說,使用負載平衡是確保網站高可用性和提高效能的重要手段之一。 Nginx作為一款功能強大的開源Web伺服器,其負載平衡功能已被廣泛應用。在負載平衡中,如何實現故障轉移和恢復機制,是需要重點考慮的問題。本文將介紹Nginx負載平衡中的故障轉移與復原機制,並給出具體的程式碼範例。一、故障轉移機制

建構高可用性的負載平衡系統:Nginx Proxy Manager的最佳實踐 建構高可用性的負載平衡系統:Nginx Proxy Manager的最佳實踐 Sep 27, 2023 am 08:22 AM

建構高可用性的負載平衡系統:NginxProxyManager的最佳實務引言:在網際網路應用的發展中,負載平衡系統是不可或缺的元件之一。它能夠透過將請求分發到多台伺服器上,實現高並發、高可用性的服務。 NginxProxyManager是一款常用的負載平衡軟體,本文將介紹如何使用NginxProxyManager建構一個高可用性的負載平衡系統,並提供

Nginx負載平衡方案的高可用性和容災方案 Nginx負載平衡方案的高可用性和容災方案 Oct 15, 2023 am 11:43 AM

Nginx負載平衡方案的高可用性和容災方案隨著網際網路的快速發展,Web服務的高可用性已成為關鍵的需求。為了實現高可用性和容災能力,Nginx一直是最常用且可靠的負載平衡器之一。在本文中,我們將介紹Nginx的高可用性和容災方案,並提供具體的程式碼範例。 Nginx的高可用性主要透過使用多個伺服器來實現。 Nginx作為負載平衡器,可以將流量分配到多個後端伺服器上,以

Nginx負載平衡方案中的動態失敗偵測與負載權重調整策略 Nginx負載平衡方案中的動態失敗偵測與負載權重調整策略 Oct 15, 2023 pm 03:54 PM

Nginx負載平衡方案中的動態失敗偵測和負載權重調整策略,需要具體程式碼範例引言在高並發的網路環境中,負載平衡是一種常見的解決方案,可以有效地提高網站的可用性和效能。 Nginx是一種開源的高效能Web伺服器,它提供了強大的負載平衡功能。本文將介紹Nginx負載平衡中的兩個重要特性,動態失敗偵測和負載權重調整策略,並提供具體的程式碼範例。一、動態失敗偵測動態失敗檢

負載平衡策略在Java框架效能最佳化中的運用 負載平衡策略在Java框架效能最佳化中的運用 May 31, 2024 pm 08:02 PM

负载均衡策略在Java框架中至关重要,用于高效分布请求。根据并发情况,不同的策略具有不同的性能表现:轮询法:低并发下性能稳定。加权轮询法:低并发下与轮询法性能相似。最少连接数法:高并发下性能最佳。随机法:简单但性能较差。一致性哈希法:平衡服务器负载。结合实战案例,本文说明了如何根据性能数据选择合适的策略,以显著提升应用性能。

利用Nginx Proxy Manager實現反向代理的負載平衡策略 利用Nginx Proxy Manager實現反向代理的負載平衡策略 Sep 26, 2023 pm 12:05 PM

利用NginxProxyManager實現反向代理的負載平衡策略NginxProxyManager是一款基於Nginx的代理程式管理工具,可以幫助我們輕鬆實現反向代理程式和負載平衡。透過設定NginxProxyManager,我們可以將請求分發給多個後端伺服器,以實現負載平衡,提高系統的可用性和效能。一、安裝並設定NginxProxyManager安

Nginx負載平衡方案中的後端伺服器健康檢查和動態調整 Nginx負載平衡方案中的後端伺服器健康檢查和動態調整 Oct 15, 2023 am 11:37 AM

Nginx負載平衡方案中的後端伺服器健康檢查和動態調整,需要具體程式碼範例摘要:在Nginx負載平衡方案中,後端伺服器的健康狀況是一個重要的考量。本文將介紹如何使用Nginx的健康檢查模組和動態調整模組來實現後端伺服器的健康檢查和動態調整,並給出具體的程式碼範例。引言在現代的應用程式架構中,負載平衡是常用的解決方案之一,可以提高應用程式的效能和可靠性。 Ngi

See all articles