【SpringCloud】Ribbon负载均衡的基本原理与使用

news2024/11/16 8:28:07

【SpringCloud】Ribbon负载均衡的基本原理与使用

一、负载均衡原理

二、源码解析

@LoadBalanced

IDEA源码跟踪

负载均衡源码小结

三、负载均衡策略

负载均衡策略

策略规则解析

自定义负载均衡策略

(1)代码方式

(2)配置文件方式

四、饥饿加载


【SpringCloud】Ribbon负载均衡的基本原理与使用

一、负载均衡原理

SpringCloud底层其实是利用了一个名为Ribbon的组件,来实现负载均衡功能的

上一节的文章中,我们在 OrderApplication启动类中添加了 @LoadBalanced 注解,就实现了负载均衡原理

具体如下所示: 

OrderService 向 UserService 发送访问请求,是通过 http://userservice/user/1 这个地址访问的,但是显然这不是一个真实的地址!

显然,要想访问成功,一定会有一个中间体来做一些处理,这里的这个中间体就是 Ribbon

由于所有服务都会注册到Eureka中,所以Ribbon会 “拿着userservice” 向Eureka拉取服务,这里会返回两个服务,那么Ribbon就会对这两个服务做负载均衡!!!

二、源码解析

@LoadBalanced

@Bean
@LoadBalanced
public RestTemplate restTemplate() {
    return new RestTemplate();
}

这里对 restTemplate() 加了一个注解@LoadBalanced,表示它发出的请求会被Ribbon处理(拦截)!

IDEA源码跟踪

这个拦截的动作是由 LoadBalancerInterceptor类来处理

public class LoadBalancerInterceptor implements ClientHttpRequestInterceptor {
    ...
}

LoadBalancerInterceptor拦截器类 实现了 ClientHttpRequestInterceptor接口,就一定要重写 intercept()方法

@FunctionalInterface
public interface ClientHttpRequestInterceptor {
	ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution)
			throws IOException;
}

ClientHttpRequestInterceptor接口中只有一个方法——intercept()

所以,我们其实主要关注 LoadBalancerInterceptor intercept() 方法,其负载均衡是的实现就是看 intercept() 里面的逻辑。

// LoadBalancerInterceptor
@Override
public ClientHttpResponse intercept(final HttpRequest request, final byte[] body,
                                    final ClientHttpRequestExecution execution) throws IOException {
    // 获取到URL地址 http://userservice/user/1
    final URI originalUri = request.getURI();

    // 解析出服务名 userservice(用于后面的拉取)
    String serviceName = originalUri.getHost();
    Assert.state(serviceName != null,
            "Request URI does not contain a valid hostname: " + originalUri);
    
    // 把解析出来的服务userservice 交给loadBalancer进行处理
    return this.loadBalancer.execute(serviceName,
            this.requestFactory.createRequest(request, body, execution));
}

在 intercept() 中通过解析URL地址,获取服务名,最后将服务名交给 loadBalancer execute() 方法处理

public <T> T execute(String serviceId, LoadBalancerRequest<T> request, Object hint)
        throws IOException {
    ILoadBalancer loadBalancer = getLoadBalancer(serviceId);

    // 重点!!!
    // 选8081还是8082,根据getServer() 里面规则来决定的
    Server server = getServer(loadBalancer, hint);
    if (server == null) {
        throw new IllegalStateException("No instances available for " + serviceId);
    }
    RibbonLoadBalancerClient.RibbonServer ribbonServer = new RibbonLoadBalancerClient.RibbonServer(serviceId, server,
            isSecure(server, serviceId),
            serverIntrospector(serviceId).getMetadata(server));

    return execute(serviceId, ribbonServer, request);
}

getLoadBalancer() 可以获取一个DynamicServerListLoadBalancer(动态服务列表负载均衡器),里面会存储根据 服务名(服务ID) userservice 所获取的服务列表,这里有2个,分别是8081和8082!

负载均衡重点主要是在 getServer() 里面实现的!

// 有很多实现类,假设是 BaseLoadBalancer 
public Server chooseServer(Object key) {
    if (counter == null) {
        counter = createCounter();
    }
    counter.increment();
    if (rule == null) {
        return null;
    } else {
        try {
            // 选择一个!!!
            return rule.choose(key);
        } catch (Exception e) {
            logger.warn("LoadBalancer [{}]:  Error choosing server for key {}", name, key, e);
            return null;
        }
    }
}

会在这里做出选择,具体选择哪一个是在IRule里面做的(基于我们指定的、或者默认的规则,做出选择)! 

负载均衡源码小结

三、负载均衡策略

负载均衡策略

负载均衡的规则都定义在IRule接口中,而IRule有很多不同的实现类

继承关系如下所示:

