spring-cloud微服务openfeign

Spring Cloud openfeign对Feign进行了增强，使其支持Spring MVC注解，另外还整合了Ribbon和Nacos，从而使得Feign的使用更加方便

优势，openfeign可以做到使用HTTP请求远程服务时就像洞用本地方法一样的体验，开发者完全感知不到这是远程方法，更感知不到这是个 http请求，它像 Dubbo一样，consumer 直接洞用接口方法调用 povider,，而不需要通过常规的 Htp Client构造请求再解析返回数据。它解决了让开发者调用远程接口就跟调用本地方法一样，无需关注与远程的交互细节，更无需关注分布式环境开发

pom导入依赖

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

在bootstrap.yml中增加OpenFeign对Sentinel的支持，增加feign.sentinel.enabled配置项

server:
  port: 9001
spring:
  application:
    name: consumer # 应用名

  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848 # nacos服务地址
    sentinel:
      transport:
        port: 8719 # 启动http server，并且该服务与Sentinel仪表板进行交互，使sentinel可以控制应用，若端口占用则8719+1依次扫描
        dashboard: 127.0.0.1:8080 # 仪表版访问地址
feign:	# 增加对sentinel的支持
  sentinel:
    enabled: true

这里说一下如果不加feign.sentinel.enabled=true的配置，那么在@FeignClient中定的fallback属性定义的异常、限流等自定义的处理逻辑不会生效

将FeignClient抽取为独立模块，并且把接口有关的POJO（实体类）、默认的Feign配置都放到这个模块中，提供给所有消费者使用，将其做成公共模块，其他服务只需要依赖该jar包

