SpringCloud-Ribbon：负载均衡(基于客户端)

6. Ribbon：负载均衡(基于客户端)

6.1 负载均衡以及Ribbon

Ribbon是什么？

  • Spring Cloud Ribbon 是基于Netflix Ribbon 实现的一套客户端负载均衡的工具。
  • 简单的说，Ribbon 是 Netflix 发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将 Netflix 的中间层服务连接在一起。Ribbon 的客户端组件提供一系列完整的配置项，如：连接超时、重试等。简单的说，就是在配置文件中列出 LoadBalancer (简称LB：负载均衡) 后面所有的及其，Ribbon 会自动的帮助你基于某种规则 (如简单轮询，随机连接等等) 去连接这些机器。我们也容易使用 Ribbon 实现自定义的负载均衡算法！

Ribbon能干嘛？

通过Ribbon的负载均衡(轮询、随机算法等)实现将10000个请求分配个多个服务注册中心（请求处理方）

在这里插入图片描述

  • LB，即负载均衡 (LoadBalancer) ，在微服务或分布式集群中经常用的一种应用。
  • 负载均衡简单的说就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA (高可用)。
  • 常见的负载均衡软件有 Nginx、Lvs 等等。
  • Dubbo、SpringCloud 中均给我们提供了负载均衡，SpringCloud 的负载均衡算法可以自定义。

负载均衡简单分类：

  • 集中式LB
    即在服务的提供方和消费方之间使用独立的LB设施，如Nginx(反向代理服务器)，由该设施负责把访问请求通过某种策略转发至服务的提供方！
  • 进程式 LB
    将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选出一个合适的服务器。
    Ribbon 就属于进程内LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址！

6.2 SpringCloud集成Ribbon

① 在springcloud-consumer-dept-80 添加 Ribbon和Eureka依赖

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

<!--Ribbon-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-ribbon</artifactId><version>1.4.6.RELEASE</version>
</dependency>
<!--Eureka: Ribbon需要从Eureka服务中心获取要拿什么-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId><version>1.4.6.RELEASE</version>
</dependency>

② 在application.yml 配置Eureka

在这里插入图片描述

# Eureka配置
eureka:client:register-with-eureka: false # 不向 Eureka注册自己，注册服务器就好service-url: # 从三个注册中心中随机取一个去访问defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

③在启动类的上添加@EnableEurekaClient ，启动Eureka

在这里插入图片描述

④ 自定义Spring配置类：ConfigBean.java 配置负载均衡实现RestTemplate

在这里插入图片描述

@Configuration
public class ConfigBean {//@Configuration -- spring  applicationContext.xml@LoadBalanced //配置负载均衡实现RestTemplate@Beanpublic RestTemplate getRestTemplate() {return new RestTemplate();}
}

⑤ 修改conroller：DeptConsumerController.java

在这里插入图片描述

//Ribbon:我们这里的地址，应该是一个变量，通过服务名来访问
//private static final String REST_URL_PREFIX = "http://localhost:8001";
private static final String REST_URL_PREFIX = "http://SPRINGCLOUD-PROVIDER-DEPT";

⑥测试结果：先启动7001、7002，再启动8001，最后客户端

在这里插入图片描述

6.3 使用Ribbon实现负载均衡

Ribben从服务注册中心获得可用的已注册服务列表，通过默认的轮询算法来实现负载均衡，选择服务提供者

流程图：

在这里插入图片描述

1、 新建两个服务提供者 ：8002、8003

2、新建两个数据库，参考8001，为另外两个Moudle添加pom.xml依赖 、resourece下的mybatis和application.yml配置，Java代码

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

3、启动所有服务测试(根据自身电脑配置决定启动服务的个数)，访问http://eureka7001.com:7002/查看结果

6.4 自定义负载均衡算法

在springcloud-provider-dept-80模块下的ConfigBean中进行配置

1.去查看IRule的源码，里面封装着许多负载均衡的算法，根据具体需求挑选使用就好

在这里插入图片描述

