Spring Cloud全文目录

OpenFeign简介

什么是Feign？

Feign是一个声明式WebService客户端。使用Feign能让编写Web Service客户端更加简单。它的使用方法是定义一个服务接口然后在上面添加注解，同时也支持JAX-RS标准的注解。Feign也支持可拔插式的编码器和解码器。Spring Cloud对Feign进行封装，使其支持了Spring MVC标准注解和HttpMessageConverters。Feign可以与Eureka和Ribbon组合使用支持负载均衡。

Feign是能干什么？

Feign旨在使编写Java Http客户端变得更容易。

前面在使用Ribbon+RestTemplate时，利用RestTemplate对http请求的封装处理，形成了一套模板化的调用方法。但是在实际开发过程中，由于对服务依赖的调用可能不止一处，往往一个接口会被多处调用，所以通常都会针对每个微服务自行封装一些客户端类来包装这些依赖服务的调用。所以,Feign在此基础上做了进一步封装，由他来帮助我们定义和实现依赖服务接口的定义。在Feign的实现下，我们只需要创建一个接口并使用注解的方式来配置它，（以前是Dao接口上面标准Mapper注解，现在是一个微服务接口上面标注一个Feign注解即可）即可完成对服务提供方的接口绑定，简化了Spring Cloud Ribbon时，自动封装服务调用客户端的开发量。

Feign集成了Ribbon

Feign集成了Ribbon，利用Ribbon维护了Payment的服务列表信息，并且通过轮询实现了客户端的负载均衡，而与Ribbon不同的是，通过Feign值需要定义服务绑定接口且一声明式的方法，优雅而简单的实现了服务调用。

Feign和OpenFeign有什么区别？

OpenFeign实现负载均衡

1.建立module: springcloud-consumer-feign-order82

2.pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>springcloud</artifactId><groupId>com.dyh.springcloud</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>springcloud-consumer-feign-order82</artifactId><dependencies><!--openfeign--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><!--eureka client--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><!--引入自定义的api通用包，可以使用Payment支付Entity--><dependency><groupId>com.dyh.springcloud</groupId><artifactId>springcloud-api-commons</artifactId><version>${project.version}</version></dependency><!--web--><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><!--一般基础通用配置--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>
</project>

3.application.yml

server:port: 82eureka:client:register-with-eureka: falseservice-url:defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/

4.主启动类 OrderFeignMain82

package com.dyh.springcloud;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;/*** @ClassName: OrderFeignMain82* @author: dyh* @since: 2021/12/17 18:26*/
@SpringBootApplication
@EnableFeignClients //开启Feign
public class OrderFeignMain82 {public static void main(String[] args) {SpringApplication.run(OrderFeignMain82.class, args);}
}

5. 业务类

PaymentFeignService

package com.dyh.springcloud.service;import com.dyh.springcloud.entities.CommonResult;
import com.dyh.springcloud.entities.Payment;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;/*** @ClassName: PaymentFeignService* @author: dyh* @since: 2021/12/17 18:28*/
@Component
@FeignClient(value = "SPRINGCLOUD-PAYMENT-SERVICE")  //指定调用哪个微服务
public interface PaymentFeignService {//调用生产者微服务名称为SPRINGCLOUD-PAYMENT-SERVICE下边的接口@GetMapping(value = "/payment/get/{id}")CommonResult<Payment> getPaymentById(@PathVariable("id") Long id);
}

OrderFeignController

package com.dyh.springcloud.controller;import com.dyh.springcloud.entities.CommonResult;
import com.dyh.springcloud.entities.Payment;
import com.dyh.springcloud.service.PaymentFeignService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;/*** @ClassName: OrderFeignController* @author: dyh* @since: 2021/12/17 18:37*/
@RestController
@Slf4j
public class OrderFeignController {@Autowiredprivate PaymentFeignService paymentFeignService;@GetMapping(value = "/consumer/payment/get/{id}")public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id) {return paymentFeignService.getPaymentById(id);}
}

6.测试

先启动2个eureka集群 7001/7002
在启动2个微服务 8001/8002
启动OpenFeign 82
访问路径http://localhost:82/consumer/payment/get/1，看看是否有负载均衡的功能。

多次刷新，8001和8002会依次出现，Feign自带负载均衡配置项

7.总结

OpenFeign就是根据@FeignClient注解所设置的微服务名称去调用该服务下的接口，如下图：

OpenFeign实现超时控制

由于我们的服务分为生产者和消费者，所以我们的消费者服务去调用生产者服务的时候响应的时间较长，会出现连接超时的现象，如果长时间未响应会对用户造成极差的体验，这时候我们就可以设置超时实现，比如，我们消费者服务调用生产者服务的时候，我们可设置如果访问生产者服务的时候超过2秒未响应就会给用户一个提示，连接超时，请稍后访问。生产者服务与消费者服务双方要进行规定设置。

那下面进行代码演示超时设置，更容易直观了解学习。我们将生产者端口为8001的服务，写一个接口，让程序暂停3秒，故意设置超时演示出错情况，如下：

//模拟业务接口延时3秒
@GetMapping("/payment/feign/timeout")
public String PaymentFeignTimeOut() throws InterruptedException {TimeUnit.SECONDS.sleep(3);return serverPort;
}

在消费者82服务业务层添加超时的接口，如下：

//调用生产者微服务名称为SPRINGCLOUD-PAYMENT-SERVICE下边的模拟超时的接口
@GetMapping("/payment/feign/timeout")
public String PaymentFeignTimeOut() throws InterruptedException;

在消费者82服务控制层添加超时的接口，如下：

