【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记(五)OpenFeign的使用

太过爱你忘了你带给我的痛 2023-09-25 23:19 108阅读 0赞

OpenFeign的使用 5/9

    • 1、OpenFeign简介
      • 1.1、Feign及OpenFeign概念和作用
      • 1.2、Feign和OpenFeign区别
    • 2、OpenFeign使用步骤
      • 2.1、创建Feign消费端微服务
      • 2.2、修改POM文件配置
      • 2.3、编写yml配置文件
      • 2.4、编写主启动类
      • 2.5、编写业务类
          • 2.5.1、编写 service 层接口,用于服务提供者接口的远程调用
          • 2.5.2、编写 controller 层,用于url映射和service调用
      • 2.6、测试
    • 3、OpenFeign超时机制
      • 3.1、超时情况
      • 3.2、设置超时时间
    • 4、OpenFeign 日志打印
      • 4.1、日志级别
      • 4.2、使用OpenFeign的日志:
      • 4.3、为指定类设置日志级别
      • 4.4、打印结果

上章中提到Ribbon停更不停用了,OpenFeign是对Ribbon进一步的简化和封装(接口+注解)

1、OpenFeign简介

1.1、Feign及OpenFeign概念和作用

Feign是一个声明式的web客户端,只需要创建一个接口,添加注解即可完成微服务之间的调用;使用Feign能让编写web service客户端更加简单。

它的作用方法是定义一个服务接口,然后在上面添加注解。feign也支持可拔插式的编码器和解码器。Spring Cloud对Feign进行了封装,使其支持了Spring MVC标准注解和Http MessageConverters。Feign可以在与Eureka和Ribbon组合使用来支持负载均衡。

Feign集成了Ribbon、RestTemplate实现了负载均衡的执行Http调用,只不过对原有的方式(Ribbon+RestTemplate)进行了封装,开发者不必手动使用RestTemplate调服务,而是定义一个接口,在这个接口中标注一个注解即可完成服务调用,这样更加符合面向接口编程的宗旨,简化了开发。
在这里插入图片描述

就是A要调用B,Feign就是在A中创建一个一模一样的B对外提供服务的的接口,我们调用这个接口,就可以服务到B

1.2、Feign和OpenFeign区别

在这里插入图片描述

2、OpenFeign使用步骤

2.1、创建Feign消费端微服务

项目模块名称为:Cloud-order-feign80

2.2、修改POM文件配置

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5. <parent>
  6. <artifactId>springcloud2023</artifactId>
  7. <groupId>com.tigerhhzz.springcloud</groupId>
  8. <version>1.0-SNAPSHOT</version>
  9. </parent>
  10. <modelVersion>4.0.0</modelVersion>
  11. <artifactId>Cloud-order-feign80</artifactId>
  12. <dependencies>
  13. <dependency>
  14. <groupId>org.springframework.cloud</groupId>
  15. <artifactId>spring-cloud-starter-openfeign</artifactId>
  16. </dependency>
  17. <dependency>
  18. <groupId>org.springframework.cloud</groupId>
  19. <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  20. </dependency>
  21. <dependency>
  22. <groupId>com.uclass.springcloud</groupId>
  23. <artifactId>Api-Commons</artifactId>
  24. <version>1.0-SNAPSHOT</version>
  25. </dependency>
  26. <dependency>
  27. <groupId>org.springframework.boot</groupId>
  28. <artifactId>spring-boot-starter-web</artifactId>
  29. </dependency>
  30. <dependency>
  31. <groupId>org.springframework.boot</groupId>
  32. <artifactId>spring-boot-starter-actuator</artifactId>
  33. </dependency>
  34. <!--热部署-->
  35. <dependency>
  36. <groupId>org.springframework.boot</groupId>
  37. <artifactId>spring-boot-devtools</artifactId>
  38. <scope>runtime</scope>
  39. <optional>true</optional>
  40. </dependency>
  41. <dependency>
  42. <groupId>org.projectlombok</groupId>
  43. <artifactId>lombok</artifactId>
  44. <optional>true</optional>
  45. </dependency>
  46. <dependency>
  47. <groupId>org.springframework.boot</groupId>
  48. <artifactId>spring-boot-starter-test</artifactId>
  49. <scope>test</scope>
  50. </dependency>
  51. </dependencies>
  52. </project>
  53. </project>

查看项目依赖,可以看到:openfeign天生就继承了ribbon,也具备了ribbon的负载均衡能力。
在这里插入图片描述

