详解Nginx轮询算法底层实现的方法
轮询算法简介
在工作中很多人都使用到了nginx,对nginx得配置也是烂熟于心,今天我主要想介绍一下nginx轮询算法得几种底层实现方式。
简单轮询算法
这种算法比较简单,举个例子就是你有三台服务器
第一台服务器 | 192.168.1.1 |
第二台服务器 | 192.168.1.2 |
第三台服务器 | 192.168.1.3 |
第一个请求过来之后默认访问第一台,第二个请求过来访问第二台,第三次请求过来访问第三台,第四次请求过来访问第一台,以此类推。以下是我代码实现简单得算法:
public class SimplePolling { /** * key是ip */ public static List <String> ipService = new LinkedList <>(); static { ipService.add("192.168.1.1"); ipService.add("192.168.1.2"); ipService.add("192.168.1.3"); } public static int pos = 0; public static String getIp(){ if(pos >= ipService.size()){ //防止索引越界 pos = 0; } String ip = ipService.get(pos); pos ++; return ip; } public static void main(String[] args) { for (int i = 0; i < 4; i++) { System.out.println(getIp()); } } }
模拟执行4次执行结果是
此时如果我有一台服务器性能比较好(比如192.168.1.1),我想让这台服务器处理多一点请求,此时就涉及到了权重得概率,这种算法就不能实现,请看我后面描述的轮询升级版算法。
加权轮询算法
此时我需要把我前面3台服务器都设置权重,比如第一台设置5,第二台设置1,第三台设置1
第一台服务器 | 192.168.1.1 | 5 |
第二台服务器 | 192.168.1.2 | 1 |
第三台服务器 | 192.168.1.3 | 1 |
此时前5个请求都会访问到第一台服务器,第六个请求会访问到第二台服务器,第七个请求会访问到第三台服务器。
以下是我给出的代码案例:
public class WeightPolling { /** * key是ip,value是权重 */ public static Map<String, Integer> ipService = new LinkedHashMap<>(); static { ipService.put("192.168.1.1", 5); ipService.put("192.168.1.2", 1); ipService.put("192.168.1.3", 1); } public static int requestId = 0; public static int getAndIncrement() { return requestId++; } public static String getIp(){ //获取总的权重 int totalWeight =0; for (Integer value : ipService.values()) { totalWeight+= value; } //获取当前轮询的值 int andIncrement = getAndIncrement(); int pos = andIncrement% totalWeight; for (String ip : ipService.keySet()) { if(pos < ipService.get(ip)){ return ip; } pos -= ipService.get(ip); } return null; } public static void main(String[] args) { for (int i = 0; i < 7; i++) { System.out.println(getIp()); } } }
可以看的第一台服务器执行了5次,后面2台依次执行一次,依次类推。可能你觉得这种算法还不错。其实这种算法有一个缺点是,如果我第一台服务器设置权重过大可能我需要很多次请求都执行到第一台服务器上去,这样的情况分布是不均匀的,会造成某一台服务器压力过大导致崩溃。所以我后面要引入第三种算法来解决这个问题
平滑加权轮询算法
这种算法可能比较复杂,我第一次看也有点不太明白,后面看过相关资料在结合我自己的理解给大家图文解释一下,这里我举例的服务器配置和权重还是和上面一样
请求 | 当前权重 = 自身权重+选中后当前权重 | 总权重 | 当前最大权重 | 返回的ip | 选中后当前权重=当前最大权重-总权重 |
---|---|---|---|---|---|
1 | {5,1,1} | 7 | 5 | 192.168.1.1 | {-2,1,1} |
2 | {3,2,2} | 7 | 3 | 192.168.1.1 | {-4,2,2} |
3 | {1,3,3} | 7 | 3 | 192.168.1.2 | {1,-4,3} |
4 | {6,-3,4} | 7 | 6 | 192.168.1.1 | {-1,-3,4} |
5 | {4,-2,5} | 7 | 5 | 192.168.1.3 | {4,-2,-2} |
6 | {9,-1,-1} | 7 | 9 | 192.168.1.1 | {2,-1,-1} |
7 | {7,0,0} | 7 | 7 | 192.168.1.1 | {0,0,0} |
由上图可以看出第一台服务器虽然权重设置的是5,但并不是第五次请求过来都是第一台服务器执行,而是分散执行,调度序列是非常均匀的,且第 7 次调度时选中后当前权重又回到 {0, 0, 0},实例的状态同初始状态一致,所以后续可以一直重复调度操作。
可能有的人还不能清楚的明白上一张图表示的含义,我这里大概描述一下:
1.首先总权重不会变,默认就是当前设置的权重之和
2.在第一次请求进来的时候我默认初始化当前权重选中值是{0,0,0},所以当前权重的值就是{5+0,1+0,1+0},这里的5,1,1就是我们前面每台服务器设置的权重。
3.这里我们可以得出第一次请求过来的最大权重是5。然后返回第一台服务器ip
4.然后我们设置选中后当前权重,这里就是当前最大权重减去总权重(5-7),没有选中的权重不变,这时候得到当前权重选中权重的值{5-7,1,1}
5.在第二次请求过来的时候我们延续上面的2,3,4步骤执行.
如果这里还有不懂得我下面会提供我自己用java代码实现的算法:
public class Polling { /** * key是ip,value是权重 */ public static Map <String,Integer> ipService = new LinkedHashMap <>(); static { ipService.put("192.168.1.1",5); ipService.put("192.168.1.2",1); ipService.put("192.168.1.3",1); } private static Map<String,Weight> weightMap = new LinkedHashMap <>(); public static String getIp(){ //计算总的权重 int totalWeight = 0; for (Integer value : ipService.values()) { totalWeight+=value; } //首先判断weightMap是否为空 if(weightMap.isEmpty()){ ipService.forEach((ip,weight)->{ Weight weights = new Weight(ip, weight,0); weightMap.put(ip,weights); }); } //给map中得对象设置当前权重 weightMap.forEach((ip,weight)->{ weight.setCurrentWeight(weight.getWeight() + weight.getCurrentWeight()); }); //判断最大权重是否大于当前权重,如果为空或者小于当前权重,则把当前权重赋值给最大权重 Weight maxWeight = null; for (Weight weight : weightMap.values()) { if(maxWeight ==null || weight.getCurrentWeight() > maxWeight.getCurrentWeight()){ maxWeight = weight; } } //最后把当前最大权重减去总的权重 maxWeight.setCurrentWeight(maxWeight.getCurrentWeight() - totalWeight); //返回 return maxWeight.getIp(); } public static void main(String[] args) { //模拟轮询7次取ip for (int i = 0; i < 7; i++) { System.out.println(getIp()); } } } class Weight{ /** * ip */ private String ip; /** * 设置得权重 */ private int weight; /** * 当前权重 */ private int currentWeight; public Weight(String ip, int weight,int currentWeight) { this.ip = ip; this.weight = weight; this.currentWeight = currentWeight; } public String getIp() { return ip; } public void setIp(String ip) { this.ip = ip; } public int getWeight() { return weight; } public void setWeight(int weight) { this.weight = weight; } public int getCurrentWeight() { return currentWeight; } public void setCurrentWeight(int currentWeight) { this.currentWeight = currentWeight; } }
可以看出此处执行结果和表格里描述得结果一致。
总结
可能第三种算法理解起来有点复杂,如果看不懂图表得意思可以先执行下代码,debugger一步步调试后还是很好理解。
相关文章
详解nginx同一端口监听多个域名和同时监听http与https
这篇文章主要介绍了详解nginx同一端口监听多个域名和同时监听http与https的相关资料,需要的朋友可以参考下...2017-07-06- 这篇文章主要介绍了Nginx根据不同浏览器语言配置页面跳转的方法,包括一个简体繁体的基本判断方法及实际根据中英文跳转的例子,需要的朋友可以参考下...2016-05-22
- 周一今天给大家分享shell脚本多实例部署nginx的详细教程,文章通过实例代码脚本给大家详细介绍,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧...2021-10-26
- 这篇文章主要介绍了Nginx中配置过滤爬虫的User-Agent的简单方法,文中罗列了一些常用搜索引擎的爬虫名称以免造成不必要的过滤,需要的朋友可以参考下...2016-01-27
- 这篇文章主要介绍了Nginx访问日志及错误日志参数说明,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-11-14
- 这篇文章主要介绍了Linux环境下nginx搭建简易图片服务器,需要的朋友可以参考下...2016-01-27
- 这篇文章主要介绍了使用nginx方式实现http转换为https的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-06
- 这篇文章主要介绍了nginx配置引发的403问题解决办法的相关资料,需要的朋友可以参考下...2017-07-06
Nginx反向代理proxy_cache_path directive is not allowed错误解决方法
这篇文章主要介绍了Nginx反向代理proxy_cache_path directive is not allowed错误解决方法,需要的朋友可以参考下...2016-01-27nginx+apache+mysql+php+memcached+squid搭建集群web环境
当前,LAMP开发模式是WEB开发的首选,如何搭建一个高效、可靠、稳定的WEB服务器一直是个热门主题,本文就是这个主题的一次尝试。...2016-01-27- Nginx日志主要分为两种:访问日志和错误日志。访问日志主要记录客户端访问Nginx的每一个请求,格式可以自定义。下面这篇文章主要给大家介绍了Nginx自定义访问日志的配置方式,需要的朋友可以参考学习,下面来一起看看吧。...2017-07-06
- 这篇文章主要介绍了nginx使用IPV6的相关配置项介绍,首先查看编译参数是否编译了IPV6模块,然后介绍了监听IPV6的配置语法,需要的朋友可以参考下...2016-01-27
解决使用了nginx获取IP地址都是127.0.0.1 的问题
这篇文章主要介绍了解决使用了nginx获取IP地址都是127.0.0.1 的问题,获取i工具的完整代码文中给大家提到,具体实例代码跟随小编一起看看吧...2021-09-18- 本篇文章主要介绍了nginx修改上传文件大小限制的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧。 ...2017-01-22
- 这篇文章主要介绍了Debian7编译安装nginx简明教程,本文直接给出操作命令和步骤,需要的朋友可以参考下...2016-01-27
- 这篇文章主要介绍了隐藏Nginx或Apache以及PHP的版本号的方法,主要用来防止针对性的漏洞攻击,需要的朋友可以参考下...2016-01-05
- 这篇文章主要介绍了Nginx DNS resolver配置实例,本文讲解在proxy_pass 和 upstream server 通信的时候需要手动指定 resolver,本文就给出了配置实例,需要的朋友可以参考下...2016-01-27
- 这篇文章主要介绍了关于Nginx中if语句的判断条件与多条件判断的相关资料,文中给出了详细的示例代码,对大家具有一定的参考价值,需要的朋友们下面来一起看看吧。...2017-07-06
详解Nginx服务器中配置Sysguard模块预防高负载的方案
这篇文章主要介绍了详解Nginx服务器中配置Sysguard模块预防高负载的方案,该模块由阿里巴巴的团队开发,能够设置负载阀值,比较强大,需要的朋友可以参考下...2016-02-02- 本篇文章主要介绍了nginx实现ssl反向代理实战,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧 ...2017-01-22