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://xiahunao.cn/news/2775916.html

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

【Java EE】----SpringBoot的日志文件

【Java EE】----SpringBoot的日志文件

1.SpringBoot使用日志 先得到日志对象通过日志对象提供的方法进行打印 2.打印日志的信息 3.日志级别 作用&#xff1a; 可以筛选出重要的信息不同环境实现不同日志级别的需求 ⽇志的级别分为&#xff1a;&#xff08;1-6级别从低到高&#xff09; trace&#xff1a;微量&#…
阅读更多...
SCI 1区论文：Segment anything in medical images（MedSAM）[文献阅读]

SCI 1区论文：Segment anything in medical images（MedSAM）[文献阅读]

基本信息 标题&#xff1a;Segment anything in medical images中文标题&#xff1a;分割一切医学图像发表年份: 2024年1月期刊/会议: Nature Communications分区&#xff1a; SCI 1区IF&#xff1a;16.6作者: Jun Ma; Bo Wang(一作&#xff1b;通讯)单位&#xff1a;加拿大多…
阅读更多...
排序算法---插入排序

排序算法---插入排序

原创不易&#xff0c;转载请注明出处。欢迎点赞收藏~ 插入排序是一种简单直观的排序算法&#xff0c;它的基本思想是将待排序的元素分为已排序和未排序两部分&#xff0c;每次从未排序部分中选择一个元素插入到已排序部分的合适位置&#xff0c;直到所有元素都插入到已排序部分…
阅读更多...
微软技术专家带你学 AI｜Azure OpenAI 服务

微软技术专家带你学 AI｜Azure OpenAI 服务

点击蓝字 关注我们 编辑&#xff1a;Alan Wang 排版&#xff1a;Rani Sun 微软技术专家带你学 AI 新的一年&#xff0c;为帮助开发者们在 Azure 上掌握人工智能&#xff0c;我们特别带来「微软技术专家带你学 AI」系列&#xff0c;通过4期的课程&#xff0c;带大家从机器学习的…
阅读更多...
ES高可用架构涉及常用功能整理

ES高可用架构涉及常用功能整理

ES高可用架构涉及常用功能整理 1. es的高可用系统架构和相关组件2. es的核心参数2.1 常规配置2.2 特殊优化配置2.2.1 数据分片按ip打散2.2.2 数据分片机架感知2.2.3 强制要求数据分片机架感知2.2.4 写入线程池优化2.2.5 分片balance优化2.2.6 限流控制器优化 3. es常用命令3.1 …
阅读更多...
在屏蔽任何FRP环境下从零开始搭建安全的FRP内网穿透服务

在屏蔽任何FRP环境下从零开始搭建安全的FRP内网穿透服务

背景 本人目前在境外某大学读博&#xff0c;校园网屏蔽了所有内网穿透的工具的数据包和IP访问&#xff0c;为了实现在家也能远程访问服务器&#xff0c;就不得不先开个学校VPN&#xff0c;再登陆。我们实验室还需要访问另一个大学的服务器&#xff0c;每次我都要去找另一个大学…
阅读更多...
海外云手机——平台引流的重要媒介

海外云手机——平台引流的重要媒介

随着互联网的飞速发展&#xff0c;跨境电商、短视频引流以及游戏行业等领域正经历着迅猛的更新换代。在这个信息爆炸的时代&#xff0c;流量成为至关重要的资源&#xff0c;而其中引流环节更是关乎业务成功的关键。海外云手机崭露头角&#xff0c;成为这一传播过程中的重要媒介…
阅读更多...
消息中间件：Puslar、Kafka、RabbigMQ、ActiveMQ

消息中间件：Puslar、Kafka、RabbigMQ、ActiveMQ

消息队列 消息队列&#xff1a;它主要用来暂存生产者生产的消息&#xff0c;供后续其他消费者来消费。 它的功能主要有两个&#xff1a; 暂存&#xff08;存储&#xff09;队列&#xff08;有序&#xff1a;先进先出 从目前互联网应用中使用消息队列的场景来看&#xff0c;…
阅读更多...
【龙年大礼】| 2023中国开源年度报告！

【龙年大礼】| 2023中国开源年度报告！

【中国开源年度报告】由开源社从 2015 年发起&#xff0c;是国内首个结合多个开源社区、高校、媒体、风投、企业与个人&#xff0c;以纯志愿、非营利的理念和开源社区协作的模式&#xff0c;携手共创完成的开源研究报告。后来由于一些因素暂停&#xff0c;在 2018 年重启了这个…
阅读更多...
Qt PCL学习（二）：点云读取与保存

Qt PCL学习（二）：点云读取与保存

注意事项 版本一览&#xff1a;Qt 5.15.2 PCL 1.12.1 VTK 9.1.0前置内容&#xff1a;Qt PCL学习&#xff08;一&#xff09;&#xff1a;环境搭建 0. 效果演示 1. pcl_open_save.pro QT core guigreaterThan(QT_MAJOR_VERSION, 4): QT widgets// 添加下行代码&#…
阅读更多...
[word] word2019段落中创建纵横混排的方法图解教程 #知识分享#其他#职场发展

