【SpringBoot系列】微服务远程调用Open Feign深度学习

简介: 【4月更文挑战第9天】微服务远程调度open Feign 框架学习

[toc]


前言

通常一个服务需要调用 Http 端点,Feign 来自 OpenFeign 项目使得以声明式方式调用 http 端点变得更加容易。Spring 通过其 Spring Cloud OpenFeign 集成了 openfeign 集成。

一、引入Feign Client

feign 的实际项目是 OpenFeign https://github.com/OpenFeign/feign ,Spring自带启动器,将以下依赖项添加到项目

<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

我们创建一个名为 feign-serviceA 的服务,该服务将调用 feign-serviceB 。feign-serviceB 公开一个 GET 端点 /hello,它返回一个简单的 hello 响应正文。为了使用来自 feign-serviceA 的 feign 客户端调用端点,我们需要执行以下操作 -

  • 创建一个带有@FeignClient注释的界面,如下所示
@FeignClient(url = "<host:port for serviceB>", name = "serviceB")
public interface ServiceBClient{

    @GetMapping("/hello")
    public ResponseEntity<String> sayHello();
}
  • 为主启动类添加@EnableFeignClients 注解

设置好了,我们可以像任何正常的方法调用一样简单地自动连接ServiceBClient并调用方法sayHello。

二、Feign 配置

Feign 自带有一些组件,这些组件用于调用远程端点并编码/解码请求响应。

  • 客户端 - 要进行 HTTP 调用,需要 http 客户端。默认情况下,openfeign 带有默认客户端。我们可以用 ApacheHttpClient、OkHttpClient 或 ApacheHC5FeignClient 覆盖它。这些客户端是委托客户端的包装器。例如,ApacheHttpClient 包装一个 httpcomponents、httpclient。

  • 解码器 - 需要将 feign Response 转换为 feign 方法返回类型的实际类型。默认情况下,spring 提供了一个 OptionalDecoder,它委托给 ResponseEntityDecoder,后者进一步委托给 SpringDecoder,我们可以通过定义一个 Bean 来覆盖它 解码器 。

  • 编码器 - 我们通过向它传递对象来调用feign方法,需要将其转换为 http 请求正文。默认情况下,spring 提供 SpringEncoder。

除了上面的组件外,feign还支持缓存等功能。我们可以创建一个配置类并覆盖上述组件的默认值。如果我们想覆盖单个组件的默认值,@Feign接受配置参数,我们可以使用它来定义默认值的自定义覆盖。

三、重试机制

Feign 已经支持重试机制。但是,默认情况下,它使用 Retry.NEVER_RETRY 。例如,我们可以创建一个自定义重试器,它将重试任何状态代码> 400的请求,以下是我们的 CustomRetryer 的代码:

public class CustomRetryer extends Retryer.Default{
   
    public CustomRetryer(long period, long maxPeriod, int maxAttempts){
   
        super(period, maxPeriod, maxAttempts);
    }

    @Override
    public void continueOrPropagate(RetryableException e){
   
        log.info("Going to retry for ", e);
        super.continueOrPropagate(e);
    }

    @Override
    public Retryer clone(){
   
        return new CustomRetryer(5,SECONDS.toMillis(1), 5);
    }
}

一个重要的事实是 feign Retry 适用于 IOException 或从某些 errorDecoder 引发的 RetryableException ,以下是自定义解码器的样子:

 @Bean
    public ErrorDecoder errorDecoder(){
   
        return (methodKey, response) -> {
   
            byte[] body = {
   };
            try {
   
                if (response.body() != null) {
   
                    body = Util.toByteArray(response.body().asInputStream());
                }
            } catch (IOException ignored) {
    // NOPMD
            }
            FeignException exception = new FeignException.BadRequest(response.reason(), response.request(), body, response.headers());
            if (response.status() >= 400) {
   
                return new RetryableException(
                        response.status(),
                        response.reason(),
                        response.request().httpMethod(),
                        exception,
                        Date.from(Instant.now().plus(15, ChronoUnit.MILLIS)),
                        response.request());
            }
            return exception;
        };
    }

四、弹性

我们在前面介绍了通过重试实现的一种弹性形式,Spring 对 feign 有 CircuitBreaker 支持,它通过单独的 Feign 构建器 FeignCircuitBreaker.Builder 来实现它,Circuitbreaker 的实际实现来自 resilience4j 库。

五、拦截器

有时我们想通过添加一些额外的信息来修改请求,例如,我们可以为每个请求添加一些标头,我们可以通过使用 RequestInterceptor 来实现这一点,在下面添加了填充标头 userid 的拦截器。

@Bean
public RequestInterceptor userIdRequestInterceptor(){
     return (template) -> {
        template.header("userid", "somerandomtext");
    };
}

feign-serviceB 读取此标头并返回为标头,我们请求curl,我们得到的响应如下:

