springcloud 之 Feign Rpc
本文内容纲要：
既然springcloud是一个微服务架构生态体系，而且上一章我们也介绍了微服务体系中一个核心组件“服务的发现与注册”eureka，接下来我们来简单探索以下微服务体系中另一个核心组件“rpc”；在springcloud体系中实现rpc的组件有2个，一个是ribbon，另一个是feign，而且feign在底层封装了ribbon，以更友好，更灵活的形式展现在了我们眼前，所以今天我们研究的重心放在了feign身上。
（摘抄一段话，帮助大家更清晰的认识feign）
feign是netflix提供的服务间基于http的rpc调用框架，在springcloud得到广泛应用。默认情况下，一个feignclient是在hystrix断路器中执行，并利用ribbon进行软负载选择远程服务（service），所以可以想象出一个feignclient的层次架构是包裹的层次，hystrix控制整个rpc从调用到方法返回，而ribbon控制从选址到socket返回；
那么什么是hystrix呢？
首先我们先置身于这样一个场景在微服务架构中，我们将业务拆分成一个个的服务，而服务与服务之间可以相互调用（RPC方式）。为了保证其高可用，单个服务又可能回事集群环境部署。所以可能存在由于网络原因或者自身的原因，并不能保证服务的100%可用，如果单个服务出现问题，调用这个服务就会出现网络延迟，此时若有大量的网络涌入，会形成任务累计，导致服务瘫痪，甚至导致服务“雪崩”。
为了解决这个问题，就出现断路器模型。
而hystrix就是Netflix的一个库并且实现了断路器模式。
（摘抄自一位网友的图）
较底层的服务如果出现故障，会导致连锁故障。当对特定的服务的调用达到一个阀值（hystric是5秒20次）断路器将会被打开。
断路打开后，可用避免连锁故障，fallback方法可以直接返回一个固定值。
好了，接下来我们来配置一下实际环境中我们应该怎样使用feign+hystrix？
注：基于test项目（我新建的另一个springboot项目）和demo-springboot项目；
1.打开test项目的pom.xml加入相关依赖：
<!--feign-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-feign</artifactId>
<version>1.3.4.RELEASE</version>
</dependency>
2.打开application-dev.properties加入以下内容：
#feignreadtimeout(10s)
hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=10000
#feignreadtimoutdisable（该配置，用于禁用Hystrix的超时时间 ）
#hystrix.command.default.execution.timeout.enabled=false
#关闭hystrix功能
#feign.hystrix.enabled=false
切记feignreadtimeout配置一个合适的超时时间，不要用默认的，我刚开始的时候没有配置，结构一直调用返回error，发现是超时了。
3.在demo-springboot中添加测试controller:
packagecom.example.demo.controller;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RequestParam;
importorg.springframework.web.bind.annotation.RestController;
/**
*@authorxiaofeng
*@versionV1.0
*@title:TestController.java
*@package:com.example.demo.controller
*@description:TODO
*@date2018/4/30003下午2:10
*/
@RestController
@RequestMapping(value="/test")
publicclassTestController{
@RequestMapping(value="/info")
publicStringinfo(@RequestParam(value="msg")Stringmsg){
return"welcometodemo-springboot:"+msg;
}
}
4.在test项目中增加rpc相关服务类：
@FeignClient(value="demo-springboot",fallback=RpcServiceImpl.class)
publicinterfaceRpcService{
/**
*查询test
*
*@parammsg
*@return
*/
@RequestMapping(value="/test/info",method=RequestMethod.GET)
Stringquery(@RequestParam(value="msg")Stringmsg);
}
@Service
publicclassRpcServiceImplimplementsRpcService{
/**
*查询test
*
*@parammsg
*@return
*/
@Override
publicStringquery(Stringmsg){
return"error";
}
}
5.在test项目中编写测试controller:
@RestController
publicclassTestController{
@Autowired
RpcServicerpcService;
@RequestMapping(value="/test/index")
publicStringindex(@RequestParam(value="msg")Stringmsg){
returnrpcService.query(msg);
}
}
然后再启动类中开启注解@EnableFeignClients(basePackages={"com.xx.xx.test.service"})：表示feign需要扫描的package路径（我的rpcService放在service包下）。
@EnableFeignClients(basePackages={"com.xx.xx.test.service"})
@EnableAutoConfiguration
@EnableEurekaClient
@SpringBootApplication
publicclassXsignal2TestApplication{
publicstaticvoidmain(String[]args){
SpringApplication.run(Xsignal2TestApplication.class,args);
}
}
6.最后分别启动discover-server、demo-springboot、test三个服务
查看eureka控制面板三个服务是否都已经启动：
ok，接下来开始测试，首先是正常测试，打开浏览器：
出现的是我们理想的结果，说明我们的rpc已经走通了哦，是不是有点小鸡冻啊。
7.介绍一些常用配置
以上这种配置也是全局配置，如果我们想针对某一个接口配置，比如**/hello**接口，那么可以按照下面这种写法，如下：
#设置熔断超时时间
hystrix.command.hello.execution.isolation.thread.timeoutInMilliseconds=10000
#关闭熔断功能
hystrix.command.hello.execution.timeout.enabled=false
#配置请求GZIP压缩
feign.compression.request.enabled=true
#配置响应GZIP压缩
feign.compression.response.enabled=true
#配置压缩支持的MIMETYPE
feign.compression.request.mime-types=text/xml,application/xml,application/json
#配置压缩数据大小的下限
feign.compression.request.min-request-size=2048
注意点：
1.有些公共的组件抽出来其他模块的maven依赖，此时要在使用的项目中加载此jar包的springcomponent以及feign组件，仅仅依靠@ComponentScan是不够的，还需要在@EnableFeignClients(basePackages={"com.xx.xx.test.service"})中标注basekPackages。
2.springcloudfeign注入beannull问题
解决办法：
-
如果swagger版本是v1.x，那么请参考：https://segmentfault.com/a/1190000006595187
-
如果swagger版本是v2.x，那么请将升级swagger版本到2.5.0以上即可。
io.springfox springfox-swagger2 2.5.0 io.springfox springfox-swagger-ui 2.5.0
3.feignrpc返回的json对象转换失败
1.复杂对象转换失败（Response<pageList
2.接口返回对象转换：
ResponseModel
newTypeReference<ResponseModel
本文内容总结：
原文链接：https://www.cnblogs.com/babac/p/9028476.html