详解Java实现负载均衡的几种算法代码

作者：帆侮听我悄悄说星星 | 2021-10-21 00:24

本篇文章主要介绍Java实现负载均衡的几种算法，具体如下：轮询:packageclass2.zookeeper.loadbalance;importjava.util.ArrayList;importjava.util.HashMap;importjava.util.Map;importjava.u

本篇文章主要介绍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 serverWeigthMap = new HashMap();

   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 serverMap = new HashMap();
      serverMap.putAll(serverWeigthMap);
      //獲取ip列表list
      Set keySet = serverMap.keySet();
      ArrayList keyList = new ArrayList();
      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 serverWeigthMap = new HashMap();

   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 serverMap = new HashMap();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set keySet = serverMap.keySet();
    Iterator it = keySet.iterator();

    List serverList = new ArrayList();

    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 serverWeigthMap = new HashMap();

   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 serverMap = new HashMap();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set keySet = serverMap.keySet();
    ArrayList keyList = new ArrayList();
    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 serverWeigthMap = new HashMap();

   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 serverMap = new HashMap();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set keySet = serverMap.keySet();
    Iterator it = keySet.iterator();

    List serverList = new ArrayList();

    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 serverWeigthMap = new HashMap();

   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 serverMap = new HashMap();
    serverMap.putAll(serverWeigthMap);
    //獲取ip列表list
    Set keySet = serverMap.keySet();
    ArrayList keyList = new ArrayList();
    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);
  }

}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

推荐阅读

程序员
jQuery load（）不会在div中加载脚本标签

如何解决《jQueryload（）不会在div中加载脚本标签》经验，为你挑选了1个好方法。 ... [详细]
程序员
使用R到COUNT()和GROUP_CONCAT(DISTINCT x)

如何解决《使用R到COUNT()和GROUP_CONCAT(DISTINCTx)》经验，为你挑选了2个好方法。 ... [详细]
程序员
ProgressBar的颜色没有改变c#

如何解决《ProgressBar的颜色没有改变c#》经验，为你挑选了1个好方法。 ... [详细]
程序员
Active Directory LDAP示例

如何解决《ActiveDirectoryLDAP示例》经验，为你挑选了0个好方法。 ... [详细]
程序员
方法的擦除与类型中的另一种方法相同

如何解决《方法的擦除与类型中的另一种方法相同》经验，为你挑选了1个好方法。 ... [详细]
程序员
在派生类中传递* args / ** kwargs

如何解决《在派生类中传递*args/**kwargs》经验，为你挑选了1个好方法。 ... [详细]
程序员
msvc"断点当前不会被击中"

如何解决《msvc"断点当前不会被击中"》经验，为你挑选了0个好方法。 ... [详细]
程序员
Firefox会在选择时触发,而不是在更改时触发

如何解决《Firefox会在选择时触发,而不是在更改时触发》经验，为你挑选了0个好方法。 ... [详细]
程序员
多个匹配分隔符

如何解决《多个匹配分隔符》经验，为你挑选了1个好方法。 ... [详细]
程序员
在数组中的每个对象上调用实例方法

如何解决《在数组中的每个对象上调用实例方法》经验，为你挑选了1个好方法。 ... [详细]
程序员
无法使用productFlavors在库中导入android支持v4或v7

如何解决《无法使用productFlavors在库中导入android支持v4或v7》经验，为你挑选了0个好方法。 ... [详细]
程序员
在c#中创建套接字的代码

如何解决《在c#中创建套接字的代码》经验，为你挑选了1个好方法。 ... [详细]
程序员
CS0122和CS0143之间的C#编译器错误差异

如何解决《CS0122和CS0143之间的C#编译器错误差异》经验，为你挑选了0个好方法。 ... [详细]
程序员
我们使用"pipe(int pipefd [2])"在c中创建的unix管道(|)和管道是否相同？

如何解决《我们使用"pipe(intpipefd[2])"在c中创建的unix管道(|)和管道是否相同？》经验，为你挑选了2个好方法。 ... [详细]
程序员
IEnumerable - 更新foreach循环内的对象

如何解决《IEnumerable-更新foreach循环内的对象》经验，为你挑选了1个好方法。 ... [详细]
程序员
Python Killed:9使用从2个csv文件创建的词典运行代码

如何解决《PythonKilled:9使用从2个csv文件创建的词典运行代码》经验，为你挑选了1个好方法。 ... [详细]
程序员
查询不返回数据库

如何解决《查询不返回数据库》经验，为你挑选了1个好方法。 ... [详细]
程序员
Hibernate/Spring - 在事务中回滚事务

如何解决《Hibernate/Spring-在事务中回滚事务》经验，为你挑选了1个好方法。 ... [详细]
程序员
使用自定义引导加载程序创建可引导的ISO映像

如何解决《使用自定义引导加载程序创建可引导的ISO映像》经验，为你挑选了2个好方法。 ... [详细]
程序员
sequelize.js - 按id和返回结果查找

如何解决《sequelize.js-按id和返回结果查找》经验，为你挑选了2个好方法。 ... [详细]

帆侮听我悄悄说星星

这个屌丝很懒，什么也没留下！

关注作者

Tags | 热门标签

RankList | 热门文章