中文字幕在线观看,亚洲а∨天堂久久精品9966,亚洲成a人片在线观看你懂的,亚洲av成人片无码网站,亚洲国产精品无码久久久五月天

負(fù)載均衡的幾種算法Java實現(xiàn)代碼

2018-07-20    來源：open-open

容器云強勢上線！快速搭建集群，上萬Linux鏡像隨意使用

輪詢

package class2.zookeeper.loadbalance;

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

/**
 * 負(fù)載均衡算法，輪詢法
 * @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,避免出現(xiàn)由於服務(wù)器上線和下線導(dǎo)致的並發(fā)問題
			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);
			}
		}
}

加權(quán)輪詢

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;

/**
 * 加權(quán)隨機載均衡算法
 * @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,避免出現(xiàn)由於服務(wù)器上線和下線導(dǎo)致的並發(fā)問題
		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;

/**
 * 隨機負(fù)載均衡算法
 * @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,避免出現(xiàn)由於服務(wù)器上線和下線導(dǎo)致的並發(fā)問題
		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);
	}
}

加權(quán)隨機

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;

/**
 * 加權(quán)隨機載均衡算法
 * @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,避免出現(xiàn)由於服務(wù)器上線和下線導(dǎo)致的並發(fā)問題
		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;

/**
 * 負(fù)載均衡 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);
	}

	 /**
	  * 獲取請求服務(wù)器地址
	  * @param remoteIp 負(fù)載均衡服務(wù)器ip
	  * @return
	  */
	public static String ipHash(String remoteIp)
	{
		//重新建立一個map,避免出現(xiàn)由於服務(wù)器上線和下線導(dǎo)致的並發(fā)問題
		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);
	}

}

 

標(biāo)簽： 服務(wù)器 服務(wù)器地址

版權(quán)申明：本站文章部分自網(wǎng)絡(luò)，如有侵權(quán)，請聯(lián)系：west999com@outlook.com
特別注意：本站所有轉(zhuǎn)載文章言論不代表本站觀點！
本站所提供的圖片等素材，版權(quán)歸原作者所有，如需使用，請與原作者聯(lián)系。

上一篇:Jboot v1.6.3 發(fā)布，修復(fù)分布式 session 等若干問題

下一篇:Andorid Bitmap 重采樣