当前位置： 首页 > news >正文

04_feign介绍（OpenFeign）

news 来源：原创 2024/5/10 3:59:00

feign介绍

更接口化 面向对象那种形式 (消费端)

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

Feign可以做到使用HTTP 请求远程服务时就像调用本地方法一样的体验

OpenFeign—快速使用

复制order-nacos项目

1.引入依赖

   <!--   添加openfeign依赖   前提要有springcloud依赖支持  -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>

2.编写接口

package com.tian.order.feign;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 * name 指定调用rest接口所对应的服务名
 * path指定调用rest接口所在的StockController指定的@RequestMapping
 */
@FeignClient(name = "stock-service",path = "/stock")
public interface StockFeignService {
    //声明需要调用的rest接口对应得方法
    //没有实现类 ----  可以联想mybatis 动态代理
    @RequestMapping("/reduct")
     String reduct();
}
/*
*  stock-service controller的代码
@RestController
@RequestMapping("/stock")
public class StockController {

    @Value("${server.port}")
    String port;

    @RequestMapping("/reduct")
    public String reduct(){
        System.out.println("扣减库存");
        return "扣减库存"+port;
    }
}

* */

3.controller层

@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    StockFeignService stockFeignService;
    @RequestMapping("/add")
    public String add(){
        System.out.println("下单成功!");
        String msg = stockFeignService.reduct();
        return "hello feign"+msg;
    }
}

4.主启动类

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


}

5.配置文件

server:
  port: 8040
#应用名称 nacos会将该名称当作服务名称
spring:
  application:
    name: order-service
  cloud:
    nacos:
      server-addr: 127.0.0.1:8848
      discovery:
        username: nacos
        password: nacos
        namespace: public

6.测试访问

http://localhost:8040/order/add

OpenFeign—日志配置

通过源码可以看到日志等级有4种，分别是;

  • NONE【性能最佳，适用于生产】:不记录任何日志（默认值)。

  • BASIC【适用于生产环境追踪问题】︰仅记录请求方法、 URL、响应状态代码以及执行时间。

  • HEADERS:记录BASIC级别的基础上，记录请求和响应的header.

  • FULL【比较适用于开发及测试环境定位问题】∶记录请求和响应的header、body和元数据。

  • 全局配置 作用于所有的服务提供方

1.创建一个模块 product-nacos

pom依赖

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--    nacos服务注册发现 -->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
    </dependencies>

配置文件

server:
  port: 8023

#应用名称 nacos会将该名称当作服务名称
spring:
  application:
    name: product-service
  cloud:
    nacos:
      server-addr: 127.0.0.1:8848
      discovery:
        username: nacos
        password: nacos
        namespace: public

controller

@RestController
@RequestMapping("/product")
public class ProductController {

    @Value("${server.port}")
    String port;

    @RequestMapping("/{id}")
    public String get(@PathVariable Integer id){
        System.out.println("查询商品"+id);
        return "查询商品"+id+":"+port;
    }
}

2.order-openfeign模块

编写配置类 config/FeignConfig.java

//@Configuration
//如果想要局部 注释@Configuration 想在哪配置日记就加上
//例在StockFeignService接口中配置 @FeignClient(name = "stock-service",path = "/stock",configuration = FeignConfig.class)
public class FeignConfig {

    @Bean
    public Logger.Level feignLoggerLevel(){
        return Logger.Level.FULL;
    }
}

相当于serive层 feign/StockFeignService

/**
 * name 指定调用rest接口所对应的服务名
 * path指定调用rest接口所在的StockController指定的@RequestMapping
 */
@FeignClient(name = "stock-service",path = "/stock",configuration = FeignConfig.class)
public interface StockFeignService {
    //声明需要调用的rest接口对应得方法
    //没有实现类 ----  可以联想mybatis 动态代理
    @RequestMapping("/reduct")
     String reduct();
}

相当于serive层 feign/ProductFeignService