@GetMapping("/consumer/feign/timeout")
public String PaymentFeignTimeOut() throws InterruptedException{return paymentFeignService.PaymentFeignTimeOut();
}

我们先自测一下端口为8001的生产者的微服务，访问接口http://localhost:8001/payment/feign/timeout，如下图：

自测通过后访问消费者82的服务，接口为 http://localhost:82/consumer/feign/timeout，会出现如下报错界面，提示我们接口访问超时。

原因就是Openfeign默认等待1秒钟，超过后会报错。但是我们的生产者8001服务确实需要处理复杂的业务，处理时间会超过1秒，就需要修改Openfeign默认等待的时间。需要在消费者82的服务的yml文件进行设置。因为Feign集成了Ribbon，所以需要设置Ribbon的相关。如下：

server:port: 82eureka:client:register-with-eureka: falsefetch-registry: trueservice-url:defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/# 设置feign客户端超时时间(OpenFeign默认支持ribbon)
ribbon:# 指的是建立连接所用的时间,适用于网络状态正常的情况下,两端连接所用的时间，设置等待5000为5秒时间ReadTimeout: 5000# 指的是建立连接后从服务器读取到可用资源所用的时间ConnectTimeout: 5000

我们重启消费者82服务，再次访问http://localhost:82/consumer/feign/timeout，会出现如下成功界面：

OpenFeign实现日志打印

Openfeign提供了日志打印功能。比如我们消费者服务调用生产者的服务的时候在接口调用的时候，我们可能需要更详细的信息，如信息头、状态码、时间、接口等等。就可以使用Openfeign日志打印功能，我们可以通过配置来调整日志级别，从而了解Feign中Http请求的细节。也就是对Feign接口的调用情况进行监控和输出。
Logger有四种类型：

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

通过注册Bean来设置日志记录级别！

开始配置日志Bean，我们新建配置文件FeignConfig，记得加注解@Configuration

package com.dyh.springcloud.config;import feign.Logger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @ClassName: FeignConfig* @author: dyh* @since: 2021/12/22 15:35*/
@Configuration
public class FeignConfig {/*** feignClient配置日志级别** @return*/@Beanpublic Logger.Level feignLoggerLevel() {// 请求和响应的头信息,请求和响应的正文及元数据return Logger.Level.FULL;}}

在yml文件中需要开启日志的Feign客户端，要写PaymentFeignService业务类的全限定类名

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

重启的消费者82服务，访问接口，看一下控制台打印的日志信息。

OpenFeign就学习到这里了，简直是so easy！

下一篇文章我们继续Hystrix，继续加油鸭！

手把手教你搭建SpringCloud项目（十）集成OpenFeign服务接口调用相关推荐

手把手教你搭建SpringCloud项目（十六）集成Stream消息驱动
Spring Cloud全集文章目录: 零.什么是微服务?一看就会系列! 一.手把手教你搭建SpringCloud项目(一)图文详解,傻瓜式操作二.手把手教你搭建SpringCloud项目(二)生产 ...
手把手教你搭建SpringCloud项目（十）集成Hystrix之服务降级
Spring Cloud全集文章目录: 零.什么是微服务?一看就会系列! 一.手把手教你搭建SpringCloud项目(一)图文详解,傻瓜式操作二.手把手教你搭建SpringCloud项目(二)生产 ...
手把手教你搭建SpringCloud项目（九）集成OpenFeign服务接口调用
Spring Cloud全集文章目录: 零.什么是微服务?一看就会系列! 一.手把手教你搭建SpringCloud项目(一)图文详解,傻瓜式操作二.手把手教你搭建SpringCloud项目(二)生产 ...
手把手教你搭建Maven项目
大家好,我是雄雄,欢迎关注微信公众号[雄雄的小课堂]. 今天给大家分享的是"手把手教你买基金",奥!!不对,不好意思,是"手把手教你使用idea搭建Maven项目&quo ...
SpringCloud Hoxton——OpenFeign服务接口调用
1.开篇 github源码地址:https://github.com/2656307671/-SpringCloud-Hoxton-OpenFeign gite源码地址:https://gitee.c ...
手把手教你搭建SpringCloudAlibaba之Nacos服务配置中心
SpringCloud Alibaba全集文章目录: 零.手把手教你搭建SpringCloudAlibaba项目一.手把手教你搭建SpringCloud Alibaba之生产者与消费者二.手把手教 ...
六、手把手教你搭建SpringCloudAlibaba之Sentinel实现流量实时监控
SpringCloud Alibaba全集文章目录: 零.手把手教你搭建SpringCloudAlibaba项目一.手把手教你搭建SpringCloud Alibaba之生产者与消费者二.手把手教 ...
手把手教你搭建Hadoop生态系统伪分布式集群
Hello,我是 Alex 007,一个热爱计算机编程和硬件设计的小白,为啥是007呢?因为叫 Alex 的人太多了,再加上每天007的生活,Alex 007就诞生了. 手把手教你搭建Hadoop生态 ...
手把手教你创建springBoot项目
**# 手把手教你创建springBoot项目千里之行始于足下简介 springboot是用来简化spring应用的初始搭建以及开发过程使用特定的方式来进行配置(properties或yml文 ...
手把手教你搭建属于自己的技术博客（小白教程）
手把手教你搭建属于自己的技术博客先放上我自己搭建的博客地址 https://sourl.cn/Tbk7yt 这里我使用的是 Hexo 框架以及 Github pages 进行的搭建文章目录手把 ...

手把手教你搭建SpringCloud项目（十）集成OpenFeign服务接口调用