電子發(fā)燒友App
負(fù)載：就是后端系統(tǒng)的承載能力。比如同等條件下，一個(gè)1核cpu-1G內(nèi)存的機(jī)器的承載能力一般會(huì)比8核cpu-8G內(nèi)存的機(jī)器要差；相同配置下，一個(gè)cpu利用率為80%的機(jī)器比30%的承載能力一般要差等等。
均衡：保證后端請(qǐng)求的平衡。比如：在同等情況下，分配到多臺(tái)機(jī)器的請(qǐng)求要相當(dāng)；有些情況下，同一用戶盡可能分配到同一臺(tái)機(jī)器等等。
負(fù)載均衡的算法實(shí)際上就是解決跨系統(tǒng)調(diào)用的時(shí)候，在考慮后端機(jī)器承載情況的前提下，保證請(qǐng)求分配的平衡和合理。下面是基于java的負(fù)載均衡算法解析及源碼，以供參考。
1、輪詢：
package class2.zookeeper.loadbalance;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.Set;
/**
* 負(fù)載均衡算法，輪詢法
* @author guoy
*
*/
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（）
{
//重新建立一個(gè)map，避免出現(xiàn)由于服務(wù)器上線和下線導(dǎo)致的并發(fā)問(wèn)題
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）;
}
}
}
2、加權(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)隨機(jī)載均衡算法
* @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（）
{
//重新建立一個(gè)map，避免出現(xiàn)由于服務(wù)器上線和下線導(dǎo)致的并發(fā)問(wèn)題
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）;
}
}
3、隨機(jī)：
package class2.zookeeper.loadbalance;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import java.util.Set;
/**
* 隨機(jī)負(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（）
{
//重新建立一個(gè)map，避免出現(xiàn)由于服務(wù)器上線和下線導(dǎo)致的并發(fā)問(wèn)題
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）;
}
}
4、加權(quán)隨機(jī)：
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)隨機(jī)載均衡算法
* @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（）
{
//重新建立一個(gè)map，避免出現(xiàn)由于服務(wù)器上線和下線導(dǎo)致的并發(fā)問(wèn)題
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）;
}
}
5、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）;
}
/**
* 獲取請(qǐng)求服務(wù)器地址
* @param remoteIp 負(fù)載均衡服務(wù)器ip
* @return
*/
public static String ipHash（String remoteIp）
{
//重新建立一個(gè)map，避免出現(xiàn)由于服務(wù)器上線和下線導(dǎo)致的并發(fā)問(wèn)題
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）;
}
}
工商網(wǎng)監(jiān)
評(píng)論