SpringCloud系列(22)--Ribbon默认负载轮询算法原理及源码解析

news/2024/9/20 7:15:45/ 标签: spring cloud, ribbon

前言:在上一篇文章中我们介绍了如何去切换Ribbon的负载均衡模式,而本章节内容则是介绍Ribbon默认负载轮询算法的原理。

1、负载轮询算法公式

rest接口第N次请求数 % 服务器集群总数 = 实际调用服务器下标(每次服务器重启后rest接口计数从1开始)

举例子:

现在集群有两台服务器,分别有payment8001、payment8002这两个实例,即服务器集群总数为2

把这两个实例放进一个List集合里,即List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");

如:List[0] instances = 127.0.0.1:8001

       List[1] instances = 127.0.0.1:8002

之后对请求数进行%服务器集群总数的操作,然后取出实际调用的服务器下标,用该下标从实例集合里取出的实例就是要访问的服务器

如:

第1次请求 : 1 % 2 = 1,即这时要调用List集合下标为1的服务器,获得instances下标为1的服务器地址127.0.0.1:8002,然后调用这台服务器

第2次请求 : 2 % 2 = 0,即这时要调用List集合下标为0的服务器,获得instances下标为0的服务器地址127.0.0.1:8001,然后调用这台服务器

第3次请求 : 3 % 2 = 1,即这时要调用List集合下标为1的服务器,获得instances下标为1的服务器地址127.0.0.1:8002,然后调用这台服务器

第4次请求 : 4 % 2 = 0,即这时要调用List集合下标为0的服务器,获得instances下标为0的服务器地址127.0.0.1:8001,然后调用这台服务器

第5次请求 : 5 % 2 = 1,即这时要调用List集合下标为0的服务器,获得instances下标为1的服务器地址127.0.0.1:8002,然后调用这台服务器

如此类推.......

以上就是Ribbon轮询算法的原理

2、Ribbon负载轮询算法源码解析

(1)我们进入到MySelfRule这个类里面,然后点进IRule类

(2)点击跳转到IRule接口的RoundRobinRule实现类里,RoundRobinRule这个类就是关于轮询算法的代码实现

(3)解析源代码

[1]我们可以看到RoundRobinRule构造方法里初始化了一个值为0的AtomicInteger类

[2]负载均衡算法主要实现在choose方法里,我们看choose方法可以看到关于各种关于服务的非空判断和各种的取值,其中最重要的是通过incrementAndGetModulo方法取得下标,然后根据这个下标从服务集合里取出其中一个服务

[3]incrementAndGetModulo方法,它的实现方式就跟我们第一个步骤介绍的算法一样,即: 

往incrementAndGetModulo方法传入服务总数,nextServerCyclicCounter.get()方法取得原子类当前的值,因为默认值是0,所以取得的值是0,即current的值为0,(current + 1) % modulo的计算方式就跟我们第一个步骤说的一样,即是请求次数%服务总数,current为0,module是服务总数,假使我们当前的服务有有payment8001、payment8002两个,即module是2,(current + 1) % modulo求得next的值为1,nextServerCyclicCounter.compareAndSet(current, next))方法能比较AtomicInteger的值是否被其他线程改变了,若没改变则把next的值更新到AtomicInteger里,如被改变了,则继续下次循环,直到设置AtomicInteger值成功,把next的值返回为止,在不断地调用choose方法时,会不断地进行对AtomicInteger+1然后对服务总数求模取余的操作,然后不断返回下标,不断的返回相应下标的服务


http://www.ppmy.cn/news/1462740.html

相关文章

人工智能的阴暗面:犯罪分子如何利用 AI 进行欺诈

在当今数字化时代&#xff0c;人工智能&#xff08;AI&#xff09;正迅速成为推动各行各业生产力和创新的关键力量&#xff0c;而一些不法分子也开始探索如何将这些先进的工具用于他们自己的非法目的。从网络钓鱼到深度伪造&#xff0c;再到人肉搜索、越狱服务和身份验证系统的…

SO_REUSEPORT 之 TCP负载均衡验证

首先启动两个tcp server&#xff0c; 代码里开启 SO_REUSEPORT [my_testlocalhost test]$ ./tcp_server_reuseport & [1] 1864 [my_testlocalhost test]$ Server listening on port 8888[my_testlocalhost test]$ ./tcp_server_reuseport & [2] 1865 [my_testlocalh…

《Google 软件工程》读书笔记

1. 写在前面 在图书馆瞎逛&#xff0c;偶然瞄见一本《Google 软件工程》Titus Winters, Tom Manshreck, Hyrum Wright 著。主要是在这一排的书架上就这本书看着挺新的&#xff08;不知道为什么有一种喜欢看新书的情节&#xff09;&#xff0c;而且最近被领导老批评&#xff0c;…

数据结构-队列(带图详解)

目录 队列的概念 画图理解队列 代码图理解 代码展示(注意这个队列是单链表的结构实现) Queue.h(队列结构) Queue.c(函数/API实现) main.c(测试文件) 队列的概念 队列&#xff08;Queue&#xff09;是一种基础的数据结构&#xff0c;它遵循先进先出&#xff08;First In …

基础—SQL—通用语法及分类

一、SQL的通用基本语法 &#xff08;1&#xff09;SQL语句可以单行或多行书写&#xff08;以分号结尾&#xff09;。 &#xff08;2&#xff09;在编写SQL语句的时候&#xff0c;如果长度比较长&#xff0c;我们可以允许空格/缩进来增强语句的可读性&#xff0c;而且空格或者…

括号生成[中等]

