扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
小编给大家分享一下Spring cloud Feign如何使用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！
创新互联是一家集网站建设,托里企业网站建设,托里品牌网站建设,网站定制,托里网站建设报价,网络营销,网络优化,托里网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。
简介
Spring Cloud Feign是一个声明式的Web Service客户端，它的目的就是让Web Service调用更加简单。Feign提供了HTTP请求的模板，通过编写简单的接口和插入注解，就可以定义好HTTP请求的参数、格式、地址等信息。Feign会完全代理HTTP请求，开发时只需要像调用方法一样调用它就可以完成服务请求及相关处理。开源地址：https://github.com/OpenFeign/feign。Feign整合了Ribbon负载和Hystrix熔断，可以不再需要显式地使用这两个组件。总体来说，Feign具有如下特性：
可插拔的注解支持，包括Feign注解和JAX-RS注解;
支持可插拔的HTTP编码器和解码器;
支持Hystrix和它的Fallback;
支持Ribbon的负载均衡;
支持HTTP请求和响应的压缩。
Spring Cloud Feign致力于处理客户端与服务器之间的调用需求。随着业务的扩展和微服务数量的增多，不可避免的需要面对如下问题：
弹性客户端
雪崩效应
简单来说，使用Spring Cloud Feign组件，他本身整合了Ribbon和Hystrix。可设计一套稳定可靠的弹性客户端调用方案，避免整个系统出现雪崩效应。
雪崩效应
在微服务架构中，微服务是完成一个单一的业务功能，这样做的好处是可以做到解耦，每个微服务可以独立演进。但是，一个应用可能会有多个微服务组成，微服务之间的数据交互通过远程过程调用完成。这就带来一个问题，假设微服务A调用微服务B和微服务C，微服务B和微服务C又调用其它的微服务，这就是所谓的“扇出”。如果扇出的链路上某个微服务的调用响应时间过长或者不可用，对微服务A的调用就会占用越来越多的系统资源，进而引起系统崩溃，产生“雪崩效应”。引发雪崩效应的原因有：
硬件故障：如服务器宕机，机房断电，光纤被挖断等；
流量激增：如异常流量，重试加大流量等；
缓存穿透：一般发生在应用重启，所有缓存失效时，以及短时间内大量缓存失效时。大量的缓存不命中，使请求直击后端服务，造成服务提供者超负荷运行，引起服务不可用；
程序BUG：如程序逻辑导致内存泄漏，JVM长时间FullGC等；
同步等待：服务间采用同步调用模式，同步等待造成的资源耗尽；
服务降级故障：服务的降级可以是以间歇性的故障开始，并形成不可逆转的势头。可能开始只是一小部分服务调用变慢，直到突然间应用程序容器耗尽了线程（所有线程都在等待调用完成）并彻底崩溃。
弹性客户端
客户端弹性模式是在远程服务发生错误或表现不佳时保护远程资源（另一个微服务调用或者数据库查询）免于崩溃。这些模式的目标是为了能让客户端“快速失败”，不消耗诸如数据库连接、线程池之类的资源，还可以避免远程服务的问题向客户端的消费者进行传播，引发“雪崩”效应。spring cloud Feign主要使用的有四种客户端弹性模式：
客户端负载均衡（client load balance）模式
Spring Cloud Feign集成Ribbon处理。Ribbon 是一个基于 http 和 tcp 客户端的负载均衡，可以配置在客户端，以轮询、随机、权重（权重意思是请求时间越久的server,其被分配给客户端使用的可能性就越低。）等方式实现负载均衡。Feign其实不是做负载均衡的,负载均衡是Ribbon的功能,Feign只是集成了Ribbon 而已。Feign的作用的替代RestTemplate,性能比较低，但是可以使代码可读性很强。
断路器(circuit breaker)模式
本模式模仿的是电路中的断路器。有了软件断路器，当远程服务被调用时，断路器将监视这个调用，如果调用时间太长，断路器将介入并中断调用。此外，如果对某个远程资源的调用失败次数达到某个阈值，将会采取快速失败策略，阻止将来调用失败的远程资源。
后备(fallback)模式
当远程调用失败时，将执行替代代码路径，并尝试通过其他方式来处理操作，而不是产生一个异常。也就是为远程操作提供一个应急措施，而不是简单的抛出异常。
舱壁/隔板(bulkhead)模式
舱壁模式是建立在造船的基础概念上。一艘船会被划分为多个水密舱（舱壁），因而即使少数几个部位被击穿漏水，整艘船并不会被淹没。将这个概念带入到远程调用中，如果所有调用都使用的是同一个线程池来处理，那么很有可能一个缓慢的远程调用会拖垮整个应用程序。在舱壁模式中可以隔离每个远程资源，并分配各自的线程池，使之互不影响。
Hystrix介绍
Hystrix，英文翻译是豪猪，是一种保护机制，Netflix公司的一款组件。主页：https://github.com/Netflix/Hystrix/。Hystix是Netflix开源的一个延迟和容错库，用于隔离访问远程服务、第三方库，防止出现级联失败。
Hystrix特性
1.断路器机制-断路器模式
断路器很好理解, 当Hystrix Command请求后端服务失败数量超过一定比例(默认50%), 断路器会切换到开路状态(Open)。这时所有请求会直接失败而不会发送到后端服务。断路器保持在开路状态一段时间后(默认5秒), 自动切换到半开路状态(HALF-OPEN)。这时会判断下一次请求的返回情况, 如果请求成功, 断路器切回闭路状态(CLOSED), 否则重新切换到开路状态(OPEN)。Hystrix的断路器就像我们家庭电路中的保险丝, 一旦后端服务不可用, 断路器会直接切断请求链, 避免发送大量无效请求影响系统吞吐量, 并且断路器有自我检测并恢复的能力。
熔断器模式就像是那些容易导致错误的操作的一种代理。这种代理能够记录最近调用发生错误的次数，然后决定使用允许操作继续，或者立即返回错误。熔断器就是保护服务高可用的最后一道防线。 熔断器开关相互转换的逻辑如下图：
2.Fallback-后备模式
Fallback相当于是降级操作。对于查询操作, 我们可以实现一个fallback方法, 当请求后端服务出现异常的时候, 可以使用fallback方法返回的值. fallback方法的返回值一般是设置的默认值或者来自缓存。
3.资源隔离-舱壁(bulkhead)模式
在Hystrix中, 主要通过线程池来实现资源隔离。通常在使用的时候应该根据调用的远程服务划分出多个线程池。例如调用产品服务的Command放入A线程池, 调用账户服务的Command放入B线程池. 这样做的主要优点是运行环境被隔离开了。这样就算调用服务的代码存在bug或者由于其他原因导致自己所在线程池被耗尽时, 不会对系统的其他服务造成影响。 但是带来的代价就是维护多个线程池会对系统带来额外的性能开销。如果是对性能有严格要求而且确信自己调用服务的客户端代码不会出问题的话, 可以使用Hystrix的信号模式(Semaphores)来隔离资源。
Spring Cloud Feign 应用
上面主要是讲述了Feign模式管理客户端方面应对的一些问题和理论知识，下面将讲述Feign结合Ribbon和Hystrix在项目中的落地应用。
创建Feign
在Spring Boot项目中， 推荐在pom中添加Feign依赖(feign默认会使用JDK自带的 HttpUrlConnection ，相对于Apache的HttpComponent缺失连接池等扩展信息,详情见:FeignRibbonClientAutoConfiguration)。
org.springframework.cloud spring-cloud-starter-openfeign io.github.openfeign feign-httpclient
在App启动类中，设置启用Feign：
@EnableFeignClients
public class App {
}搭建一个Feign Client基本配置：
@FeignClient(value="wl-service")
public interface WlFeignClient {
@RequestMapping(method = RequestMethod.GET, value= "/stores")
List getStores();
@RequestMapping(method = RequestMethod.POST, value= "/stores/{storeId}", consumes = "application/json")
Store update(@PathVariable("storeId") Long storeId, Store store); @FeignClient
在此处可以配置客户端访问服务的方式，及通过服务名走服务发现模式和http地址模式，其参数可配置如：
服务发现：@FeignClient(value = "wl-v1-00", fallback = ArticleSystemRemoteFallback.class)
http地址：@FeignClient(name = "wl-test", url = "${test.url}", path = "combwl", fallbackFactory = GoodsGroupFeignFallbackFactory.class)
服务发现 模式value及微服务的名称，fallback即定义后备模式，当触发熔断时，定义后备返回接口，便于客户端“快速失败”。
http地址模式 url即是对应微服务的访问地址，path可设置或不设置，表示该服务下面的通用访问路径。fallback是定义后备模式。
FeignClient模式通过Apache的HttpComponent封装调用时，需注意多参数，json等数据的细节处理。
Feign Hystrix断路器模式
Feign本身集成了Hystrix。但默认情况下没有启动。必须显示声明(feign.hystrix.enabled=true)。客户端应用就是在配置文件中设置hystrix的配置，项目自动根据配置文件参数调整。hystrix配置(所有的配置可以参考com.netflix.hystrix.HystrixCommandProperties这个类)。
常用的hystrix配置设置如下：
hystrix: command: default: circuitBreaker： # 是否开启熔断(默认true) enabled: true # 熔断生效至少请求数量(默认20),当同一HystrixCommand请求数量低于此值时,熔断不会开启 requestVolumeThreshold：20 # 失败次数超过比例才开启熔断 errorThresholdPercentage: 50 # 强制开启熔断 #forceOpen： true # 强制关闭熔断 #forceClosed: true execution: isolation: # THREAD:单独开启线程执行;SEMAPHORE:在调用线程上执行(由于我们现有框架中FeignUserContextInterceptor中使用了ThreadLocal,所以必须使用第二种方式) 18. strategy: SEMAPHORE 19. thread: 20. # 执行超时时间(这个时间设置很重要,因为HystrixCommand会包装RibbonClient实例,那么这个时间就必须要大于ribbion timeout * retry,后面Ribbon章节会介绍) timeoutInMilliseconds: 2000 semaphore: # 由于我们使用SEMAPHORE模式,当每个feign并发发起请求超过此值时,请求会被拒绝,直接调用降级方法,异常信息关键字:could not acquire a semaphore for execution maxConcurrentRequests: 1000 fallback: isolation: semaphore: # 由于我们使用SEMAPHORE模式，当每个feign并发发起请求调用降级方法超过此值,调用降级方法会被拒绝,直接抛出异常,异常信息关键字:fallback execution rejected maxConcurrentRequests: 1000
Feign Hystrix后备模式
后备模式就是在远程调用服务时，被断路器切断或服务调用超时时，返回的一种备用方案。应用举例如下：
直接设置fallback，该模式不便于调试具体远程服务调用出错的信息。
/**
* 服务发现模式
*/
@FeignClient(name = "eureka-client",fallback = OpenFeignFallbackServiceImpl.class)//eureka-client工程的服务名称
public interface OpenFeignService {
@GetMapping("/name")//这里的请求路径需要和eureka-client中的请求路径一致
public String test();//这里的方法名需要和eureka-client中的方法名一致
}
/**
* 服务发现-对应后备模式的方法定义
*/
@Service
public class OpenFeignFallbackServiceImpl implements OpenFeignService{
@Override
public String test() {
return "调用服务失败！";
}除了fallback模式，还可以调用fallbackFactory，这种可以记录远程调用失败的具体明细异常。建议采用此方案设置后备模式。
/**
* 声明调用客户端
*/
@FeignClient(name = "wl-sku", url = "${wl.url}", path = "wl", fallbackFactory = WlSkuFeignFallbackFactory.class)
public interface WlSkuFeign {
/**
* 基于商品编码获取商品销售属性明细
*
* @param relationId 参数编码
* @return
*/
@RequestMapping(method = RequestMethod.GET, path = "/item/{relation_id}")
ResponseBody getItemDetail(@PathVariable("relation_id") Integer relationId);
}
/**
* 申明后备模式
*
*/
@Component
public class WlSkuFeignFallbackFactory implements FallbackFactory {
@Override
public WlSkuFeign create(Throwable cause) {
return relationId -> {
ErrorLogger.getInstance().log("商品sku getItemDetail降级服务", cause);
return ResponseBody.fallback(cause, new Error("getItemDetail", "商品服务不可用"));
};
}
} Feign Hystrix舱壁(bulkhead)模式
Feign集成了Hystrix，也可以设置客户端为舱壁模式。通过设置Hystrix的配置文件即可。
Hystrix隔离级别由SEMAPHORE(信号量)模式切换为THREAD(线程池)模式,同时服务追踪功能相应调整适用THREAD模式。该模式有如下特性：
各上游服务(feign客户端)线程资源隔离,相互不影响，可以实现完全的独立配置。
由于feign请求是独立线程,才可以真正意义上的实现超时降级功能(使用semaphore实际上是假的超时功能,比如超时设置1S，实际执行3S，但整体还是会执行3S，只是3S后会抛出TimeoutException触发降级),而thread模式则能够正在的在1S后直接Interrupt请求线程且立刻触发降级，达到真正的断流保护作用。
开启线程池模式会额外开销服务器资源，在开启这种模式时，线程池的数量，服务器资源还是需要监控，综合设置。
Hystrix舱壁(bulkhead)模式常用配置文件：