策略规则解析

默认的实现就是ZoneAvoidanceRule,是一种轮询方案

自定义负载均衡策略

通过定义IRule实现可以修改负载均衡规则,有两种方式

(1)代码方式

在order-service中的OrderApplication类中,定义一个新的IRule的Bean

@Bean
public IRule randomRule(){
    return new RandomRule();
}

(2)配置文件方式

在order-service的application.yml文件中,添加新的配置也可以修改规则,具体如下:

userservice: # 给某个微服务配置负载均衡规则,这里是userservice服务
  # 负载均衡规则
  ribbon:  
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule  

注意:一般用默认的负载均衡规则,不做修改。  

四、饥饿加载

Ribbon默认是采用懒加载,即第一次访问时才会去创建LoadBalanceClient,请求时间会很长。

饥饿加载则会在项目启动时创建,降低第一次访问的耗时

开启饥饿加载,在 application.yml 中添加配置

ribbon:
  eager-load:
    enabled: true
    clients: userservice

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Unity的Bounds(包围盒)简记

Unity的Bounds&#xff08;包围盒&#xff09;简记一、Bounds(包围盒)概述1.什么是包围盒?2.包围盒的类型2.1 AABB包围盒(Axis-aligned bounding box)2.2 包围球(Sphere)2.3 OBB方向包围盒(Oriented bounding box)2.4 FDH固定方向凸包(Fixed directions hulls或k-DOP)2.5 包围…

云服务器部署前后端分离项目(若依)详细教程

第一次在Linux云服务器上部署前后端分离项目&#xff0c;查了很多资料和视频&#xff0c;踩了许多坑。成功实现部署若依的前后端分离项目后&#xff0c;想记录一下前后端部署的过程&#xff0c;供学习的小伙伴参考。 目录1. 环境准备2. 开放端口3. 下载前后端项目4. 前端部署5.…

Linux部署Kafka及常见问题记录

Linux部署Kafka及常见问题记录kafka 使用场景Kafka 基本概念BrokerTopic(主题)Partition(分区)ProducerConsumerConsumer Group&#xff08;消费者群组&#xff09;offset 偏移量Linux 安装&启动 kafka修改核心配置文件创建数据存放目录启动验证 kafk 是否启动成功Topic (主…

AX7A200教程(1):DDR3仿真平台搭建(一)

本章节主要调用官方的MIG控制器&#xff0c;并使用官方的MIG控制器进行仿真&#xff0c;开发环境vivado2020.1鉴于很多童鞋无法仿真自己新建的DDR工程&#xff0c;即使使用modelsim仿真也仿真失败&#xff0c;本例程着重在vivado中对自己新建的带DDR3的工程进行仿真。新建DDR3工…

Python SciPy 插值及其他各种插值法

SciPy 插值什么是插值&#xff1f;在数学的数值分析领域中&#xff0c;插值&#xff08;英语&#xff1a;interpolation&#xff09;是一种通过已知的、离散的数据点&#xff0c;在范围内推求新数据点的过程或方法。简单来说插值是一种在给定的点之间生成点的方法。例如&#x…

【MySQL】MyCAT入门综述◆掌握MyCAT的基础概念、功能及适用场景

&#x1f4eb;作者简介&#xff1a;小明java问道之路&#xff0c;专注于研究 Java/Liunx内核/C及汇编/计算机底层原理/源码&#xff0c;就职于大型金融公司后端高级工程师&#xff0c;擅长交易领域的高安全/可用/并发/性能的架构设计与演进、系统优化与稳定性建设。 &#x1f4…

二叉树知识概括锦囊(一)

作者&#xff1a;爱塔居 专栏&#xff1a;数据结构 作者简介&#xff1a;大三学生&#xff0c;希望跟大家一起进步&#xff01; 文章目录 目录 文章目录 一、树形结构 二、树的基础知识 三、二叉树 3.1 概念 3.2 特殊的二叉树 3.3 二叉树的性质 四、习题挑战 一、树形结构 树是…

【论文速递】IJCV2022 - CRCNet:基于交叉参考和区域-全局条件网络的小样本分割

【论文速递】IJCV2022 - CRCNet:基于交叉参考和区域-全局条件网络的小样本分割 【论文原文】&#xff1a;CRCNet: Few-shot Segmentation with Cross-Reference and Region-Global Conditional Networks 获取地址&#xff1a;https://link.springer.com/article/10.1007/s112…

BACnet协议详解——应用层说明一

文章目录写在前面1. 应用层模型1.1 需确认的应用层服务1.2 无需确认的应用层服务2 BACnet报文的分段2.1 报文分段规则2.1.1 APDU数据流的分段规则2.1.2 APDU最大长度的确定2.1.3 可接受的最大分段数2.2 分段协议控制信息&#xff08;PCI&#xff09;写在前面 年关将至&#xf…