优质博文&#xff1a;IT-BLOG-CN 一、题目 数字n代表生成括号的对数&#xff0c;请你设计一个函数&#xff0c;用于能够生成所有可能的并且 有效的 括号组合。 示例 1&#xff1a; 输入&#xff1a;n 3 输出&#xff1a;["((()))","(()())","(())(…

2024 一键批量下载微博内容/图片/视频/评论/转发数据,导出excel和pdf

以李健的微博为例&#xff0c;抓取2010-2024年所有的微博数据excel&#xff0c;包含微博链接&#xff0c;微博内容&#xff0c;发布时间&#xff0c;点赞数&#xff0c;转发数&#xff0c;评论数&#xff0c;话题等。 每个月的微博转评赞总数曲线&#xff0c;2015年是高峰。 微…

opencv--形态学(开运算、闭运算、形态学梯度、顶帽、黑帽)

开运算 先腐蚀再膨胀&#xff0c;消除细小点、毛刺、连接点等等情况 闭运算 先膨胀再腐蚀&#xff0c;填充孔洞、增强连接点等等情况&#xff0c;或者大家说的增加明亮度 形态学梯度 使用膨胀的图减去腐蚀的图&#xff0c;简单理解就是二值化后形状膨胀后会使得物体变大&am…

APP广告变现怎么实现的,背后逻辑是什么?

广告变现的实现主要基于以下几个关键步骤和逻辑&#xff1a; 用户获取与留存&#xff1a;首先&#xff0c;APP需要吸引足够的用户并确保他们的留存率。只有拥有庞大且活跃的用户基础&#xff0c;APP才能吸引广告商投放广告。因此&#xff0c;开发者需要通过优化APP质量、提升用…

[实例] Unity Shader 逐像素漫反射与半兰伯特光照

漫反射光照是Unity中最基本最简单的光照模型&#xff0c;本篇将会介绍在片元着色器中实现反射效果&#xff0c;并会采用半兰伯特光照技术对其进行改进。 1. 逐顶点光照与逐像素光照 在Unity Shader中&#xff0c;我们可以有两个地方可以用来计算光照&#xff1a;在顶点着色器…

后端雪花算法主键ID传到前端变了

Mybatis Plus 的主键策略&#xff1a; /*** id*/TableId(type IdType.ASSIGN_ID)private Long id; 这个主键策略会用雪花算法生成一个 19位的ID&#xff0c;比如 1791006670084734978 现象 后端生成的 id 是正常的&#xff0c;通过 swagger 文档此时获取到的 id 也和数据库中…

GitHub的原理及应用详解(四)

本系列文章简介&#xff1a; GitHub是一个基于Git版本控制系统的代码托管平台&#xff0c;为开发者提供了一个方便的协作和版本管理的工具。它广泛应用于软件开发项目中&#xff0c;包括但不限于代码托管、协作开发、版本控制、错误追踪、持续集成等方面。 GitHub的原理可以简单…

RabbitMQ(二)七种工作模式

文章目录 概述:工作模式&#xff08;七种&#xff09;1. "Hello World!"2. Work Queues&#xff08;工作队列模式&#xff09;3. Publish/Subscribe&#xff08;发布订阅模式&#xff09;4. Routing5. Topics6. RPC7. Publisher Confirms 详细1. "Hello World!&…

哈醉咯最狠

3、通过命令行安装aptitude sudo apt-get install aptitude4、通过命令行利用aptitude 安装fcitx、qtsudo aptitude install fcitx-bin fcitx-table fcitx-config-gtk fcitx-config-gtk2 fcitx-frontend-allsudo aptitude install qt5-default qtcreator qml-module-qtquick-co…

Linux(centos)常用命令

Linux&#xff08;Centos&#xff09;常用命令使用说明文档 切换到/home目录下 使用cd命令切换目录&#xff0c;例如&#xff1a; cd /home列出/home目录下的所有文件 使用ls命令列出目录下的文件和子目录&#xff0c;例如&#xff1a; ls /home新建目录dir1 使用mkdir命…

Linux数组

目录 一.概念 &#xff08;一&#xff09;什么是数组&#xff1f; &#xff08;二&#xff09;数组的表现方式 &#xff08;三&#xff09;数组的数据类型 二.运用数组查看、修改、删除相关信息 &#xff08;1&#xff09;查看数组的元素列表 &#xff08;2&#xff09;查…

物联网应用开发--STM32与机智云通信(ESP8266 Wi-Fi+手机APP+LED+蜂鸣器+SHT20温湿度传感器)

实现目标 1、熟悉机智云平台&#xff0c;会下载APP 2、熟悉新云平台创建产品&#xff0c;项目虚拟调试 3、掌握云平台生成MCU代码&#xff0c;并移植。机智云透传固件的下载 4、具体目标&#xff1a;&#xff08;1&#xff09;注册机智云平台&#xff1b;&#xff08;2&…

自动驾驶---Tesla的自动驾驶技术进化史(PerceptionPlanning)

1 前言 笔者在专栏《自动驾驶Planning模块》中已经详细讲解了传统自动驾驶Planning模块的内容&#xff1a;包括行车的Behavior Planning和Motion Planning&#xff0c;以及低速记忆泊车的Planning&#xff08;最开始有15篇&#xff0c;目前逐渐更新到17篇&#xff09;。读者对整…

【微信小程序开发】小程序前后端交互--发送网络请求实战解析

✨✨ 欢迎大家来到景天科技苑✨✨ &#x1f388;&#x1f388; 养成好习惯&#xff0c;先赞后看哦~&#x1f388;&#x1f388; &#x1f3c6; 作者简介&#xff1a;景天科技苑 &#x1f3c6;《头衔》&#xff1a;大厂架构师&#xff0c;华为云开发者社区专家博主&#xff0c;…