@Configuration
public class MyRule {@Beanpublic IRule myRule(){return new MyRandomRule();//默认是轮询RandomRule,现在自定义为自己的}
}

查看IRule的源码，会发现许多负载均衡的算法

在这里插入图片描述

2.自定义负载均衡算法的要求

在这里插入图片描述

注意：官网要求

在这里插入图片描述

在这里插入图片描述

注：不是配置类，是配置类的算法，不和主启动类同一目录，否则会被扫描到，所有的RibbenClient都会共享使用

3.在启动类上，加载我们自定义的Ribben类

在这里插入图片描述

注意：指定name=“具体的服务提供者的id”，指定自定义的Ribben类

//Ribbon 和 Eureka 整合以后，客户端可以直接调用，不用关心IP地址和端口号
@SpringBootApplication
@EnableEurekaClient
//在微服务启动的时候就能加载自定义的Ribbon类(自定义的规则会覆盖原有默认的规则)
@RibbonClient(name = "SPRINGCLOUD-PROVIDER-DEPT",configuration = MyRule.class)//开启负载均衡,并指定自定义的规则
public class DeptConsumer_80 {public static void main(String[] args) {SpringApplication.run(DeptConsumer_80.class, args);}
}

4、另建新的包，配置自定义负载均衡算法以bean形式注入Spring中

在这里插入图片描述

5、自定义算法类

在这里插入图片描述

①先理解随机算法的源码：

在这里插入图片描述

②制定自定义算法的效果

在这里插入图片描述

③具体的算法

在这里插入图片描述

自定义的规则 :参考源码，修改一下

public class MyRandomRule extends AbstractLoadBalancerRule {/*** 每个服务访问5次则换下一个服务(总共3个服务)* <p>* total=0,默认=0,如果=5,指向下一个服务节点* index=0,默认=0,如果total=5,index+1*/private int total = 0;//被调用的次数private int currentIndex = 0;//当前是谁在提供服务//@edu.umd.cs.findbugs.annotations.SuppressWarnings(value = "RCN_REDUNDANT_NULLCHECK_OF_NULL_VALUE")public Server choose(ILoadBalancer lb, Object key) {if (lb == null) {return null;}Server server = null;while (server == null) {if (Thread.interrupted()) {return null;}List<Server> upList = lb.getReachableServers();//获得当前活着的服务List<Server> allList = lb.getAllServers();//获取所有的服务int serverCount = allList.size();if (serverCount == 0) {/** No servers. End regardless of pass, because subsequent passes* only get more restrictive.*/return null;}//int index = chooseRandomInt(serverCount);//生成区间随机数//server = upList.get(index);//从或活着的服务中,随机获取一个//=====================自定义代码=========================if (total < 5) {server = upList.get(currentIndex);total++;} else {total = 0;currentIndex++;if (currentIndex > upList.size()) {currentIndex = 0;}server = upList.get(currentIndex);//从活着的服务中,获取指定的服务来进行操作}//======================================================if (server == null) {/** The only time this should happen is if the server list were* somehow trimmed. This is a transient condition. Retry after* yielding.*/Thread.yield();continue;}if (server.isAlive()) {return (server);}// Shouldn't actually happen.. but must be transient or a bug.server = null;Thread.yield();}return server;}protected int chooseRandomInt(int serverCount) {return ThreadLocalRandom.current().nextInt(serverCount);}@Overridepublic Server choose(Object key) {return choose(getLoadBalancer(), key);}@Overridepublic void initWithNiwsConfig(IClientConfig clientConfig) {// TODO Auto-generated method stub}
}

在这里插入图片描述

6、测试效果：

在这里插入图片描述

注意：

在这里插入图片描述

SpringCloud-Ribbon：负载均衡(基于客户端) 到此完结，笔者归纳、创作不易，大佬们给个3连再起飞吧

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/679234.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Flask基础学习2

Flask基础学习2

连接mysql数据库测试(专业版) [注意1&#xff1a;要导入text库&#xff0c;否则可能出现找不到select 1错误] [注意2&#xff1a;若出现下列问题&#xff0c;可按照模板代码的顺序db SQLAlchemy(app) 的位置] RuntimeError: Either SQLALCHEMY_DATABASE_URI or SQLALCHEMY_B…
阅读更多...
MMKV：轻巧高效的跨平台键值存储解决方案

MMKV：轻巧高效的跨平台键值存储解决方案

MMKV&#xff1a;轻巧高效的跨平台键值存储解决方案 引言 在移动应用的开发中&#xff0c;数据存储是一个至关重要的环节。随着移动应用的普及和功能的增多&#xff0c;应用需要存储和管理各种类型的数据&#xff0c;包括用户配置信息、缓存数据、临时状态等。传统的数据存储…
阅读更多...
acwing14期周赛---------安排时间（贪心+枚举）

acwing14期周赛---------安排时间（贪心+枚举）

贝茜独立经营着一家餐厅&#xff0c;她一天的营业时间可以分为 n 个时段&#xff0c;编号 1∼n。 在这一天的营业中&#xff0c;她一共接收到了 m 个客人的预约用餐订单&#xff0c;编号 1∼m。 其中&#xff0c;第 i 个订单的相关信息如下&#xff1a; 贝茜在第 si个时段接到该…
阅读更多...
python巧用定理判断素数

python巧用定理判断素数

目录 判断一个数n是否是素数 求一个数的素因数个数 求大于等于指定数的最小素数 在数论中有三个非常重要的关于素数的定理 1、任何数都可以表示成若干个素数的乘积 2、任意数的一个素因子如果小于根号n&#xff0c;那么另一个与其对应的素因子必然大于根号n。 3、除了2和…
阅读更多...
求小数的某一位(c++题解)

求小数的某一位(c++题解)

题目描述 分数化为小数后&#xff0c;小数点后第位的数字是多少&#xff1f; 输入格式 三个正整数&#xff0c;相邻两个数之间用单个空格隔开。 输出格式 一个数字。 样例 输入样例 复制1 2 1输出样例 复制5 ______________________________________________________…
阅读更多...
pytorch张量和numpy数组相互转换

pytorch张量和numpy数组相互转换

pytorch张量和numpy数组相互转换 &#x1f335;文章目录&#x1f335; &#x1f333;引言&#x1f333;&#x1f333;将numpy数组转换为Pytorch张量&#x1f333;1. 功能介绍2. 用法 &#x1f333;将Pytorch张量转换为numpy数组&#x1f333;1. 功能介绍2. 用法 &#x1f333;P…
阅读更多...
使用python写一个二叉树

使用python写一个二叉树

可以使用Python的类来实现二叉树&#xff0c;每个节点包括一个值和指向左右子节点的引用。 class Node:def __init__(self, value):self.value valueself.left Noneself.right Noneclass BinaryTree:def __init__(self, root):self.root Node(root)def insert(self, value…
阅读更多...
浅谈应该遵守的伦敦银交易规则

浅谈应该遵守的伦敦银交易规则

做伦敦银投资的朋友应遵守伦敦银交易规则&#xff0c;伦敦银交易规则不是指那些伦敦银交易技巧&#xff0c;而是在这个市场中要遵循的一些约定&#xff0c;下面我们就来讨论一下。 风险管理。风险管理即指投资者控制自己一笔乃至整体交易的风险&#xff0c;没有风险管理意识的投…
阅读更多...
JavaSE——方法（1/2）-介绍、方法的各种形式、使用的要求

JavaSE——方法（1/2）-介绍、方法的各种形式、使用的要求

目录 方法的介绍 方法的其他形式 方法使用的要求 方法的介绍 方法是什么 方法是一种语法结构&#xff0c;它可以把一段代码封装成一个功能&#xff0c;以便重复调用。 方法的完整格式 修饰符 返回值类型 方法名 ( 形参列表 ) { 方法体代码(需要执行的功能代码) return…
阅读更多...
OpenCV-36 多边形逼近与凸包

OpenCV-36 多边形逼近与凸包

目录 一、多边形的逼近 二、凸包 一、多边形的逼近 findContours后的轮廓信息countours可能过于复杂不平滑&#xff0c;可以用approxPolyDP函数对该多边形曲线做适当近似&#xff0c;这就是轮廓的多边形逼近。 apporxPolyDP就是以多边形去逼近轮廓&#xff0c;采用的是Doug…
阅读更多...
面试经典150题——三数之和

面试经典150题——三数之和

​"The road to success and the road to failure are almost exactly the same." - Colin R. Davis 1. 题目描述 2. 题目分析与解析 2.1 思路一——暴力方法 因为三个数相加为0&#xff0c;那么说明其中两个加数的和与另一个加数为相反数则满足题意。所以可以得到…
阅读更多...
ClickHouse时区

ClickHouse时区

clickhouse数据库的时间是UTC时间。服务器默认的是上海时间。 sudo vim /etc/clickhouse-server/config.xml clickhouse默认的时区是注释的就是UTC时间 %F 表示日期&#xff0c;格式为 YYYY-MM-DD。%T 表示时间&#xff0c;格式为 HH:MM:SS。 因此&#xff0c;formatDateT…
阅读更多...
主干网络篇 | YOLOv5/v7 更换主干网络为 VGG13 / VGG16 / VGG19 | 对比实验必备

主干网络篇 | YOLOv5/v7 更换主干网络为 VGG13 / VGG16 / VGG19 | 对比实验必备

论文地址：https://arxiv.org/pdf/1409.1556.pdf 在这项工作中，我们研究了卷积网络深度对其在大规模图像识别环境中准确性的影响。我们的主要贡献是对使用非常小（33）卷积滤波器的架构的不断增加深度的网络进行了彻底评估，这表明通过将深度推进到16-19个权重层，可以在先前…
阅读更多...
第72讲后台管理Container布局实现

第72讲后台管理Container布局实现

新建layout目录 登录成功后&#xff0c;跳转layout布局容器页面 login页面&#xff1a; 导入router import router from "/router";登录成功&#xff0c;跳转后台管理页面 选用布局容器&#xff1a; <template><div class"common-layout">…
阅读更多...
javaweb物业管理系统jsp项目

javaweb物业管理系统jsp项目

文章目录 物业管理系统一、系统演示二、项目介绍三、系统部分功能截图四、部分代码展示五、底部获取项目源码&#xff08;9.9&#xffe5;带走&#xff09; 物业管理系统 可用作javaweb项目、servlet项目、jsp项目的项目设计 一、系统演示 物业管理系统 二、项目介绍 语言&a…
阅读更多...
Vue3中Setup概述和使用(三)

Vue3中Setup概述和使用(三)

一、引入Setup 1、Person.Vue 与Vue3编写简单的App组件(二) 中的区别是&#xff1a;取消data、methods等方法,而是将数据和方法定义全部放进setup中。 <template><div class"person"><h1>姓名:{{name}}</h1><h1>年龄:{{age}}</h…
阅读更多...
SQL、Hive中的SQL和Spark中的SQL三者联系与区别

SQL、Hive中的SQL和Spark中的SQL三者联系与区别

SQL、Hive中的SQL和Spark中的SQL&#xff08;即SparkSQL&#xff09;都是用于处理和分析数据的查询语言&#xff0c;但它们在实现、性能、应用场景等方面存在一些明显的区别和联系。 联系&#xff1a; 分布式计算&#xff1a;三者都是分布式计算的引擎&#xff0c;都可以在大数…
阅读更多...
2023-12蓝桥杯STEMA 考试 Python 中高级试卷解析

2023-12蓝桥杯STEMA 考试 Python 中高级试卷解析

蓝桥杯STEMA 考试 Python 中高级试卷（12 月） 一、选择题 第一题 以下哪项是取余运算符？（ C ） A、* B、// C、% D、+ 第二题 已知：s = "python"，执行 print(s[::2])语句后，输出的结果是（ B ）。 A 、 python B 、pto C 、 nohtyp D 、 yhn …
阅读更多...
像素、分辨率、公差的概念

像素、分辨率、公差的概念

像素 &#xff08;Pixel&#xff09; 像素是指在由一个数字序列表示的图像中的一个最小单位。像素的多少表明相机所含有的感光元件的多少。所谓 200 万像素 CCD 就是一个由 200 万个光电二极管构成的集合体。一台100万像素的相机拍摄的照片洗成5寸比洗成六寸清晰点。80万 1024…
阅读更多...
Acwing---839. 模拟堆

Acwing---839. 模拟堆

模拟堆 1.题目2.基本思想3.代码实现 1.题目 维护一个集合&#xff0c;初始时集合为空&#xff0c;支持如下几种操作&#xff1a; I x&#xff0c;插入一个数 x&#xff1b;PM&#xff0c;输出当前集合中的最小值&#xff1b;DM&#xff0c;删除当前集合中的最小值&#xff08…
阅读更多...
最新文章

Copyright @ 2022~2023