springcloud-alibba之FeignClient

🕗 发布于 2024-07-09 23:38 spring cloud spring boot java openfeign 微服务

代码地址：springcloud系列: springcloud 组件分析拆解

1.FeignClient的集成

springboot版本：3.1.5

springcloud组件版本：2022.0.4

nacos客户端的版本：2.3.2

1.引pom

这里引入了nacos和feginclient的版本

            <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>
        <!--openfeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

  <!--nacos-discovery-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

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

2.加注解

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class UserServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class, args);
    }

}

3.使用

feignclient支持按照springmvc的框架，按照mvc的接口形式，将接口通过代理的方式解析成httpclient，发送请求。

一个最简单的使用示例

我现在有一个用户服务和一个订单服务，需要用户通过订单号查询订单

定一个FeginClient

@FeignClient(name = "order-service")
public interface UserFeignClient {

    @GetMapping("order/get")
    String  get(@RequestParam String orderNo);

}

@Feginclient 注解

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by FernFlower decompiler)
//

package org.springframework.cloud.openfeign;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.core.annotation.AliasFor;

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface FeignClient {
    @AliasFor("name")
    String value() default "";

    /** @deprecated */
    @Deprecated
    String serviceId() default "";

    @AliasFor("value")
    String name() default "";

    String qualifier() default "";

    String url() default "";

    boolean decode404() default false;

    Class<?>[] configuration() default {};

    Class<?> fallback() default void.class;

    Class<?> fallbackFactory() default void.class;

    String path() default "";

    boolean primary() default true;
}

参数详细说明

url：目标服务的基础url

value：同name属性，指定Feign客户端的名称。当两者都存在时，value优先级高于name

path：客户端接口中所有方法的基础路径前缀，如果不设置，默认为空字符串。

configuration：指定一个或多个配置类，这些配置类可以用来定制Feign的行为，比如设置日志级别、错误解码器等。

decode404：布尔值，默认为false。如果设为true，Feign会在接收到404响应时尝试解码响应体，而不是抛出异常。

fallback 和 fallbackFactory：分别用于指定回退类和回退工厂类，当远程服务调用失败时，提供降级逻辑。

在订单服务定义一个接口

@GetMapping("order/get")
    public String get(@RequestParam String orderNo) {

        try {
            System.out.println("开始休眠");
            Thread.sleep(6000);
            System.out.println("休眠结束");

        } catch (Exception e) {

        }
        System.out.println(orderNo);
        return "ok";
    }

在用户服务发起请求

    @Resource
    private UserFeginClient userFeginClient;

    @GetMapping("test")
    public String get() {

        userFeginClient.get("sdfdsf");
        return "test";
    }

在实际项目中，定义client分为两种情况

1.内部服务的调用。这种情况feginclient会将代码写字自己对应的服务种，提供api模供项目内部的服务去依赖。

2.调用外部的接口

调用外部的接口，可以将外部接口理解为普通的http请求即可，在自己的服务内部定义feginclient,按照springmvc的接口定义即可

使用feignclient注意事项

1.feignclient对于get请求，不支持使用对象的传参

使用对象传参会默认解析为post请求，会抛异常405状态码，不支持的请求

4.feignclient的超时时间配置

1.超时时间概念

1.连接超时

客户端和服务端之间建立tcp连接的时间，一般很短

2.读取超时时间

服务端接收到请求，执行自己的业务，加入在指定时间内服务端没有返回，将超时

2.支持全局的和局部client的超时时间配置

示例：

   # application.yml 示例
   feign:
     client:
       config:
         default:          # 默认配置，适用于所有Feign客户端
           connectTimeout: 5000  # 连接超时时间，单位为毫秒
           readTimeout: 5000    # 读取超时时间，单位为毫秒

在application.properties中：

   # application.properties 示例
   feign.client.config.default.connectTimeout=5000
   feign.client.config.default.readTimeout=5000

