• SpringCloud-2.服务调用（Ribbon、OpenFeign）

    目录

    一、Ribbon负载均衡与服务调用

    1.1 概述

    1.1.1 LB负载均衡(Load Balance)是什么

    1.1.2 集中式LB

    1.1.3 进程内LB

    1.1.4 Ribbon本地负载均衡客户端 VS Nginx服务端负载均衡区别

    1.2 二说RestTemplate

    1.3 IRule接口（负载均衡算法）

    1.3.1 介绍

    1.3.2 使用

    1.3.2 负载均衡算法原理（轮询为例）

    二、OpenFeign服务接口调用

    2.1 概述

    2.1.1 啥是Feign

    2.1.1 Feign能干啥

    2.1.2 Feign 和 OpenFeign区别

    2.2 使用

    2.3 超时设置

    2.4 日志功能

    一、Ribbon负载均衡与服务调用

    1.1 概述

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

            一句话来说，Ribbon的功能就是负载均衡+RestTemplate调用

            （最新的Eureka依赖包中已经集成了Ribbon）

    1.1.1 LB负载均衡(Load Balance)是什么

            简单的说就是将用户的请求平摊的分配到多个服务上，从而达到系统的HA（高可用），
    常见的负载均衡有软件Nginx，LVS，硬件 F5等。

    1.1.2 集中式LB

            即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件，如F5, 也可以是软件，如nginx), 由该设施负责把访问请求通过某种策略转发至服务的提供方；

    1.1.3 进程内LB

             将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选择出一个合适的服务器。Ribbon就属于进程内LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址。

    1.1.4 Ribbon本地负载均衡客户端 VS Nginx服务端负载均衡区别

            Nginx是服务器负载均衡，客户端所有请求都会交给nginx，然后由nginx实现转发请求。即负载均衡是由服务端实现的。
            Ribbon本地负载均衡，在调用微服务接口时候，会在注册中心上获取注册信息服务列表之后缓存到JVM本地，从而在本地实现RPC远程服务调用技术。

    1.2 二说RestTemplate

            RestTemplate的两组重要方法是getForObject/getForEntity/postForObject/postForEntity

            1.get/postForObject返回对象为响应体中数据转化成的对象，基本上可以理解为Json

            2.get/postForEntity返回对象为ResponseEntity对象，包含了响应中的一些重要信息，比如响应头、响应状态码、响应体等

             举例：

            在Cloud-consumer-order80工程的Controller中添加如下方法：

    1.  @GetMapping("/consumer/payment/getForEntity/{id}")
    2.     public CommonResult getPayment2(@PathVariable("id") Long id){
    3.         ResponseEntity entity = restTemplate.getForEntity(PAYMENT_URL + "/payment/get/" + id, CommonResult.class);
    4.         log.info(entity.getStatusCode()+"\t"+entity.getBody());
    5.         if(entity.getStatusCode().is2xxSuccessful()) return entity.getBody();
    6.         else return new CommonResult<>(444,"查询失败！");
    7.     }

             访问结果：

    1. #控制台
    2. 200 OK	CommonResult(code=200, message=查询成功！serverPort:8001, data={id=31, serial=wzwzwz})
    3.  
    4. #浏览器
    5. {
    6.     "code": 200,
    7.     "message": "查询成功！serverPort:8001",
    8.     "data": {
    9.         "id": 31,
    10.         "serial": "wzwzwz"
    11.     }
    12. }

    1.3 IRule接口（负载均衡算法）

    1.3.1 介绍

            作用：根据特定算法中从服务列表中选取一个要访问的服务

            RoundRobinRule-轮询

            RandomRule-随机选择

            RetryRule-先按照轮询策略获取服务，如果获取服务失败则在指定时间内会进行重试，获取可用的服务

            WeightedResponseTimeRule-对轮询策略的扩展，响应速度越快的实例选择权重越大，越容易被选择

            BestAvailableRule-先过滤掉由于多次访问故障而处于断路器跳闸状态的服务，然后选择一个并发量最小的服务

            AvailabilityFilteringRule-先过滤掉故障实例，再选择并发较小的实例

            ZoneAvoidanceRule-默认规则,复合判断server所在区域的性能和可用性选择服务器

    1.3.2 使用

            注：我们需要自定义一个配置类，但该自定义配置类不能放在@ComponentScan所扫描的当前包下以及子包下（不能放在主启动类所在包），否则我们自定义的这个配置类就会被所有的Ribbon客户端所共享，达不到特殊化定制的目的了。

           1. 新建包及配置类：

    1. @Configuration
    2. public class MySelfRule {
    3.     @Bean
    4.     public IRule myRule(){
    5.         return new RandomRule();//设置想要使用的策略
    6.     }
    7. }

             2. 在主启动类上加注解

                    name：指定服务提供者的名字

    @RibbonClient(name = "CLOUD-PAYMENT-SERVICE",configuration=MySelfRule.class)

            3.输入 http://localhost/consumer/payment/get/31，可以看到每次访问的服务器都是随机的（端口：8001/8002）

    1.3.2 负载均衡算法原理（轮询为例）

            负载均衡算法（轮询）：

            rest接口第几次请求数 % 服务器集群总数量 = 实际调用服务器位置下标  ，每次服务重启动后rest接口计数从1开始。

    List instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");

    如：   List [0] instances = 127.0.0.1:8002
    　　   List [1] instances = 127.0.0.1:8001
     
            8001+ 8002 组合成为集群，它们共计2台机器，集群总数为2， 按照轮询算法原理：
     
    当总请求数为1时： 1 % 2 =1 对应下标位置为1 ，则获得服务地址为127.0.0.1:8001
    当总请求数位2时： 2 % 2 =0 对应下标位置为0 ，则获得服务地址为127.0.0.1:8002
    当总请求数位3时： 3 % 2 =1 对应下标位置为1 ，则获得服务地址为127.0.0.1:8001
    当总请求数位4时： 4 % 2 =0 对应下标位置为0 ，则获得服务地址为127.0.0.1:8002
            如此类推......

    二、OpenFeign服务接口调用

    2.1 概述

    2.1.1 啥是Feign

            Feign是一个声明式WebService客户端。使用Feign能让编写Web Service客户端更加简单。
    它的使用方法是定义一个服务接口然后在上面添加注解。Feign也支持可拔插式的编码器和解码器。Spring Cloud对Feign进行了封装（OpenFeign），使其支持了Spring MVC标准注解和HttpMessageConverters。Feign可以与Eureka和Ribbon组合使用以支持负载均衡

    2.1.1 Feign能干啥

            前面在使用Ribbon+RestTemplate时，利用RestTemplate对http请求的封装处理，形成了一套模版化的调用方法。但是在实际开发中，由于对服务依赖的调用可能不止一处，往往一个接口会被多处调用，所以通常都会针对每个微服务自行封装一些客户端类来包装这些依赖服务的调用。所以，Feign在此基础上做了进一步封装，由他来帮助我们定义和实现依赖服务接口的定义。

            简单来说，Feign就是微服务调用接口+@FeignClient

            在Feign的实现下，我们只需创建一个接口并使用注解的方式来配置它(以前是Dao接口上面标注Mapper注解,现在是一个微服务接口上面标注一个Feign注解即可)，即可完成对服务提供方的接口绑定，简化了使用Spring cloud Ribbon时，自动封装服务调用客户端的开发量。

    2.1.2 Feign 和 OpenFeign区别

    2.2 使用

            1.新建maven子工程，名字：cloud-consumer-feign-order80

            2.POM

    1.     <dependencies>
    2.         
    3.         <dependency>
    4.             <groupId>org.springframework.cloudgroupId>
    5.             <artifactId>spring-cloud-starter-openfeignartifactId>
    6.         dependency>
    7.         
    8.         <dependency>
    9.             <groupId>org.springframework.cloudgroupId>
    10.             <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
    11.         dependency>
    12.         
    13.         <dependency>
    14.             <groupId>com.atguigu.springcloudgroupId>
    15.             <artifactId>cloud-api-commonsartifactId>
    16.             <version>${project.version}version>
    17.         dependency>
    18.         
    19.         <dependency>
    20.             <groupId>org.springframework.bootgroupId>
    21.             <artifactId>spring-boot-starter-webartifactId>
    22.         dependency>
    23.         <dependency>
    24.             <groupId>org.springframework.bootgroupId>
    25.             <artifactId>spring-boot-starter-actuatorartifactId>
    26.         dependency>
    27.         
    28.         <dependency>
    29.             <groupId>org.springframework.bootgroupId>
    30.             <artifactId>spring-boot-devtoolsartifactId>
    31.             <scope>runtimescope>
    32.             <optional>trueoptional>
    33.         dependency>
    34.         <dependency>
    35.             <groupId>org.projectlombokgroupId>
    36.             <artifactId>lombokartifactId>
    37.             <optional>trueoptional>
    38.         dependency>
    39.         <dependency>
    40.             <groupId>org.springframework.bootgroupId>
    41.             <artifactId>spring-boot-starter-testartifactId>
    42.             <scope>testscope>
    43.         dependency>
    44.     dependencies>

            3.YML

    1. server:
    2.   port: 80
    3.  
    4. eureka:
    5.   client:
    6.     register-with-eureka: false
    7.     service-url:
    8.       defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/

            4.主启动类，要加@EnableFeignClients注解

    1. @SpringBootApplication
    2. @EnableFeignClients
    3. public class OrderFeignMain80
    4. {
    5.     public static void main(String[] args)
    6.     {
    7.         SpringApplication.run(OrderFeignMain80.class,args);
    8.     }
    9. }

            5.业务类

                    5.1 service接口，其中定义要用到的服务提供者Controller中的方法.注意service接口要加@FeignClient注解，表明要去哪个服务里找

            provider的Controller中的方法长这个样子：

            如果按照之前的RestTemplate形式调用，consumer中的控制器方法是这个样子的（需要注入RestTemplate，声明PAYMENT_URL）

             使用OpenFegin后，consumer中创建service接口：

    1. @Component
    2. @FeignClient(value = "CLOUD-PAYMENT-SERVICE")
    3. public interface PaymentFeignService
    4. {
    5.     @GetMapping(value = "/payment/get/{id}")
    6.     CommonResult getPaymentById(@PathVariable("id") Long id);
    7. }

                   5.2 controller

            改良后的consumer的controller：

    1. @RestController
    2. @Slf4j
    3. public class OrderFeignController {
    4.     @Resource
    5.     private PaymentFeignService paymentFeignService;
    6.  
    7.     @GetMapping("/consumer/payment/get/{id}")
    8.     public CommonResult getPaymentById(@PathVariable("id") Long id){
    9.         return paymentFeignService.getPaymentById(id);
    10.     }
    11. }

            总结： 
            consumer的controller的方法调用了service中的方法，而service中的方法远程调用了指定服务名的provier的controller的同名方法。

    2.3 超时设置

            默认Feign客户端只等待一秒钟，但是若服务端处理需要超过1秒钟，导致Feign客户端不想等待了，直接返回报错。为了避免这样的情况，有时候我们需要设置Feign客户端的超时控制。

            在yml中配置：

    1. #设置feign客户端超时时间(OpenFeign默认支持ribbon)
    2. ribbon:
    3. #指的是建立连接所用的时间，适用于网络状况正常的情况下,两端连接所用的时间
    4.   ReadTimeout: 5000
    5. #指的是建立连接后从服务器读取到可用资源所用的时间
    6.   ConnectTimeout: 5000

    2.4 日志功能

            Feign 提供了日志打印功能，我们可以通过配置来调整日志级别，从而了解 Feign 中 Http 请求的细节。说白了就是对Feign接口的调用情况进行监控和输出

            日志级别： 
                    NONE：默认的，不显示任何日志；
                    BASIC：仅记录请求方法、URL、响应状态码及执行时间； 
                    HEADERS：除了 BASIC 中定义的信息之外，还有请求和响应的头信息； 
                    FULL：除了 HEADERS 中定义的信息之外，还有请求和响应的正文及元数据。

            首先要建一个配置类，指明日志级别

    1. @Configuration
    2. public class FeignConfig
    3. {
    4.     @Bean
    5.     Logger.Level feignLoggerLevel()
    6.     {
    7.         return Logger.Level.FULL;
    8.     }
    9. }

            然后再yml中配置

    1. logging:
    2.   level:
    3.     # feign日志以什么级别监控哪个接口
    4.     com.atguigu.springcloud.service.PaymentFeignService: debug

  • 相关阅读:
    fortify漏洞修复笔记
    android 车载widget小部件部分详细源码实战开发-千里马车载车机framework开发实战课程
    cAdvisor监控Docker容器做性能测试
    详解【计算机类&面试真题】军队文职考试——第8期：OSI的七层模型 | 数据通信的三种方式 | 通信网络的检查方法，附Python进行网络连通性检查、带宽测试、端口扫描、链路质量测试、安全性扫描
    【汇编】Loop指令、段前缀
    [Mongodb 5.0]比较运算符
    【Pytorch + AlexNet + torchsummary】torchsummary 查看网 及 各层输出的 feature map 尺寸
    【多线程与高并发】- 浅谈volatile
    javascript基本语法(一)
    金蝶 EAS及EAS Cloud任意文件上传漏洞复现
  • 原文地址：https://blog.csdn.net/weixin_62427168/article/details/126448096