[word] word2019段落中创建纵横混排的方法图解教程 #知识分享#其他#职场发展

word2019段落中创建纵横混排的方法图解教程 有时候在word文档中需要让文字纵横混排&#xff0c;word2019正好为我们带来了纵横混排的功能了&#xff0c;今天我们就来给大家介绍一下word2019段落中创建纵横混排的方法。 步骤1&#xff1a;打开Word文档&#xff0c;选中需要纵向…
阅读更多...
MT4和MT5中如何创建挂单，很简单，fpmarkets1秒教会

MT4和MT5中如何创建挂单，很简单，fpmarkets1秒教会

其实在MT4和MT5中创建挂单是非常容易的&#xff0c;今天fpmarkets1秒教会&#xff0c;接下来一步一步的演示&#xff1a; 首先单击新订单&#xff0c;将出现设置窗口。在“类型”选项卡中选择“按待定顺序”。 接着选择挂单的类型。选择买入止损单&#xff0c;并指定订单执行的…
阅读更多...
【Leetcode】236. 二叉树的最近公共祖先

【Leetcode】236. 二叉树的最近公共祖先

文章目录 题目思路代码结果 题目 题目链接 给定一个二叉树, 找到该树中两个指定节点的最近公共祖先。 百度百科中最近公共祖先的定义为&#xff1a;“对于有根树 T 的两个节点 p、q&#xff0c;最近公共祖先表示为一个节点 x&#xff0c;满足 x 是 p、q 的祖先且 x 的深度尽可…
阅读更多...
Python爬虫http基本原理#2

Python爬虫http基本原理#2

Python爬虫逆向系列&#xff08;更新中&#xff09;&#xff1a;http://t.csdnimg.cn/5gvI3 HTTP 基本原理 在本节中&#xff0c;我们会详细了解 HTTP 的基本原理&#xff0c;了解在浏览器中敲入 URL 到获取网页内容之间发生了什么。了解了这些内容&#xff0c;有助于我们进一…
阅读更多...
攻防世界 CTF Web方向 引导模式-难度1 —— 1-10题 wp精讲

攻防世界 CTF Web方向 引导模式-难度1 —— 1-10题 wp精讲

目录 view_source robots backup cookie disabled_button get_post weak_auth simple_php Training-WWW-Robots view_source 题目描述: X老师让小宁同学查看一个网页的源代码&#xff0c;但小宁同学发现鼠标右键好像不管用了。 不能按右键&#xff0c;按F12 robots …
阅读更多...
备战蓝桥杯---搜索（完结篇）

备战蓝桥杯---搜索（完结篇）

再看一道不完全是搜索的题&#xff1a; 解法1&#xff1a;贪心并查集&#xff1a; 把冲突事件从大到小排&#xff0c;判断是否两个在同一集合&#xff0c;在的话就返回&#xff0c;不在的话就合并。 下面是AC代码&#xff1a; #include<bits/stdc.h> using namespace …
阅读更多...
CTF--Web安全--SQL注入之‘绕过方法’

CTF--Web安全--SQL注入之‘绕过方法’

一、什么是绕过注入 众所周知&#xff0c;SQL注入是利用源码中的漏洞进行注入的&#xff0c;但是有攻击手段&#xff0c;就会有防御手段。很多题目和网站会在源码中设置反SQL注入的机制。SQL注入中常用的命令&#xff0c;符号&#xff0c;甚至空格&#xff0c;会在反SQL机制中…
阅读更多...
从github上拉取项目到pycharm中

从github上拉取项目到pycharm中

有两种方法&#xff0c;方法一较为简单&#xff0c;方法二用到了git bash&#xff0c;推荐方法一 目录 有两种方法&#xff0c;方法一较为简单&#xff0c;方法二用到了git bash&#xff0c;推荐方法一方法一&#xff1a;方法二&#xff1a; 方法一&#xff1a; 在github上复制…
阅读更多...
【开源】JAVA+Vue.js实现高校实验室管理系统

【开源】JAVA+Vue.js实现高校实验室管理系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、研究内容2.1 实验室类型模块2.2 实验室模块2.3 实验管理模块2.4 实验设备模块2.5 实验订单模块 三、系统设计3.1 用例设计3.2 数据库设计 四、系统展示五、样例代码5.1 查询实验室设备5.2 实验放号5.3 实验预定 六、免责说明 一、摘…
阅读更多...
基于鲲鹏服务器的LNMP配置

基于鲲鹏服务器的LNMP配置

基于鲲鹏服务器的LNMP配置 系统 Centos8 # cat /etc/redhat-release CentOS Linux release 8.0.1905 (Core) 卸载已经存在的旧版本的安装包 # rpm -qa | grep php #查看已经安装的PHP旧版本# rpm -qa | grep php | xargs rpm -e #卸载已经安装的旧版&#xff0c;如果提示有…
阅读更多...
最新文章

Copyright @ 2022~2023