真的特定的client超时间配置

   feign:
     client:
       config:
         myCustomClient:    # 替换为你的Feign客户端接口名
           connectTimeout: 8000
           readTimeout: 6000

5.openfeign 的重试机制

openfeign默认是不走重试机制的

配置重试：

@Configuration
public class FeignConfig {
    @Bean
    public Retryer myRetryer() {
        //默认不开启重试 NEVER_RETRY
        //最大请求次数
        // 100 失败多少毫秒之后执行  1最大间隔   1秒 一秒一次   
        //最大重复次数3次（1+2） 第一次请求+重试两次
        return new Retryer.Default(100, 1, 3);
    }
}

代码验证

controller

 @Resource
    private OrderClient orderClient;

    @RequestMapping("getUser")
    public String  getUser() {
        var user = new UserVo();
        user.setName("test");
        user.setPassword("123456");
        var l1 = System.currentTimeMillis();
        System.out.println("调用开始---------------");
        try {
            orderClient.getOrder();


        }catch (Exception e){

        }
        var l = System.currentTimeMillis();
        System.out.println("调用结束----------------"+(l-l1)/1000+"s");

        return "feign调用 订单服务success";
    }

配置文件

server:
  port: 8080

spring:
  application:
    name: user-service1
  cloud:
    openfeign:
      client:
        config:
          default:
            #连接超时时间
            connectTimeout: 2000
            #读取超时时间
            readTimeout: 4000

日志