在主启动类上加入@EnableFeignClients注解，标记为启用OpenFeign，具体如下：

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class OrderNacosApplication{

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

假如是分布式项目，将openfeign抽取为一个单独的服务模块时，可能出现我openfeign中的包名和其他模块不一致，可以自己声明FeignClient组件的basePackages设置一下FeignClient的扫描路径。示例如下：

@SpringBootApplication
@EnableDiscoveryClient
//这种方式是精准打击，只拿指定的类
//@EnableFeignClients(clients = {UserDemo.class})
//这种方式会将指定包下的所有东西都拿过来
@EnableFeignClients(basePackages = "com.alibaba.provider.feigns")
public class OrderNacosApplication{

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

OpenFeign的超时配置

Ps：OpenFeign早期版本（例如 2020版本以前 ）要求服务提供方在1秒内处理业务逻辑并返回响应。如果超过1秒没有返回，OpenFeign会直接报错，不会等待服务执行。随着版本的更新，OpenFeign已经对此做出了调整或优化（例如 2021.0.1)

方法一：修改超时时间：在远程调用方的 application.yml 中配置，指定某个服务提供方的调用超时时间

feign:
  client:
    config:
      product-service: # 服务名
        connect-timeout: 5000 # 配置指定服务连接超时时间
        read-timeout: 5000 # 配置指定服务等待超时时间
      stock-nacos: # 服务名
        connect-timeout: 5000 # 配置指定服务连接超时时间
        read-timeout: 5000 # 配置指定服务等待超时时间

在远程调用方的 application.yml 中配置，指定所有服务提供方的调用超时时间

feign:
  client:
    config:
      default: # 所有服务
        connect-timeout: 5000 # 配置指定服务连接超时时间
        read-timeout: 5000 # 配置指定服务等待超时时间

方法二；配置类

package com.test.order.config;

import feign.Request;
import org.springframework.context.annotation.Bean;

/**
 * @Description:
 * @Author: xu
 * @Data: 2024-2024/4/10-21
 * @Version: V1.0
 */
 //@Configuration
//注意: 此处配置@configuration注解就会全局生效，如果想指定对应微服务生效，就不能配置
public class FeignTimeOutConfig {
    @Bean
    public Request.Options options() {
        return new Request.Options(5000, 10800);
    }
}

OpenFeign日志有以下几个级别

  • NONE:无记录，默认的
  • BASIC:只记录请求方法和url及响应状态代码和执行时间
  • HEADERS:只记录基本信息及请求和响应头
  • FULL:记录请求和响应的头文件，正文和元数据，信息最全

方法一：配置文件方式设置OpenFeign日志（要查看openfeign日记设置开启openfeign日记和设置feign配置日记级别缺一不可）（推荐）

#开启 openfeign 日志
logging:
  level:
    com.test.order.feign: debug  #这样打印的就只有openfeign的debug日记

#全局生效
feign:
  client:
    config:
      default: # 所有服务生效
        logger-level: FULL

#局部生效
feign:
  client:
    config:
      product-service:  #服务名
        logger-level: basic
      stock-nacos:      #服务名
        logger-level: full

如果配置类设置，配置文件也设置，谁设置全局就是日记级别

方法二：java代码方式设置OpenFeign日志

package com.test.order.config;

import feign.Logger;
import org.springframework.context.annotation.Bean;

/**
 * @Description:
 * @Author: xu
 * @Data: 2024-2024/4/10-17
 * @Version: V1.0
 */
//@Configuration
//注意: 此处配置@configuration注解就会全局生效，如果想指定对应微服务生效，就不能配置
public class FeignClientConfiguration {
    @Bean
    public Logger.Level feignLogLevel(){
        return Logger.Level.FULL;  //一般使用 BASIC 级别，因为太多的日志信息影响效率
    }
}

在这里插入图片描述

全局设置OpenFeign日志级别（如果FeignClientConfiguration类加了注解@Configuration就无需设置以下的defaultConfiguration 属性）

@EnableFeignClients(defaultConfiguration = FeignClientConfiguration.class)

指定服务，设置OpenFeign日志级别（如果FeignClientConfiguration类加了注解@Configuration就无需设置以下的configuration 属性）

@FeignClient(value = "stock-nacos",path = "/stock",configuration = {FeignClientConfiguration.class})
public interface StockFeignService {

    @RequestMapping("/reduce")
    String reduce();

}

Feign 的性能优化：

Feign 的底层客户端实现：

  • URLConnection：默认实现，不支持连接池
  • Apache HttpClient ：支持连接池
  • OKHttp：支持连接池

因此优化Feign的性能主要包括：

  • 使用连接池代替默认的URLConnection
  • 日志级别，最好用basic或none
  • 因此使用 HttpClient 或 OKHttp 代替 URLConnection

引入依赖

<!--httpClient的依赖 -->
<dependency>
    <groupId>io.github.openfeign</groupId>
    <artifactId>feign-httpclient</artifactId>
</dependency>

配置连接池

feign:
  client:
    config:
      default: # default全局的配置
        loggerLevel: BASIC # 日志级别，BASIC就是基本的请求和响应信息 
  httpclient:
    enabled: true # 开启feign对HttpClient的支持
    max-connections: 200 # 最大的连接数
    max-connections-per-route: 50 # 每个路径的最大连接数

实现负载均衡，OpenFeign也具有负载均衡的功能，多个服务端时，采用对应的算法寻找一个服务端进行请求

具体的添加@LoadBalancerClient注解：在调用服务的Service类上添加@LoadBalancerClient注解，并指定服务名。这样，负载均衡器将根据配置的属性来选择合适的服务实例进行调用。例如

/**
* name：指定调用rest接口所对应的服务名
* path 指定调用rest接口所在的stockController指定的eRequestMapping
* 类上无需添加@Component注解
*/
@FeignClient(value = "stock-nacos", path = "/stock") 
public interface StockFeignService{  
    @RequestMapping("/reduce")
    String reduce();
}

package com.test.order.config;

import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.loadbalancer.core.RandomLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ReactorLoadBalancer;
import org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
import org.springframework.cloud.loadbalancer.support.LoadBalancerClientFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.Environment;

public class CustomLoadBalancerConfiguration {

    @Bean
    ReactorLoadBalancer<ServiceInstance> randomLoadBalancer(Environment environment,
                                                            LoadBalancerClientFactory loadBalancerClientFactory) {
        String name = environment.getProperty(LoadBalancerClientFactory.PROPERTY_NAME);
        return new RandomLoadBalancer(loadBalancerClientFactory
                .getLazyProvider(name, ServiceInstanceListSupplier.class),
                name);
    }

}

在你提供的代码示例中，CustomLoadBalancerConfiguration 类并没有标记 @Configuration 注解，但它仍然可以作为一个配置类，并且被 @LoadBalancerClients 注解指定的负载均衡客户端所引用。这是因为 Spring Cloud 在处理 @LoadBalancerClients 注解时会扫描指定的配置类，并且将其中的 @Bean 方法注册为 bean。因此，虽然 CustomLoadBalancerConfiguration 类没有标记 @Configuration 注解，但它仍然被识别为一个配置类，并且其中的 @Bean 方法会被注册为 bean。这样做的好处是，你可以将负载均衡的配置与负载均衡客户端的注册分开，使得代码更加清晰和模块化。

package com.test.order;

import com.test.order.config.CustomLoadBalancerConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClient;
import org.springframework.cloud.loadbalancer.annotation.LoadBalancerClients;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * @Description:
 * @Author: xu
 * @Data: 2024-2024/3/29-16
 * @Version: V1.0
 */
@SpringBootApplication
@EnableFeignClients
@LoadBalancerClients({@LoadBalancerClient(value = "stock-nacos", configuration = {CustomLoadBalancerConfiguration.class})})
public class OrderOpenFeignApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderOpenFeignApplication.class, args);
    }
}

