SpringCloud --- 服务调用 (Ribbon，OpenFeign)

Posted 2022-12-02 黑桃️

服务调用

• 一、Ribbon 负载均衡调用
• • 🔺 概述
  • • (1) 是什么
    • (2) 官网资料
    • (3) 能干嘛
  • 🔺 Ribbon 负载均衡演示
  • • (1) 架构说明
    • (2) POM
    • (3) 二说RestTemplate的使用
    • • ① 官网
      • ② getForObject方法 / getForEntity方法 (Get 请求方法)
  • 🔺 Ribbon 核心组件 IRule
  • • (1) IRule:根据特定算法从服务列表中选取一个要访问的服务
    • (2) 如何替换
    • • ① 修改cloud-consumer-order80
      • ② 注意配置细节
      • ③ 新建包 myrule
      • ④ 新建类 MySelfRule
      • ⑤ 主启动类添加@RibbonClient
  • 🔺 Ribbon 负载均衡算法
  • • (1) 原理
    • (2) 手写轮询算法
    • • ① 7001/7002集群 和 8001/8002集群启动
      • ② 80订单微服务改造
• 二、OpenFeign服务接口调用
• • 🔺 概述
  • • (1) OpenFeign 是什么
    • (2) OpenFeign 能干嘛
    • (3) Feign和OpenFeign两者区别
  • 🔺 OpenFeign 使用步骤
  • • (1) 接口+注解
    • (2) 新建模块 cloud-consumer-feign-order80
    • (3) 配置 pom.xml
    • (4) 配置 application.xml
    • (5) 创建主启动类
    • (6) 编写业务类
    • • ① Service层：PaymentFeignService
      • ② Controller层：OrderFeignController
    • (7) 测试
    • (8) 小总结
  • 🔺 OpenFeign 超时控制
  • • (1) 超时设置,故意设置超时演示出错情况
    • • ① 服务提供方8001故意写暂停程序
      • ② 服务消费方80添加超时方法PaymentFeignService
      • ③ 服务消费方80添加超时方法OrderFeignController
      • ④ 测试
    • (2) 超时的原因：
    • (3) 解决方法：
  • 🔺 OpenFeign 日志打印功能
  • • (1) 是什么
    • (2) 日志级别
    • (3) 配置日志bean：FeignConfig
    • (4) YML文件里需要开启日志的Feign客户端
    • (5) 测试

---

一、Ribbon 负载均衡调用

🔺 概述

(1) 是什么

(2) 官网资料

https://github.com/Netflix/ribbon/wiki/Getting-Started

Ribbon目前也进入维护模式，未来的替换方案如下

(3) 能干嘛

LB (负载均衡)

• 集中式LB

• 进程内LB

前面的80通过轮询负载访问8001/8002，即 负载均衡 + RestTemplate调用

---

🔺 Ribbon 负载均衡演示

(1) 架构说明

总结 : Ribbon其实就是一个软负载均衡的客户端组件, 他可以和其他所需请求的客户端结合使用,和eureka结合只是其中一个实例

---

(2) POM

(3) 二说RestTemplate的使用

① 官网

② getForObject方法 / getForEntity方法 (Get 请求方法)

还有 postForObject / postForEntity (Post 请求方法)

---

🔺 Ribbon 核心组件 IRule

(1) IRule:根据特定算法从服务列表中选取一个要访问的服务

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

---

(2) 如何替换

① 修改cloud-consumer-order80

② 注意配置细节

③ 新建包 myrule

根据前面说的官方文档中的警告，不要被@ComponentScan扫描到，否则达不到特殊化定制的目的

而springboot项目中的@ComponentScan就在主启动类上的@SpringBootApplication中(源码中可以看到)，所以为了避免被扫到，就不要和主启动类在同一个包下

④ 新建类 MySelfRule

@Configuration
public class MySelfRule 
    @Bean
    public IRule myRule() 
        // 将默认的轮换算法替换为随机算法
        return new RandomRule();
    

⑤ 主启动类添加@RibbonClient

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

---

🔺 Ribbon 负载均衡算法

(1) 原理

(2) 手写轮询算法

① 7001/7002集群 和 8001/8002集群启动

② 80订单微服务改造

创建接口： LoadBalancer

public interface LoadBalancer 
    // 从服务集群中选择出本次来提供服务的一个service
    ServiceInstance instances(List<ServiceInstance> serviceInstances);

创建 LoadBalancer 接口的实现类 MyLB