调用开始---------------
2024-07-06T15:52:13.392+08:00  INFO 22140 --- [nio-8080-exec-1] com.alibaba.nacos.client.naming          : [SUBSCRIBE-SERVICE] service:order-service, group:DEFAULT_GROUP, clusters: 
2024-07-06T15:52:13.400+08:00  INFO 22140 --- [nio-8080-exec-1] com.alibaba.nacos.client.naming          : init new ips(1) service: DEFAULT_GROUP@@order-service -> [{"instanceId":"192.168.137.1#8081#DEFAULT#DEFAULT_GROUP@@order-service","ip":"192.168.137.1","port":8081,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"DEFAULT","serviceName":"DEFAULT_GROUP@@order-service","metadata":{"preserved.register.source":"SPRING_CLOUD","IPv6":"[2408:8220:364:ddc1:82a:8136:409c:ca0a]"},"ipDeleteTimeout":30000,"instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000}]
2024-07-06T15:52:13.414+08:00  INFO 22140 --- [nio-8080-exec-1] com.alibaba.nacos.client.naming          : current ips:(1) service: DEFAULT_GROUP@@order-service -> [{"instanceId":"192.168.137.1#8081#DEFAULT#DEFAULT_GROUP@@order-service","ip":"192.168.137.1","port":8081,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"DEFAULT","serviceName":"DEFAULT_GROUP@@order-service","metadata":{"preserved.register.source":"SPRING_CLOUD","IPv6":"[2408:8220:364:ddc1:82a:8136:409c:ca0a]"},"ipDeleteTimeout":30000,"instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000}]
2024-07-06T15:52:13.966+08:00  INFO 22140 --- [or-127.0.0.1-13] com.alibaba.nacos.common.remote.client   : [b2df3a7f-c8da-49d8-8f39-0f980088e6d5] Receive server push request, request = NotifySubscriberRequest, requestId = 9
2024-07-06T15:52:13.967+08:00  INFO 22140 --- [or-127.0.0.1-13] com.alibaba.nacos.common.remote.client   : [b2df3a7f-c8da-49d8-8f39-0f980088e6d5] Ack server push request, request = NotifySubscriberRequest, requestId = 9
调用结束----------------12s

如果想要每次重试都打印，需要开启feign的日志功能

6.openfeign集成httpclient5

openfeign默认使用的是HttpUrlConnection 做的连接，该方式性能和httpclient5有很大的差距

生产使用这个会舒服很多

集成

引入依赖

    <!-- httpclient5-->
        <dependency>
            <groupId>org.apache.httpcomponents.client5</groupId>
            <artifactId>httpclient5</artifactId>
            <version>5.3</version>
        </dependency>
        <!-- feign-hc5-->
        <dependency>
            <groupId>io.github.openfeign</groupId>
            <artifactId>feign-hc5</artifactId>
            <version>13.1</version>
        </dependency>

开启开关

7.请求回应压缩

官网截图

对请求和响应进行gzip压缩。以减少通信过程中的性能损耗

通过两个参数就能开启

细粒度压缩

8.openfeign 的日志打印功能

默认不显示任何日志

NONE,默认的不显示

BASIC, 仅记录请求方法,url，响应状态码和响应头的信息

HEADERS,多了请求和响应头信息

FULL 多了请求和响应的正文及元数据

代码配置

   @Bean
    public Logger.Level feginLoggerLevel() {
        //开启之后重试次数每次重试请求都可以打印
        return Logger.Level.FULL;
    }

原文地址：https://blog.csdn.net/qq_35410620/article/details/140225166

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：边缘概率密度、条件概率密度、边缘分布函数、联合分布函数关系
下一篇：KIVY Button¶

leetcode289:生命游戏
根据，简称为，是英国数学家约翰·何顿·康威在 1970 年发明的细胞自动机。给定一个包含m × n个格子的面板，每一个格子都可以看成是一个细胞。每个细胞都具有一个初始状态：1即为（live），或0即为
阅读更多2024-10-20
MongoDB数据恢复
注意：两个MongoDB的版本要一致，本文使用的是mongo:4.2.24。先把K8S上面的MongoDB 容器停止（可以把副本改成0）。1、将容器挂载MongoDB的数据目录备份到本地。经常是数据文
阅读更多2024-10-20
C#中实现事务
C#中实现事务
阅读更多2024-10-20
【LeetCode每日一题】——560.和为 K 的子数组
给你一个整数数组 nums 和一个整数 k ，请你统计并返回该数组中和为 k 的子数组的个数。子数组是数组中元素的连续非空序列。
阅读更多2024-10-20
「漏洞复现」满客宝智慧食堂系统 selectUserByOrgId 未授权访问漏洞
请勿利用文章内的相关技术从事非法测试，由于传播、利用此文所提供的信息而造成的任何直接或者间接的后果及损失，均由使用者本人负责，作者不为此承担任何责任。工具来自网络，安全性自测，如有侵权请联系删除。本次
阅读更多2024-10-20
React面试题目（从基本到高级）
React前端面试常见题目涵盖了React的基础概念、组件、状态管理、生命周期、性能优化等多个方面。
阅读更多2024-10-20
12.个人博客系统（Java项目基于spring和vue）
1 在校学习的学生，可用于日常学习使用或是毕业设计使用 2 毕业一到两年的开发人员，用于锻炼自己的独立功能模块设计能力，增强代码编写能力。 3 亦可以部署为商化项目使用。 4 需要完整资料及源码
阅读更多2024-10-20
YoloV8改进策略：注意力改进|DeBiFormer，可变形双级路由注意力|引入DeBiLevelRoutingAttention注意力模块（全网首发）
本次改进的核心在于将DeBiLevelRoutingAttention模块嵌入到YoloV8的主干网络中，具体位置是在SPPF（Spatial Pyramid Pooling Fast）模块之后。这一
阅读更多2024-10-20
word取消自动单词首字母大写
情况说明：在word输入单词后首字母会自动变成大写取消单词首字母大写步骤：（1）点击菜单栏文件（2）点击“更多”——>“选项”（3）点击“校对”——>“自动更正选项”（4）取消“句首字母大
阅读更多2024-10-20
web前端网页用户注册页面
【代码】web前端网页用户注册页面。
阅读更多2024-10-20