修改契约配置，支持Feign原生的注解（注意:修改契约配置后，OrderFeignService 不再支持springmvc的注解，需要使用Feign原生的注解）

package com.test.order.config;

import feign.Contract;
import org.springframework.context.annotation.Bean;

/**
 * @Description:
 * @Author: xu
 * @Data: 2024-2024/4/10-21
 * @Version: V1.0
 */
 @Component不要使用该注解，会变成全局
public class ContractConfig {

    @Bean
    public Contract feigncontract() {
        return new Contract.Default();
    }
}

方法一：局部配置那个服务使用锲约


@FeignClient(value = "stock-nacos", path = "/stock" ,configuration = {ContractConfig.class})
public interface StockFeignService {

    @RequestLine("GET /reduce")
    String reduce();

}

方法二：配置文件设置指定服务使用锲约

#局部生效
feign:
  client:
    config:
      product-service:
        logger-level: basic
      stock-nacos:
        logger-level: full
        contract: feign.Contract.Default  #指定Feign原生注解契约配置

openfeign拦截器

定义openfeign拦截器继承RequestInterceptor 接口

package com.test.order.interceptor;

import feign.RequestInterceptor;
import feign.RequestTemplate;

/**
 * @Description:
 * @Author: xu
 * @Data: 2024-2024/4/10-21
 * @Version: V1.0
 */
public class CustomFeignAuthRequestInterceptor implements RequestInterceptor {


    @Override
    public void apply(RequestTemplate requestTemplate) {
        System.out.println("openfeign拦截器执行了");
        requestTemplate.header("token","888");
    }
}

方法一：使用配置类实现openfeign的拦截器

package com.test.order.config;

import com.test.order.interceptor.CustomFeignAuthRequestInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Description:
 * @Author: xu
 * @Data: 2024-2024/4/10-21
 * @Version: V1.0
 */
//@Configuration
//注意: 此处配置@configuration注解就会全局生效，如果想指定对应微服务生效，就不能配置
public class FeignInterceptorConfig {

    @Bean
    public CustomFeignAuthRequestInterceptor feignAuthRequestInterceptor(){
        return new CustomFeignAuthRequestInterceptor();
    }
}

全局设置OpenFeign拦截器（如果FeignClientConfiguration类加了注解@Configuration就无需设置以下的defaultConfiguration 属性）

@EnableFeignClients(defaultConfiguration = FeignInterceptorConfig .class)

指定服务，设置OpenFeign拦截器（如果FeignInterceptorConfig 类加了注解@Configuration就无需设置以下的configuration 属性）

@FeignClient(value = "stock-nacos",path = "/stock",configuration = {FeignInterceptorConfig .class})
public interface StockFeignService {

    @RequestMapping("/reduce")
    String reduce();

}

方法二：配置文件的yml实现openfeign的拦截器

feign:
  client:
    config:
      stock-nacos:
        request-interceptors:
          - com.test.order.interceptor.CustomFeignAuthRequestInterceptor

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/532988.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

计算机视觉 | 基于 ORB 特征检测器和描述符的全景图像拼接算法

计算机视觉 | 基于 ORB 特征检测器和描述符的全景图像拼接算法

Hi&#xff0c;大家好&#xff0c;我是半亩花海。本项目实现了基于 ORB 特征检测器和描述符的全景图像拼接算法&#xff0c;能够将两张部分重叠的图像拼接成一张无缝连接的全景图像。 文章目录 一、随机抽样一致算法二、功能实现三、代码解析四、效果展示五、完整代码 一、随机…
阅读更多...
如何合理利用Vue 3中的ref和reactive

如何合理利用Vue 3中的ref和reactive

&#x1f90d; 前端开发工程师、技术日更博主、已过CET6 &#x1f368; 阿珊和她的猫_CSDN博客专家、23年度博客之星前端领域TOP1 &#x1f560; 牛客高级专题作者、打造专栏《前端面试必备》 、《2024面试高频手撕题》 &#x1f35a; 蓝桥云课签约作者、上架课程《Vue.js 和 E…
阅读更多...
uni-app实现分页--（1）准备工作，首页下拉触底加载更多

uni-app实现分页--（1）准备工作，首页下拉触底加载更多