@FeignClient(name = "product-service",path = "/product")
public interface ProductFeignService {
    //feign更严格 @PathVariable("id") 要指定参数
    @RequestMapping("/{id}")
    public String get(@PathVariable("id") Integer id);
}

配置文件配置局部日志

server:
  port: 8040
#应用名称 nacos会将该名称当作服务名称
spring:
  application:
    name: product-service
  cloud:
    nacos:
      server-addr: 127.0.0.1:8848
      discovery:
        username: nacos
        password: nacos
        namespace: public
#全局配置--springboot默认的日记级别是info ，feign的debug日志级别就不会输入
logging:
  level:   # 如果在这写上debug 就是所有的 非常多
    com.tian.order.feign: debug   
#局部配置 -- feign日记局部配置
feign:
  client:
    config:
      product-service:
        loggerLevel: BASIC

controller层

@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    StockFeignService stockFeignService;
    @Autowired
    ProductFeignService productFeignService;


    @RequestMapping("/add")
    public String add(){
        System.out.println("下单成功!");
        String msg = stockFeignService.reduct();
        String s = productFeignService.get(1);
        return "hello feign"+msg+s;
    }
}

测试访问查看控制台日记记录

http://localhost:8040/order/add

结果页面显示 hello feign扣减库存8021查询商品1:8023

  • 局部配置 1.配置类 2.配置文件

配置类

@FeignClient(name = "stock-service",path = "/stock",configuration = FeignConfig.class)
public interface StockFeignService {
    //...
}

配置文件

#局部配置 -- feign日记局部配置
feign:
  client:
    config:
      product-service:   #提供服务名
        loggerLevel: BASIC

OpenFeign—契约配置

@RequestMapping("/{id}")  //原生注解@RequestLine
public String get(@PathVariable("id") Integer id); //原生注解@Param

使用场景 版本升级 保留这个原生注解

Sping Cloud在Feign的基础上做了扩展，使目 spring MNVC的注解来完feign的功能。而生的feign是不支持springMVC注解的，如果你想在springcloud中使用质生的主解方式来定义容户端也是可以的的，通过配置契约来改变这个配置，Spring Cloud 中默认的是 SpringMvcContract。

​ Spring Cloud 1早期版本就是用的原生Fegin.随着netflix的停更替换成了Open feign

1.配置类配置

   /**
     * 修改契约配置，支持feign原生的注解
     * @return
     */
    @Bean
    public Contract feignContract(){
        return new Contract.Default();
    }

2.配置文件配置

# feign日记局部配置
feign:
  client:
    config:
      product-service:
        loggerLevel: BASIC
        contract: feign.Contract.Default #设置为默认的契约（还原成原生注解）

ProductFeignService接口改变

@FeignClient(name = "product-service",path = "/product")
public interface ProductFeignService {
    @RequestLine("GET /{id}") 
    public String get(@Param("id") Integer id); /
}

OpenFeign—超时时间配置

通过Oplons 可以配置连接超时时间和读取超的间，Options 的第一个参数是连接的超的时时间(ms)，默认值是2s;第二个是清求处理的超时加时间(ns)，默认值是5s.

全局配置

@Configuration
public class FeignConfig {
    @Bean
    public Request.Options options(){
        return new Request.Options(5000,10000);
    }
}

yml中配置

# feign日记局部配置
feign:
  client:
    config:
      product-service:
        loggerLevel: BASIC
        contract: feign.Contract.Default #设置为默认的契约（还原成原生注解）
        # 连接超时时间 默认2s
        connectTimeout: 5000
        # 请求处理超时时间 默认5s
        readTimeout: 3000

OpenFeign—自定义拦截器

1.编写拦截器

package com.tian.order.interceptor;

import feign.RequestInterceptor;
import feign.RequestTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class CustomFeignInterceptor implements RequestInterceptor {
   Logger logger= LoggerFactory.getLogger(this.getClass());
    public void apply(RequestTemplate requestTemplate) {
        requestTemplate.header("xxx","xxx");
        requestTemplate.query("id","111");
        requestTemplate.uri("9");
        logger.info("feign拦截器!");
    }
}