分享77个PHP源码,总有一款适合您

PHP源码 分享77个PHP源码&#xff0c;总有一款适合您 下面是文件的名字&#xff0c;我放了一些图片&#xff0c;文章里不是所有的图主要是放不下...&#xff0c; 77个PHP源码下载链接&#xff1a;https://pan.baidu.com/s/12hh-lhIVPL1bZw-d2sfVlQ?pwdvhqj 提取码&#xff…

selenium 操作已经打开的浏览器

有时通过selenium打开网站时&#xff0c;发现有些网站需要扫码登录&#xff0c;就很头疼&#xff0c;导致爬虫进展不下去。 如果继续想使用selenium进行数据抓取&#xff0c;下一步应该怎么办呢&#xff1f; 步骤一&#xff1a;创建文件夹 在电脑的D盘或者F盘或者合适的盘创建…

《Python数据分析基础教程:NumPy学习指南:第二版》读书笔记

内容 主要介绍了NumPy库中的函数。 组成方式 用非常零散的知识点串联成章节。 内容摘要 极简地展示了章节中所运用的函数。 第一章 arrange函数创建NumPy数组。 第二章 NumPy特性 在NumPy中&#xff0c;复数的虚部是用j表示的。如果数组中包含复数元素&#xff0c;则…

VMware vSphere 中 Clone 与 Template 的区别

VMware vSphere 中 Clone 与 Template 的区别 Clone&#xff08;克隆&#xff09;Template&#xff08;模板&#xff09;克隆在克隆过程中为正在运行的虚拟机创建一个精确的副本模板作为具有根据组织标准预先定义的配置的虚拟机的基线映像。克隆虚拟机使用相同的配置和安装的软…

【C语言初阶】指针

文章目录1.指针是什么2.指针和指针类型2.1指针的解引用2.1指针类型的意义3.野指针3.1野指针成因3.2如何规避野指针4.指针运算4.1指针-整数4.2指针-指针4.3指针的关系运算5.指针和数组6.二级指针7.指针数组1.指针是什么 指针理解的2个要点&#xff1a; 指针是内存中一个最小单元…

【GD32F427开发板试用】+使用USBFS轻松实现HID键盘应用

本篇文章来自极术社区与兆易创新组织的GD32F427开发板评测活动&#xff0c;更多开发板试用活动请关注极术社区网站。作者&#xff1a;不锈钢铁侠 前言 最近有项目需要用到键盘自动输入功能&#xff0c;提升工作效率。故使用该开发板实现自定义输入内容并通过按键控制自动通过u…

STM32——外部中断

目录 外部中断简述 什么是外部中断 传统单片机与新型单片机外部中断区别 STM32外部中断请求 STM32中断线与IO口的对应 STM32 中断服务函数 外部中断与中断服务函数的对应 中断服务函数列表 STM32外部中断程序编写 常用的库函数 外部中断的一般配置步骤 外部中断简…

【ArcGIS微课1000例】0058:波段合成(CompositeBands)工具的使用

波段合成工具常见于遥感软件,例如Envi和Erdas等,用于将多个单波段数据合成为一个多波段数据集,在ArcGIS中也提供了波段合成的工具,使用灵活方便。 文章目录 一、波段合成工具介绍二、波段合成工具案例1. 输出Esri Grid格式2. 输出tif格式3. 输出jgp格式4. 输出其它格式一、…

sqlite 使用distinct时组合索引可能不是你想的那样

目录先来唠唠嗑吧~那一探究竟吧&#xff01;表结构及索引信息我的查询场景到底命中什么索引了&#xff1f;简单小结下~先来唠唠嗑吧~ 在使用sqlite作为词条数据库查询数据&#xff0c;发现有的sql执行很快&#xff0c;有的sql执行很慢&#xff0c;你以为是没有走索引吗&#x…

深入浅出进程控制

文章目录进程控制浅谈fork写时拷贝fork调用失败的原因进程终止进程退出的场景进程常见退出方法查看进程退出码echo $? :查看进程退出码exit和_exit进程等待进程等待的方法waitwaitpid获取子进程status宏定义查看进程是否正常退出&#xff0c;查看退出码再谈僵尸进程浅谈阻塞等…

基于.Net Core开发的支付SDK,简化支付功能开发

更多开源项目请查看&#xff1a;一个专注推荐.Net开源项目的榜单 在我们做项目中&#xff0c;不管是电商系统、外卖系统、还是上门维修系统等等&#xff0c;都需要支付功能&#xff0c;这就需要我们与第三方支付平台进行对接&#xff0c;但是第三方平台文档&#xff0c;往往都存…