实现流程如下: 分析&#xff1a;需要在滚动容器中添加滚动触底&#xff0c;在猜你喜欢中获取数据。难点&#xff1a;如何在父页面调用子组件内的方法。父组件中用ref&#xff0c;并定义组件实例类型&#xff0c;子组件中暴露方法 具体代码如下&#xff1a; 1.在父组件中添加…
阅读更多...
去中心化社交媒体：分析 Facebook 在区块链平台上的角色

去中心化社交媒体：分析 Facebook 在区块链平台上的角色

在当今数字时代&#xff0c;社交媒体已经成为人们日常生活中不可或缺的一部分。然而&#xff0c;随着人们对数据隐私和信息控制的关注不断增加&#xff0c;传统的中心化社交媒体平台也面临着越来越多的质疑和挑战。为了应对这些挑战&#xff0c;越来越多的人开始探索去中心化社…
阅读更多...
关于Renesas R7 的选项字节开关看门狗

关于Renesas R7 的选项字节开关看门狗

Renesas看门狗的模式是在选项字节中进行配置的&#xff0c;OPBT0的寄存器说明如下&#xff0c; 关于看门狗模式 &#xff1a; 和看门狗喂狗方式&#xff1a; 我们选择关闭看门狗&#xff08;也就是配置31位为软件触发看门狗开始&#xff0c;然后不启动就相当于关闭&#xff09…
阅读更多...
【动手学深度学习】15_汉诺塔问题

【动手学深度学习】15_汉诺塔问题

注&#xff1a; 本系列仅为个人学习笔记&#xff0c;学习内容为《算法小讲堂》&#xff08;视频传送门&#xff09;&#xff0c;通俗易懂适合编程入门小白&#xff0c;需要具备python语言基础&#xff0c;本人小白&#xff0c;如内容有误感谢您的批评指正 汉诺塔&#xff08;To…
阅读更多...
2024谷歌Google广告推广投放怎么做？如何收费？

2024谷歌Google广告推广投放怎么做？如何收费？

当今全球市场&#xff0c;谷歌作为全球最大的搜索引擎&#xff0c;其广告服务——Google Ads&#xff0c;已成为企业触达全球消费者、提升品牌知名度、驱动业务增长的首选渠道之一。尤其是在2024年&#xff0c;随着数字营销环境的持续演进&#xff0c;精准、高效地运用Google A…
阅读更多...
MySQL-创建和管理表：基础知识、创建和管理数据库、创建表、修改表、重命名表、删除表、清空表、拓展

MySQL-创建和管理表：基础知识、创建和管理数据库、创建表、修改表、重命名表、删除表、清空表、拓展

创建和管理表 1. 基础知识1.1 一条数据存储的过程1.2 标识符命名规则1.3 MySQL中的数据类型 2. 创建和管理数据库2.1 创建数据库2.2 使用数据库2.3 修改数据库2.4 删除数据库 3. 创建表3.1 创建方式13.2 创建方式23.3 查看数据表结构 4. 修改表4.1 追加一个列4.2 修改一个列4.3…
阅读更多...
Prometheus+Grafana监控K8S集群(基于K8S环境部署)

Prometheus+Grafana监控K8S集群(基于K8S环境部署)

目录 一.环境信息二.部署提前工作三.部署Prometheus监控系统四.部署Node_exporter组件五.部署Kube_state_metrics组件六.部署Grafana可视化平台七.Grafana接入Prometheus数据八.Grafana添加监控模板九.拓展 一.环境信息 1.服务器及k8s版本信息 IP地址主机名称角色版本192.168…
阅读更多...
SAM功能改进VRP-SAM论文解读VRP-SAM: SAM with Visual Reference Prompt

SAM功能改进VRP-SAM论文解读VRP-SAM: SAM with Visual Reference Prompt

现已总结SAM多方面相关的论文解读&#xff0c;具体请参考该专栏的置顶目录篇 一、总结 1. 简介 发表时间&#xff1a;2024年3月30日 论文&#xff1a; 2402.17726.pdf (arxiv.org)https://arxiv.org/pdf/2402.17726.pdf代码&#xff1a; syp2ysy/VRP-SAM (github.com)htt…
阅读更多...
JVM面试整理--对象的创建和堆

JVM面试整理--对象的创建和堆

文章目录 对象的创建过程是怎样的?对象在内存中的结构是怎样的&#xff08;专业的叫法&#xff1a;对象的内存布局&#xff09;对象在内存分配时使用的哪种方式&#xff08;有的地方也称为&#xff1a;分配算法&#xff09;知道什么是“指针碰撞”吗&#xff1f;知道什么是“空…
阅读更多...
电商技术揭秘十八：电商平台的云计算与大数据应用小结