2.3、编写yml配置文件

  1. server:
  2. port: 80
  3. spring:
  4. application:
  5. name: Cloud-consumer-feign-order80
  6. eureka:
  7. client:
  8. register-with-eureka: true
  9. fetch-registry: true
  10. service-url:
  11. # defaultZone: http://localhost:7001/eureka/ #单机版
  12. defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/ #集群版

2.4、编写主启动类

类上添加 @EnableFeignClients 注解,表示 Feign 客户端

  1. package com.tigerhhzz.springcloud;
  2. import lombok.extern.slf4j.Slf4j;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.openfeign.EnableFeignClients;
  6. @Slf4j
  7. @EnableFeignClients //激活对Feign的使用
  8. @SpringBootApplication
  9. public class OrderFeignMain80 {
  10. public static void main(String[] args) {
  11. SpringApplication.run(OrderFeignMain80.class, args);
  12. log.info("OrderFeignMain80启动成功~~~~~~~~~~~~~~~~~~~");
  13. }
  14. }

2.5、编写业务类

业务逻辑接口+@FeignClient注解配置调用provider8001或者8002服务。

2.5.1、编写 service 层接口,用于服务提供者接口的远程调用

service层:注意添加 @FeignClient(value = “cloud-payment-service”) 注解,其中value值表示需要远程调用的微服务名称。

  1. package com.tigerhhzz.springcloud.service;
  2. import com.tigerhhzz.springcloud.entities.CommonResult;
  3. import com.tigerhhzz.springcloud.entities.Payment;
  4. import org.springframework.cloud.openfeign.FeignClient;
  5. import org.springframework.stereotype.Component;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. /**
  9. * @author tigerhhzz
  10. * @date 2023/4/11 15:27
  11. */
  12. @Component
  13. @FeignClient(value = "cloud-provider-service") //需要寻找的微服务名称
  14. public interface PaymentFeignService {
  15. @GetMapping(value = "/payment/{id}")
  16. public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id);
  17. }
2.5.2、编写 controller 层,用于url映射和service调用
  1. package com.tigerhhzz.springcloud.controller;
  2. import com.tigerhhzz.springcloud.entities.CommonResult;
  3. import com.tigerhhzz.springcloud.entities.Payment;
  4. import com.tigerhhzz.springcloud.service.PaymentFeignService;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import javax.annotation.Resource;
  10. @RestController
  11. @Slf4j
  12. public class OrderFeignController {
  13. @Resource
  14. private PaymentFeignService paymentFeignService;
  15. @GetMapping(value = "/consumer/payment/get/{id}")
  16. public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id){
  17. return paymentFeignService.getPaymentById(id);
  18. }
  19. }

说明:80模块启动后,客户端访问地址是/consumer/payment/get/{id},首先找自己的访问接口层 2.5.1中写的PaymentFeignService 接口,通过注解@FeignClient(value = “cloud-provider-service”)去Eureka注册中心中找服务名称为”cloud-provider-service”的微服务接口,它的调用接口是8001模块提供对外暴露出来的@GetMapping(value = “/payment/{id}”)接口;中间隔了一层openfeign接口。

2.6、测试

访问接口,并测试openfeign带有负载均衡的功能。

  1. 先启动2个Eureka集群7001/7002
  2. 再启动2个微服务8001/8002
  3. 启动OpenFeign模块OrderFeignMain80
  4. 访问地址:http://localhost/consumer/payment/get/1

Feign默认使用ribbon实现负载均衡,得到结果(Feign自带负载均衡配置项)
在这里插入图片描述

3、OpenFeign超时机制

3.1、超时情况

OpenFeign默认等待时间是1秒,超过1秒,直接报错

3.2、设置超时时间

application.yaml 配置文件中,设置超时时长:

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

因为OpenFeign的底层是ribbon进行负载均衡,所以它的超时时间是由ribbon控制。

4、OpenFeign 日志打印

在这里插入图片描述

对 Feign 接口的调用情况进行监控和输出,通过配置,调整日志级别,从而了解 Feign 中 Http 请求的细节。

4.1、日志级别

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

4.2、使用OpenFeign的日志:

实现在配置类中添加OpenFeign的日志类

注意:Logger 引入的是 import feign.Logger 包下的

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

4.3、为指定类设置日志级别

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

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

4.4、打印结果

在这里插入图片描述

发表评论

表情:
评论列表 (有 0 条评论,108人围观)

还没有评论,来说两句吧...

相关阅读