2.配置文件使其生效(或者注入配置类 configuration 中@Bean)

# feign日记局部配置
feign:
  client:
    config:
      product-service:
        loggerLevel: BASIC
        contract: feign.Contract.Default #设置为默认的契约（还原成原生注解）
        # 连接超时时间 默认2s
#        connectTimeout: 5000
        # 请求处理超时时间 默认5s
#        readTimeout: 3000
        requestInterceptors[0]:
          com.tian.order.interceptor.CustomFeignInterceptor

相关文章：

  • （已更新）关于Visual Studio 2019安装时VS installer无法下载文件，进度条为0，显示网络有问题的解决办法
  • 长安链源码学习v2.2.1--ioc机制（九）
  • 面试必备：《Java 最常见 200+ 面试题全解析》
  • 抖音短视频运营规划内容孵化计划书模板
  • Leetcode 946.验证栈序列
  • CREO：利用CREO软件实现装配设计之四连杆机构设计案例应用(图文教程)之详细攻略
  • 基于数字孪生的智慧城市是如何发展的？
  • STL——list使用和模拟
  • 缓存怎么测试？
  • 智能控制理论及应用 王耀南等编著
  • 修改centos中Mysql( mariadb)数据默认存储位置
  • 神经网络编程教程入门课,人工神经网络编程内容
  • 零基础学Java有哪些必看书？推荐这5本
  • Python语句和循环
  • 阿里巴巴微服务核心手册：Spring Boot+Spring cloud+Dubbo
  • ABAP的include关键字，Java的import, C的include和C4C ABSL 的import比较
  • Fabric架构演变之路
  • httpie使用详解
  • mysql_config not found
  • MySQL常见的两种存储引擎：MyISAM与InnoDB的爱恨情仇
  • Python 反序列化安全问题（二）
  • react 代码优化(一) ——事件处理
  • 创建一个Struts2项目maven 方式
  • 关于 Cirru Editor 存储格式
  • 聊聊redis的数据结构的应用
  • 买一台 iPhone X，还是创建一家未来的独角兽？
  • 我与Jetbrains的这些年
  • ​iOS实时查看App运行日志
  • ​ssh-keyscan命令--Linux命令应用大词典729个命令解读
  • ​中南建设2022年半年报“韧”字当头，经营性现金流持续为正​
  • # 睡眠3秒_床上这样睡觉的人，睡眠质量多半不好
  • #define MODIFY_REG(REG, CLEARMASK, SETMASK)
  • #FPGA（基础知识）
  • （C语言）fgets与fputs函数详解
  • （超详细）语音信号处理之特征提取
  • （二开）Flink 修改源码拓展 SQL 语法
  • （三）elasticsearch 源码之启动流程分析
  • （一）VirtualBox安装增强功能
  • （转）原始图像数据和PDF中的图像数据
  • （转载）从 Java 代码到 Java 堆
  • * 论文笔记 【Wide Deep Learning for Recommender Systems】
  • ***详解账号泄露：全球约1亿用户已泄露
  • **PHP分步表单提交思路（分页表单提交）
  • .net core 6 集成 elasticsearch 并 使用分词器
  • .NET 的程序集加载上下文
  • .NET 反射 Reflect
  • .NET（C#、VB）APP开发——Smobiler平台控件介绍：Bluetooth组件
  • .NET序列化 serializable，反序列化
  • .set 数据导入matlab,设置变量导入选项 - MATLAB setvaropts - MathWorks 中国
  • .xml 下拉列表_RecyclerView嵌套recyclerview实现二级下拉列表，包含自定义IOS对话框...
  • @Import注解详解
  • [ C++ ] STL---string类的模拟实现
  • [ 代码审计篇 ] 代码审计案例详解(一) SQL注入代码审计案例
  • [20140403]查询是否产生日志
  • [AIR] NativeExtension在IOS下的开发实例 --- IOS项目的创建 (一)