电商技术揭秘十八：电商平台的云计算与大数据应用小结

电商技术揭秘相关系列文章 电商技术揭秘一&#xff1a;电商架构设计与核心技术 电商技术揭秘二&#xff1a;电商平台推荐系统的实现与优化 电商技术揭秘三&#xff1a;电商平台的支付与结算系统 电商技术揭秘四&#xff1a;电商平台的物流管理系统 电商技术揭秘五&#xf…
阅读更多...
【产品】ANET智能通信管理机 物联网网关 电力监控/能耗监测/能源管理系统

【产品】ANET智能通信管理机 物联网网关 电力监控/能耗监测/能源管理系统

产品概述 本系列智能通信管理机是一款采用嵌入式硬件计算机平台&#xff0c;具有多个下行通信接口及一个或者多个上行网络接口&#xff0c;用于将一个目标区域内所有的智能监控/保护装置的通信数据整理汇总后&#xff0c;实时上传主站系统&#xff0c;完成遥信、遥测等能源数据…
阅读更多...
遥感图像处理：从畸变消除到专题信息提取

遥感图像处理：从畸变消除到专题信息提取

​ ​ ​在遥感技术的应用中&#xff0c;图像处理是不可或缺的关键步骤。从消除各种辐射畸变和几何畸变&#xff0c;到利用增强技术突出景物的光谱和空间特征&#xff0c;再到进一步理解、分析和判别处理后的图像&#xff0c;这一过程为我们呈现了一幅幅更为真实、清晰的…
阅读更多...
Elasticsearch：从 ES|QL 到 PHP 对象

Elasticsearch：从 ES|QL 到 PHP 对象

作者&#xff1a;来自 Elastic Enrico Zimuel 从 elasticsearch-php v8.13.0 开始&#xff0c;你可以执行 ES|QL 查询并将结果映射到 stdClass 或自定义类的 PHP 对象。 ES|QL ES|QL 是 Elasticsearch 8.11.0 中引入的一种新的 Elasticsearch 查询语言。 目前&#xff0c;它在…
阅读更多...
基于GRU实现评论文本情感分析

基于GRU实现评论文本情感分析

一、问题建模 在线评论的细粒度情感分析对于深刻理解商家和用户、挖掘用户情感等方面有至关重要的价值&#xff0c;并且在互联网行业有极其广泛的应用&#xff0c;主要用于个性化推荐、智能搜索、产品反馈、业务安全等。此博文&#xff0c;共包含6大类20个细粒度要素的情感倾…
阅读更多...
SpringBoot中的Redis的简单使用

SpringBoot中的Redis的简单使用

在Spring Boot项目中使用Redis作为缓存、会话存储或分布式锁等组件&#xff0c;可以简化开发流程并充分利用Redis的高性能特性。以下是使用Spring Boot整合Redis的详细步骤&#xff1a; 1. 环境准备 确保开发环境中已安装&#xff1a; Java&#xff1a;用于编写和运行Spring…
阅读更多...
RISC-V特权架构 - 中断注入

RISC-V特权架构 - 中断注入

中断注入 1 中断注入的作用2 mip寄存器3 中断注入后的处理过程 本文属于《 RISC-V指令集基础系列教程》之一&#xff0c;欢迎查看其它文章。 1 中断注入的作用 中断注入&#xff0c;就是在M模式下&#xff0c;手动向S模式去产生一个中断。 比如&#xff1a;向mip寄存器的bit5…
阅读更多...
✌2024/4/6—力扣—最长公共前缀✌

✌2024/4/6—力扣—最长公共前缀✌

代码实现&#xff1a; char *longestCommonPrefix(char **strs, int strsSize) {if (strsSize 0) {return "";}for (int i 0; i < strlen(strs[0]); i) { // 列for (int j 1; j < strsSize; j) { // 行if (strs[0][i] ! strs[j][i]) { // 如果比较字符串的第…
阅读更多...
三、Mat、Bitmap和Image数据类型之间的转换（OpenCvSharp）

三、Mat、Bitmap和Image数据类型之间的转换（OpenCvSharp）

在OpenCV中可以通过ImRead方法读取照片&#xff0c;通过ImShow方法显示照片&#xff1b;但是无法在PictureBox控件中显示 PictureBox控件只能展示Bitmap和Image数据类型图片 为此查阅了网上很多篇博文&#xff0c;将三种数据类型之间的转换进行了归纳整理&#xff0c;感谢网上…
阅读更多...
最新文章

Copyright @ 2022~2023