< HTTP/1.1 200
< connection: keep-alive
< date: Sat, 20 Aug 2022 15:27:47 GMT
< keep-alive: timeout=60
< userid: somerandomtext
< Content-Type: text/plain;charset=UTF-8
< Content-Length: 7
<
* transfer closed with 7 bytes remaining to read

我们看到 userid 已添加到响应中。一个非常有用的拦截器应用程序是当 feign 必须发送 oauth2 访问令牌时。Out of the spring 提供了一个 OAuth2FeignRequestInterceptor,它为每个请求添加访问令牌。

六、负载均衡

从 spring boot 2.4.0 开始,feign 与 spring-cloud-loadbalancer 集成,后者可以从各种服务发现提供商获取客户端 url 信息,并使该信息可供 feign 使用。feign 的使用简化了发出 http 请求的各个方面。在典型的生产环境中,我们可能需要重写多个组件,如客户端、解码器、errorDecoder 等。同样在 Spring 生态系统中,feign 与弹性、负载平衡、指标等很好地集成在一起,这使得我们在微服务架构中可以自动选择它。

小结

本节我们学习了Spring Feign Client,我们介绍了Feign的配置,重试机制,弹性以及拦截器,负载均衡等能力。Spring Feign Client在微服务调度过程中起到了重要的作用,通过Spring Feign Client,我们可以实现对其他服务的调度能力,后面我们会对Spring Boot系列继续进行深入学习,欢迎大家持续关注,如果你还喜欢小编的风格,请点赞+关注,给小编一个三连赞,小编一定会特别开心哒。

目录
相关文章
|
30天前
|
Dubbo Java 应用服务中间件
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
|
30天前
|
存储 Java 时序数据库
【SpringBoot系列】微服务监测(常用指标及自定义指标)
【4月更文挑战第6天】SpringBoot微服务的监测指标及自定义指标讲解
66 0
|
3天前
|
JavaScript Java 测试技术
基于springboot+vue.js+uniapp小程序的微服务的车联网位置信息管理附带文章源码部署视频讲解等
基于springboot+vue.js+uniapp小程序的微服务的车联网位置信息管理附带文章源码部署视频讲解等
9 1
|
6天前
|
监控 数据管理 Java
智慧城管源码,基于微服务+java+springboot+vue+uniapp开发的城管综合执法系统源码
智慧城管执法系统利用微服务和Java技术提升城市管理水平,涵盖事件处理、投诉、处罚等功能,包含PC和APP源码。系统支持执法APP,便于领导随时随地审批,具备文书模板、地图定位、法规查询等功能。此外,执法办案系统通过监控视频分析事件,实现案件全程闭环管理,包括组织、案件、信用和执法队伍管理,以及法规库等基础支撑。系统旨在优化流程,提高数据管理和效率。
智慧城管源码,基于微服务+java+springboot+vue+uniapp开发的城管综合执法系统源码
|
18天前
|
机器学习/深度学习 监控 持续交付
构建高效微服务架构:后端开发的新趋势探索深度学习在图像识别中的边界
【5月更文挑战第27天】随着业务需求的快速变化和市场竞争的激烈,企业需要更灵活、高效和可扩展的系统来支持其运营。微服务架构作为一种新兴的软件开发模式,已经成为后端开发领域的热门话题。本文将深入探讨微服务架构的概念、优势以及如何构建一个高效的微服务架构,帮助后端开发者更好地应对业务挑战。 【5月更文挑战第27天】 随着人工智能的不断进步,深度学习技术已经在图像识别领域取得了显著成就。本文将深入探讨深度学习模型在处理复杂图像数据时的挑战与机遇,分析现有技术的局限性,并提出潜在的改进方向。通过实验验证,我们将展示如何通过创新的网络架构、数据增强策略和损失函数设计来提升模型性能。本研究不仅为深度学习
|
30天前
|
负载均衡 Java Apache
【微服务系列笔记】Feign
Feign是一个声明式的伪HTTP客户端,它使得HTTP请求变得更简单。使用Feign,只需要创建一个接口并注解。Feign默认集成了Ribbon,并和Eureka结合,默认实现了负载均衡的效果。 OpenFeign 是SpringCloud在Feign的基础上支持了SpringMVC的注解。
57 8
|
30天前
|
Java Docker 微服务
|
30天前
|
SQL 安全 Java
微服务之Springboot整合Oauth2.0 + JWT
微服务之Springboot整合Oauth2.0 + JWT
26 1
|
30天前
|
Java 数据库连接 数据库
【SpringBoot系列】微服务数据持久化方案
【4月更文挑战第8天】微服务数据持久化方案Spring Boot JPA + Hiberate
25 0
|
30天前
|
Java 关系型数据库 数据库
【SpringBoot系列】微服务集成Flyway
【4月更文挑战第7天】SpringBoot微服务集成Flyway
62 1
【SpringBoot系列】微服务集成Flyway