公告:欢迎访问,查看更多资源请点我^.^!            点我关闭广告
负载均衡算法实现代码
2018-09-12 17:29:07
1160人阅读
评论(0)
分类:分布式
/**
 * Created by 赵超 on 2017/1/17
 * 服务器的ip地址
 */
public class IpAddrUtil {

    /**
     * 用于存储各个服务器的ip,key代表ip,value代表该ip的权重
     */
    public static HashMap<String, Integer> serverIpAddrMap = new HashMap<>();

    static {
        serverIpAddrMap.put("192.168.3.100", 1);
        serverIpAddrMap.put("192.168.3.101", 1);
        serverIpAddrMap.put("192.168.3.102", 4);
        serverIpAddrMap.put("192.168.3.103", 1);
        serverIpAddrMap.put("192.168.3.104", 2);
        serverIpAddrMap.put("192.168.3.105", 1);
        serverIpAddrMap.put("192.168.3.105", 3);
    }

}

/**
* Created by 赵超 on 2017/1/17
* 负载均衡实现方法
* 轮询法
* 随机法
* 源地址hash法
* 加权轮询法
* 加权随机法
* 最小连接数法(并未实现)
*/
public class LoadBalanceUtil {

private static Integer pos = 0;

/**
* 轮询法
* @return
*/
public static String roundRobin() {
//重建一个Map,避免服务器的上下线导致的并发问题
Map<String, Integer> serverMap = new HashMap<>();
serverMap.putAll(IpAddrUtil.serverIpAddrMap);
//获取地址的list
Set<String> keySet = serverMap.keySet();
ArrayList<String> keyList = new ArrayList<>();
keyList.addAll(keySet);

String server;

synchronized (pos) {
if (pos > keyList.size()) {
pos = 0;
}
server = keyList.get(pos);
pos ++;
}

return server;
}

/**
* 随机法
* @return
*/
public static String random() {
//重建一个Map,避免服务器的上下线导致的并发问题
Map<String, Integer> serverMap = new HashMap<>();
serverMap.putAll(IpAddrUtil.serverIpAddrMap);
//获取地址的list
Set<String> keySet = serverMap.keySet();
ArrayList<String> keyList = new ArrayList<>();
keyList.addAll(keySet);
Random random = new Random();
int serverPos = random.nextInt(keyList.size());
return keyList.get(serverPos);
}

/**
* 源地址hash法
* @return
*/
public static String hash() {
//重建一个Map,避免服务器的上下线导致的并发问题
Map<String, Integer> serverMap = new HashMap<>();
serverMap.putAll(IpAddrUtil.serverIpAddrMap);
Set<String> keySet = serverMap.keySet();
ArrayList<String> keyList = new ArrayList<>();
keyList.addAll(keySet);
//在web应用中通过HttpServlet的getRemoteIp方法获取
String remoteIp = "127.0.0.1"; //这里不是定值
int hashCode = remoteIp.hashCode();
int size = keyList.size();
int serverPos = hashCode % size;
return keyList.get(serverPos);
}

/**
* 加权轮询法
* @return
*/
public static String weightRoundRobin() {
Map<String, Integer> serverMap = new HashMap<>();
serverMap.putAll(IpAddrUtil.serverIpAddrMap);
Set<String> keySet = serverMap.keySet();
Iterator<String> iterator = keySet.iterator();
List<String> serverList = new ArrayList<>();
while (iterator.hasNext()) {
String server = iterator.next();
int weight = serverMap.get(server);
//权重越高 添加次数越多 使用的频率会越高(次数越多)
for (int i = 0; i < weight; i++) {
serverList.add(server);
}
}
String server;
synchronized (pos) {
if (pos > serverList.size()) {
// if (pos > keySet.size()) {
pos = 0;
}
server = serverList.get(pos);
pos ++;
}
return server;
}

/**
* 加权随机法
* @return
*/
public static String weightRandom() {
Map<String, Integer> serverMap = new HashMap<>();
serverMap.putAll(IpAddrUtil.serverIpAddrMap);
Set<String> keySet = serverMap.keySet();
Iterator<String> iterator = keySet.iterator();
List<String> serverList = new ArrayList<>();
while (iterator.hasNext()) {
String server = iterator.next();
int weight = serverMap.get(server);
for (int i = 0; i < weight; i ++) {
serverList.add(server);
}
}
Random random = new Random();
int serverPos = random.nextInt(serverList.size());
return serverList.get(serverPos);
}

/**
* 最小连接数法(并未实现)
*/
public static String leastConnections() {
return null;
}

}

分享一下:
赞一下(4)
博主资料
博主头像
zc521106
文章:34
浏览:19899
文章分类
Java(12)
NoSql(112)
数据库(12)
前端(12)
阅读排行
Java基础知识
(12)
NoSql应用
(112)
数据库Oracle语法
(12)
前端常用工具类
(12)
java web项目
(12)
linux安装mysql
(12)
评论区
这篇文章怎么样?写点评论吧!
姓名:
邮箱:
有回复时通知我:
发表
回复【10.20.30.32】:
暂无评论,快抢沙发!
* 以上用户言论只代表其个人观点,不代表iBlog网站的观点或立场,如有任何疑问请随时联系管理员...