負載均衡的幾種算法

時間  2019-12-05
標籤 負載 均衡 幾種 算法 欄目 負載均衡 简体版
原文   原文鏈接

輪詢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 hashdom

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);
	}

}
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程