SpringCloud入门实战(五)-集成Ribbon
创始人
2024-05-19 19:55:03
0

一、Ribbon简介

Spring Cloud Ribbon是Netflix发布的开源项目,主要功能是提供客户端软件负载均衡算法和服务调用。Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等。简单地说,就是在配置文件中列出Load Balancer(简称LB)后面所有机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随机连接等)去连接这些机器。我们很容易使用Ribbon实现自定义的负载均衡算法

由官网https://github.com/Netflix/ribbon可知,Ribbon也进入维护中了,但是生产中大量使用中,还是比较优秀,不是立刻退出技术舞台的时刻。
在这里插入图片描述

Tip:未来可替换方案趋势:Spring 的LoadBalancer
Ribbon=负载均衡+RestTemplate

二、Ribbon和Nginx负载均衡区别

负载均衡:简单地说就是将用户的请求平均分摊到多个服务上,从而达到系统的HA(高可用)。

常见的负载均衡软件有Nginx,LVS,硬件F5等。

1、Ribbon和Nginx负载均衡区别:

  • ​Nginx是服务器负载均衡,客户端所有请求都会交给Nginx,然后由Nginx实现转发请求。即负载均衡是由服务端实现的。

  • Ribbon本地负载均衡,在调用微服务接口时候,会在注册中心上获取注册信息服务列表之后缓存到JVM本地,从而在本地实现RPC远程服务调用技术

2、Ribbon负载均衡

  • 进程内LB将LB逻辑集成到消费方,消费方从服务注册中心获知有哪些地址可用,然后再从这些地址中选择出一台合适的服务器。它只是一个类库,集成于消费方进程。
  • 集中式LB:即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件,如F5,也可以是软件,如Nginx),由该设施负责把访问请求通过某种策略转发至服务提供方。

eg:我们的order调用payment工程,ribbon应该在我们的order服务消费方

三、RestTemplate

RestTemplate的一些方法 :
获取数据结果可通过 RestTemplate 的getForObjectgetForEntity 发送数据postForObject,getForEntity 中可以获取返回的状态码、请求头等信息,通过 getBody 获取响应的内容。其余的和 getForObject 一样,也是有 3 个重载的实现:

@RestController
@RequestMapping("/consumer")
@Slf4j
public class OrderController {//public static final String PAYMENT_URL = "http://localhost:8001";public static final String PAYMENT_URL = "http://CLOULD-PAYMENT";@Resourceprivate RestTemplate restTemplate;@PostMapping("/order")public CommonResult createOrder(@RequestBody Payment payment) {return restTemplate.postForObject(PAYMENT_URL + "/payment", payment, CommonResult.class);}@GetMapping("/order/{id}")public CommonResult getOrderPayment(@PathVariable("id") Long id) {return restTemplate.getForObject(PAYMENT_URL + "/payment/" + id, CommonResult.class);}@GetMapping("/order/getForEntity/{id}")public CommonResult getOrderPayment2(@PathVariable("id") Long id) {ResponseEntity entity = restTemplate.getForEntity(PAYMENT_URL + "/payment/" + id, CommonResult.class);if (entity.getStatusCode().is2xxSuccessful()) {return entity.getBody();} else {return new CommonResult<>(444, "操作失败");}}
}

四、Ribbon核心组件IRule

Ribbon在工作时分为两步
第一步:先选择 EurekaServer,它优先选择在同一个区域内负载较少的Server;
第二步:再根据用户指定的策略,在从Server取到的服务注册列表中选择一个地址;
其中Ribbon提供了多种策略,比如轮询、随机、根据响应时间加权。

1、Ribbon与Eureka

spring-cloud-starter-netflix-eureka-client3.0.x版本以前是包含对ribbon的依赖的,官方内置了随机和轮询负载均衡策略,所以不用额外引入ribbon依赖也可以使用,但是Spring Cloud在2020.0版本后就移除了Ribbon,用的是 loadbalancer.。

 org.springframework.cloudspring-cloud-starter-netflix-eureka-client

在这里插入图片描述
在这里插入图片描述

由于我们之前搭建的工程都是基于最新版本的springcloud 2021.0.3版本,导入Eureka依赖spring-cloud-starter-netflix-eureka-client后检查不到Ribbon的依赖,无法查看IRule接口代码,是使用LoadBalancer代替的Ribbon。

所以我们新搭建一个SpringCloud 2020版本以下的工程学习Ribbon,注意引入的依赖:
父pom:

 org.springframework.bootspring-boot-dependencies2.0.2.RELEASEpomimportorg.springframework.cloudspring-cloud-dependenciesFinchley.RELEASEpomimport

子pom:

 org.springframework.cloudspring-cloud-starter-netflix-eureka-client

IRule接口在ribbon-loadbalancer包中,下载源码,可以查看IRule类图
在这里插入图片描述

2、IRule 简介

IRule 是一个接口。其作用是:根据特定算法从服务列表中选取一个要访问的服务,Ribbon默认的算法为轮询算法

IRule类图
在这里插入图片描述
Ribbon中的7中负载均衡算法:

  • com.netflix.loadbalancer.RoundRobinRule:轮询
  • com.netflix.loadbalancer.RandomRule:随机
  • com.netflix.loadbalancer.RetryRule:先按照RoundRobinRule的策略获取服务,如果获取服务失败则在指定时间内会进行重试
  • WeightedResponseTimeRule :对RoundRobinRule的扩展,响应速度越快的实例选择权重越大,越容易被选择
  • BestAvailableRule :会先过滤掉由于多次访问故障而处于断路器跳闸状态的服务,然后选择一个并发量最小的服务
  • AvailabilityFilteringRule :先过滤掉故障实例,再选择并发较小的实例
  • ZoneAvoidanceRule:默认规则,复合判断server所在区域的性能和server的可用性选择服务器

相关内容

热门资讯

监控摄像头接入GB28181平... 流程简介将监控摄像头的视频在网站和APP中直播,要解决的几个问题是:1&...
Windows10添加群晖磁盘... 在使用群晖NAS时,我们需要通过本地映射的方式把NAS映射成本地的一块磁盘使用。 通过...
protocol buffer... 目录 目录 什么是protocol buffer 1.protobuf 1.1安装  1.2使用...
在Word、WPS中插入AxM... 引言 我最近需要写一些文章,在排版时发现AxMath插入的公式竟然会导致行间距异常&#...
【PdgCntEditor】解... 一、问题背景 大部分的图书对应的PDF,目录中的页码并非PDF中直接索引的页码...
Fluent中创建监测点 1 概述某些仿真问题,需要创建监测点,用于获取空间定点的数据࿰...
educoder数据结构与算法...                                                   ...
MySQL下载和安装(Wind... 前言:刚换了一台电脑,里面所有东西都需要重新配置,习惯了所...
修复 爱普生 EPSON L4... L4151 L4153 L4156 L4158 L4163 L4165 L4166 L4168 L4...
MFC文件操作  MFC提供了一个文件操作的基类CFile,这个类提供了一个没有缓存的二进制格式的磁盘...