首页 > 站长百科 > 网络编程

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

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;

/**
 * 負載均衡算法，輪詢法
 * @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);
	}

}

 

标签： 服务器 服务器地址

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点！
本站所提供的图片等素材，版权归原作者所有，如需使用，请与原作者联系。

上一篇:Jboot v1.6.3 发布，修复分布式 session 等若干问题

下一篇:Andorid Bitmap 重采样

相关文章
最新资讯
热门推荐
热门标签
网站 seo 网络 网站优化 安全 百度 互联网 服务器 云计算 媒体 大数据 代码 外链建设 搜索 搜索优化 数据 淘宝 搜索引擎 百度百 通信 博 数据库 网站推广 金融 排名 Google 推广 谷歌 网站排名 关键词优化