@Component
public class MyLB implements LoadBalancer 

    private AtomicInteger atomicInteger = new AtomicInteger(0);

    // 提供服务的次数
    public final int getAndIncrement() 
        int current;
        int next;

        do 
            current = this.atomicInteger.get();
            next = (current+1) % Integer.MAX_VALUE;
        while(!this.atomicInteger.compareAndSet(current, next));
        System.out.println("-------第" + next +  "次访问");
        return next;
    


    @Override
    public ServiceInstance instances(List<ServiceInstance> serviceInstances) 
        // 轮询,需要提供服务的实例下标
        int index = getAndIncrement() % serviceInstances.size();

        // 返回该服务实例
        return serviceInstances.get(index);
    

在 8001 和 8002的 PaymentController 上增加逻辑代码 (添加相同的代码)

@GetMapping("/payment/lb")
public String getPaymentLB() 
    return serverPort;

在 80 的 OrderController 添加业务逻辑

// 注意别导错包
@Resource
private DiscoveryClient discoveryClient;

// 注入的是接口,不是实现类
@Resource
private LoadBalancer loadBalancer;

@GetMapping("/consumer/payment/lb")
public String getPaymentLB() 

    // 获取服务名为：cloud-payment-service 的所有实例
    List<ServiceInstance> instances = discoveryClient.getInstances("cloud-payment-service");

    if (instances == null || instances.size() <= 0) 
        return null;
    

    // 调用方法,得到本次提供服务的实例
    ServiceInstance instance = loadBalancer.instances(instances);

    URI uri = instance.getUri();

    return restTemplate.getForObject(uri + "/payment/lb", String.class);

---

二、OpenFeign服务接口调用

🔺 概述

(1) OpenFeign 是什么

https://github.com/spring-cloud/spring-cloud-openfeign

(2) OpenFeign 能干嘛

(3) Feign和OpenFeign两者区别

🔺 OpenFeign 使用步骤

(1) 接口+注解

微服务调用接口 + @FeignClient

(2) 新建模块 cloud-consumer-feign-order80

(3) 配置 pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>cloud2020</artifactId>
        <groupId>com.atguigu.springcloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>cloud-consumer-feign-order80</artifactId>

    <dependencies>
        <!--openfeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <!--eureka client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>$project.version</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--监控-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!--热部署-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.atguigu.springcloud</groupId>
            <artifactId>cloud-api-commons</artifactId>
            <version>1.0-SNAPSHOT</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>

</project>

(4) 配置 application.xml

server:
  port: 80

eureka:
  client:
    register-with-eureka: false
    fetch-registry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

(5) 创建主启动类

@SpringBootApplication
@EnableFeignClients // 开启FeignClient功能,后面使用@FeignClient注解才有效
public class OrderFeignMain80 
    public static void main(String[] args) 
        SpringApplication.run(OrderFeignMain80.class, args);
    

(6) 编写业务类

① Service层：PaymentFeignService

@Component
//可以远程调用该服务名的controller
@FeignClient("CLOUD-PAYMENT-SERVICE") 
public interface PaymentFeignService 

    @GetMapping("/payment/get/id")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id);

② Controller层：OrderFeignController

@RestController
@Slf4j
public class OrderFeignController 
    @Resource
    private PaymentFeignService paymentFeignService;

    @GetMapping("/consumer/payment/get/id")
    public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id) 
        return paymentFeignService.getPaymentById(id);
    
    

(7) 测试

(8) 小总结

---

🔺 OpenFeign 超时控制

(1) 超时设置,故意设置超时演示出错情况

① 服务提供方8001故意写暂停程序

@GetMapping("/payment/Feign/Timeout")
public String paymentFeignTimeout() throws InterruptedException 
    // 延迟3s
    TimeUnit.SECONDS.sleep(3000);

    return serverPort;

② 服务消费方80添加超时方法PaymentFeignService

@GetMapping("/payment/Feign/Timeout")
public String paymentFeignTimeout();

③ 服务消费方80添加超时方法OrderFeignController

@GetMapping("/consumer/payment/Feign/Timeout")
public String paymentFeignTimeout() 
    return paymentFeignService.paymentFeignTimeout();

④ 测试

---

(2) 超时的原因：

OpenFeign默认等待1秒钟,超过后报错

(3) 解决方法：

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

---

🔺 OpenFeign 日志打印功能

(1) 是什么

(2) 日志级别

(3) 配置日志bean：FeignConfig

@Configuration
public class FeignConfig 
    // feignClient配置日志级别
    @Bean
    public Logger.Level feignLoggerLevel() 
        // 请求和响应的头信息,请求和响应的正文及元数据
        return Logger.Level.FULL;
    

(4) YML文件里需要开启日志的Feign客户端

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

(5) 测试