1、前言
后面介绍了Spring Cloud 中的灵魂摆渡者Nacos
,和它的前辈们相比不仅仅功能强大,而且部署非常简单。
明天介绍一款服务调用的组件:OpenFeign
,同样是一款超过先辈(Ribbon
、Feign
)的狠角色。
文章目录如下:
2、Feign是什么?
Feign也是一个狠角色,Feign旨在使得Java Http客户端变得更容易。
Feign集成了Ribbon、RestTemplate实现了负载平衡的执行Http调用,只不过对原有的形式(Ribbon+RestTemplate)进行了封装,开发者不用手动应用RestTemplate调服务,而是定义一个接口,在这个接口中标注一个注解即可实现服务调用,这样更加合乎面向接口编程的主旨,简化了开发。
但遗憾的是Feign当初进行迭代了,当然当初也是有不少企业在用。
有想要学习Feign的读者能够上spring Cloud官网学习,陈某这里也不再具体介绍了,不是明天的重点。
3、openFeign是什么?
后面介绍过进行迭代的Feign,简略点来说:OpenFeign是springcloud在Feign的根底上反对了SpringMVC的注解,如@RequestMapping
等等。OpenFeign的@FeignClient
能够解析SpringMVC的@RequestMapping
注解下的接口,并通过动静代理的形式产生实现类,实现类中做负载平衡并调用其余服务。
官网地址:https://docs.spring.io/spring...
4、Feign和openFeign有什么区别?
Feign | openFiegn |
---|---|
Feign是SpringCloud组件中一个轻量级RESTful的HTTP服务客户端,Feign内置了Ribbon,用来做客户端负载平衡,去调用服务注册核心的服务。Feign的应用形式是:应用Feign的注解定义接口,调用这个接口,就能够调用服务注册核心的服务 | OpenFeign 是SpringCloud在Feign的根底上反对了SpringMVC的注解,如@RequestMapping等。OpenFeign 的@FeignClient能够解析SpringMVC的@RequestMapping注解下的接口,并通过动静代理的形式产生实现类,实现类中做负载平衡并调用其余服务。 |
5、环境筹备
本篇文章Spring Cloud版本、JDK环境、我的项目环境均和上一篇Nacos的环境雷同:五十五张图通知你微服务的灵魂摆渡者Nacos到底有多强?。
注册核心就不再应用Eureka
了,间接应用Nacos
作为注册和配置核心,有不会的能够查看Nacos文章。
本篇文章搭建的我的项目构造如下图:
注册核心应用Nacos,创立个微服务,别离为服务提供者Produce,服务消费者Consumer。
6、创立服务提供者
既然是微服务之间的互相调用,那么肯定会有服务提供者了,创立openFeign-provider9005
,注册进入Nacos中,配置如下:
server: port: 9005spring: application: ## 指定服务名称,在nacos中的名字 name: openFeign-provider cloud: nacos: discovery: # nacos的服务地址,nacos-server中IP地址:端口号 server-addr: 127.0.0.1:8848management: endpoints: web: exposure: ## yml文件中存在特殊字符,必须用单引号蕴含,否则启动报错 include: '*'
留神:此处的spring.application.name
指定的名称将会在openFeign接口调用中应用。
我的项目源码都会上传,对于如何注册进入Nacos,增加什么依赖源码都会有,联合陈某上篇Nacos文章,这都不是难事!
7、创立服务消费者
新建一个模块openFeign-consumer9006
作为消费者服务,步骤如下。
1、增加依赖
除了Nacos的注册核心的依赖,还要增加openFeign的依赖,如下:
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId></dependency>
2、增加注解@EnableFeignClients开启openFeign性能
老套路了,在Spring boot 主启动类上增加一个注解@EnableFeignClients
,开启openFeign性能,如下:
@SpringBootApplication@EnableDiscoveryClient@EnableFeignClientspublic class OpenFeignConsumer9006Application{ public static void main(String[] args) { SpringApplication.run(OpenFeignConsumer9006Application.class, args); }}
3、新建openFeign接口
新建一个openFeign接口,应用@FeignClient
注解标注,如下:
@FeignClient(value = "openFeign-provider")public interface OpenFeignService {}
留神:该注解@FeignClient
中的value
属性指定了服务提供者在nacos注册核心的服务名。
4、新建一个Controller调试
新建一个controller用来调试接口,间接调用openFeign的接口,如下:
@RestController@RequestMapping("/openfeign")public class OpenFeignController { }
好了,至此一个openFeign的微服务就搭建好了,并未实现具体的性能,上面一点点实现。
8、openFeign如何传参?
开发中接口传参的形式有很多,然而在openFeign中的传参是有肯定规定的,上面具体介绍。
1、传递JSON数据
这个也是接口开发中罕用的传参规定,在Spring Boot 中通过@RequestBody
标识入参。
provider接口中JSON传参办法如下:
@RestController@RequestMapping("/openfeign/provider")public class OpenFeignProviderController { @PostMapping("/order2") public Order createOrder2(@RequestBody Order order){ return order; }}
consumer中openFeign接口中传参代码如下:
@FeignClient(value = "openFeign-provider")public interface OpenFeignService { /** * 参数默认是@RequestBody标注的,这里的@RequestBody能够不填 * 办法名称任意 */ @PostMapping("/openfeign/provider/order2") Order createOrder2(@RequestBody Order order);}
留神:openFeign
默认的传参形式就是JSON传参(@RequestBody
),因而定义接口的时候能够不必@RequestBody
注解标注,不过为了标准,个别都填上。
2、POJO表单传参
这种传参形式也是比拟罕用,参数应用POJO对象接管。
provider服务提供者代码如下:
@RestController@RequestMapping("/openfeign/provider")public class OpenFeignProviderController { @PostMapping("/order1") public Order createOrder1(Order order){ return order; }}
consumer消费者openFeign代码如下:
@FeignClient(value = "openFeign-provider")public interface OpenFeignService { /** * 参数默认是@RequestBody标注的,如果通过POJO表单传参的,应用@SpringQueryMap标注 */ @PostMapping("/openfeign/provider/order1") Order createOrder1(@SpringQueryMap Order order);}
网上很多人纳闷POJO表单形式如何传参,官网文档明确给出了解决方案,如下:
openFeign提供了一个注解@SpringQueryMap
完满解决POJO表单传参。
3、URL中携带参数
此种形式针对restful形式中的GET申请,也是比拟罕用申请形式。
provider服务提供者代码如下:
@RestController@RequestMapping("/openfeign/provider")public class OpenFeignProviderController { @GetMapping("/test/{id}") public String test(@PathVariable("id")Integer id){ return "accept one msg id="+id;}
consumer消费者openFeign接口如下:
@FeignClient(value = "openFeign-provider")public interface OpenFeignService { @GetMapping("/openfeign/provider/test/{id}") String get(@PathVariable("id")Integer id);}
应用注解@PathVariable
接管url中的占位符,这种形式很好了解。
4、一般表单参数
此种形式传参不倡议应用,然而也有很多开发在用。
provider服务提供者代码如下:
@RestController@RequestMapping("/openfeign/provider")public class OpenFeignProviderController { @PostMapping("/test2") public String test2(String id,String name){ return MessageFormat.format("accept on msg id={0},name={1}",id,name); }}
consumer消费者openFeign接口传参如下:
@FeignClient(value = "openFeign-provider")public interface OpenFeignService { /** * 必须要@RequestParam注解标注,且value属性必须填上参数名 * 办法参数名能够任意,然而@RequestParam注解中的value属性必须和provider中的参数名雷同 */ @PostMapping("/openfeign/provider/test2") String test(@RequestParam("id") String arg1,@RequestParam("name") String arg2);}
5、总结
传参的形式有很多,比方文件传参.....陈某这里只是列举了四种常见得传参形式。
9、超时如何解决?
想要了解超时解决,先看一个例子:我将provider服务接口睡眠3秒钟,接口如下:
@PostMapping("/test2")public String test2(String id,String name) throws InterruptedException { Thread.sleep(3000); return MessageFormat.format("accept on msg id={0},name={1}",id,name);}
此时,咱们调用consumer的openFeign接口返回后果如下图:
很显著的看出程序异样了,返回了接口调用超时。what?why?...........
openFeign其实是有默认的超时工夫的,默认别离是连贯超时工夫10秒
、读超时工夫60秒
,源码在feign.Request.Options#Options()
这个办法中,如下图:
那么问题来了:为什么我只设置了睡眠3秒就报超时呢?
其实openFeign集成了Ribbon,Ribbon的默认超时连接时间、读超时工夫都是是1秒,源码在org.springframework.cloud.openfeign.ribbon.FeignLoadBalancer#execute()
办法中,如下图:
源码大抵意思:如果openFeign没有设置对应得超时工夫,那么将会采纳Ribbon的默认超时工夫。
了解了超时设置的原理,由之产生两种计划也是很明了了,如下:
- 设置openFeign的超时工夫
- 设置Ribbon的超时工夫
1、设置Ribbon的超时工夫(不举荐)
设置很简略,在配置文件中增加如下设置:
ribbon: # 值的是建设链接所用的工夫,实用于网络情况失常的状况下, 两端链接所用的工夫 ReadTimeout: 5000 # 指的是建设链接后从服务器读取可用资源所用的工夫 ConectTimeout: 5000
2、设置openFeign的超时工夫(举荐)
openFeign设置超时工夫非常简单,只须要在配置文件中配置,如下:
feign: client: config: ## default 设置的全局超时工夫,指定服务名称能够设置单个服务的超时工夫 default: connectTimeout: 5000 readTimeout: 5000
default设置的是全局超时工夫,对所有的openFeign接口服务都失效
然而失常的业务逻辑中可能波及到多个openFeign接口的调用,如下图:
上图中的伪代码如下:
public T invoke(){ //1. 调用serviceA serviceA(); //2. 调用serviceA serviceB(); //3. 调用serviceA serviceC();}
那么下面配置的全局超时工夫能不能通过呢?很显然是serviceA
、serviceB
可能胜利调用,然而serviceC
并不能胜利执行,必定报超时。
此时咱们能够给serviceC
这个服务独自配置一个超时工夫,配置如下:
feign: client: config: ## default 设置的全局超时工夫,指定服务名称能够设置单个服务的超时工夫 default: connectTimeout: 5000 readTimeout: 5000 ## 为serviceC这个服务独自配置超时工夫 serviceC: connectTimeout: 30000 readTimeout: 30000
留神:单个配置的超时工夫将会笼罩全局配置。
10、如何开启日志加强?
openFeign尽管提供了日志加强性能,然而默认是不显示任何日志的,不过开发者在调试阶段能够本人配置日志的级别。
openFeign的日志级别如下:
- NONE:默认的,不显示任何日志;
- BASIC:仅记录申请办法、URL、响应状态码及执行工夫;
- HEADERS:除了BASIC中定义的信息之外,还有申请和响应的头信息;
- FULL:除了HEADERS中定义的信息之外,还有申请和响应的注释及元数据。
配置起来也很简略,步骤如下:
1、配置类中配置日志级别
须要自定义一个配置类,在其中设置日志级别,如下:
留神:这里的logger是feign包里的。
2、yaml文件中设置接口日志级别
只须要在配置文件中调整指定包或者openFeign的接口日志级别,如下:
logging: level: cn.myjszl.service: debug
这里的cn.myjszl.service
是openFeign接口所在的包名,当然你也能够配置一个特定的openFeign接口。
3、演示成果
上述步骤将日志设置成了FULL
,此时发出请求,日志成果如下图:
日志中具体的打印出了申请头、申请体的内容。
11、如何替换默认的httpclient?
Feign在默认状况下应用的是JDK原生的URLConnection发送HTTP申请,没有连接池,然而对每个地址会放弃一个长连贯,即利用HTTP的persistence connection。
在生产环境中,通常不应用默认的http client,通常有如下两种抉择:
- 应用ApacheHttpClient
- 应用OkHttp
至于哪个更好,其实各有千秋,我比拟偏向于ApacheHttpClient,毕竟老牌子了,稳定性不在话下。
那么如何替换掉呢?其实很简略,上面演示应用ApacheHttpClient替换。
1、增加ApacheHttpClient依赖
在openFeign接口服务的pom文件增加如下依赖:
<!-- 应用Apache HttpClient替换Feign原生httpclient--> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> </dependency> <dependency> <groupId>io.github.openfeign</groupId> <artifactId>feign-httpclient</artifactId> </dependency>
为什么要增加下面的依赖呢?从源码中不难看出,请看org.springframework.cloud.openfeign.FeignAutoConfiguration.HttpClientFeignConfiguration
这个类,代码如下:
上述红色框中的生成条件,其中的@ConditionalOnClass(ApacheHttpClient.class)
,必须要有ApacheHttpClient
这个类才会失效,并且feign.httpclient.enabled
这个配置要设置为true
。
2、配置文件中开启
在配置文件中要配置开启,代码如下:
feign: client: httpclient: # 开启 Http Client enabled: true
3、如何验证曾经替换胜利?
其实很简略,在feign.SynchronousMethodHandler#executeAndDecode()
这个办法中能够分明的看出调用哪个client,如下图:
上图中能够看到最终调用的是ApacheHttpClient
。
4、总结
上述步骤仅仅演示一种替换计划,剩下的一种不再演示了,原理雷同。
12、如何通信优化?
在讲如何优化之前先来看一下GZIP 压缩算法,概念如下:
gzip是一种数据格式,采纳用deflate算法压缩数据;gzip是一种风行的数据压缩算法,利用非常宽泛,尤其是在Linux平台。
当GZIP压缩到一个纯文本数据时,成果是非常明显的,大概能够缩小70%以上的数据大小。
网络数据通过压缩后实际上升高了网络传输的字节数,最显著的益处就是能够放慢网页加载的速度。网页加载速度放慢的益处显而易见,除了节俭流量,改善用户的浏览体验外,另一个潜在的益处是GZIP与搜索引擎的抓取工具有着更好的关系。例如 Google就能够通过间接读取GZIP文件来比一般手工抓取更快地检索网页。
GZIP压缩传输的原理如下图:
依照上图拆解出的步骤如下:
- 客户端向服务器申请头中带有:
Accept-Encoding:gzip,deflate
字段,向服务器示意,客户端反对的压缩格局(gzip或者deflate),如果不发送该音讯头,服务器是不会压缩的。 - 服务端在收到申请之后,如果发现申请头中含有
Accept-Encoding
字段,并且反对该类型的压缩,就对响应报文压缩之后返回给客户端,并且携带Content-Encoding:gzip
音讯头,示意响应报文是依据该格局压缩过的。 - 客户端接管到响应之后,先判断是否有Content-Encoding音讯头,如果有,按该格局解压报文。否则按失常报文解决。
openFeign反对申请/响应开启GZIP压缩,整体的流程如下图:
上图中波及到GZIP传输的只有两块,别离是Application client -> Application Service、 Application Service->Application client。
留神:openFeign反对的GZIP仅仅是在openFeign接口的申请和响应,即是openFeign消费者调用服务提供者的接口。
openFeign开启GZIP步骤也是很简略,只须要在配置文件中开启如下配置:
feign: ## 开启压缩 compression: request: enabled: true ## 开启压缩的阈值,单位字节,默认2048,即是2k,这里为了演示成果设置成10字节 min-request-size: 10 mime-types: text/xml,application/xml,application/json response: enabled: true
上述配置实现之后,发出请求,能够分明看到申请头中曾经携带了GZIP压缩,如下图:
13、如何熔断降级?
常见的熔断降级框架有Hystrix
、Sentinel
,openFeign默认反对的就是Hystrix
,这个在官网文档上就有体现,毕竟是一奶同胞嘛,哈哈...........
然而阿里的Sentinel无论是性能个性、简略易上手等各方面都齐全秒杀Hystrix,因而此章节就应用openFeign+Sentinel进行整合实现服务降级。
阐明:此处并不着重介绍Sentinel,陈某打算放在下一篇文章具体介绍Sentinel的弱小之处。
1、增加Sentinel依赖
在openFeign-consumer9006
消费者的pom文件增加sentinel依赖(因为应用了聚合模块,不指定版本号),如下:
<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId></dependency>
2、配置文件中开启sentinel熔断降级
要想openFeign应用sentinel的降级性能,还须要在配置文件中开启,增加如下配置:
feign: sentinel: enabled: true
3、增加降级回调类
这个类肯定要和openFeign接口实现同一个类,如下图:
OpenFeignFallbackService
这个是降级回调的类,一旦OpenFeignService
中对应得接口呈现了异样则会调用这个类中对应得办法进行降级解决。
4、增加fallback属性
在@FeignClient
中增加fallback
属性,属性值是降级回调的类,如下:
@FeignClient(value = "openFeign-provider",fallback = OpenFeignFallbackService.class)public interface OpenFeignService {}
5、演示
通过如上4个步骤,openFeign的熔断降级曾经设置实现了,此时演示下成果。
通过postman调用http://localhost:9006/openfeign/order3
这个接口,失常逻辑返回如下图:
当初手动造个异样,在服务提供的接口中抛出异样,如下图:
此时从新调用http://localhost:9006/openfeign/order3
,返回如下图:
哦豁,能够很分明的看到服务曾经胜利降级调用,哦了,性能实现。
留神:理论开发中返回后果应该依据架构对立定制,陈某这里只是为了演示不便,不要借鉴,哈哈。。。
14、总结
本篇文章次要面对初学者,深刻的源码以及熔断降级放在前面具体介绍,文中若有表述不清,谬误的中央欢送斧正!
这是陈某Spring Cloud 进阶专栏的第二篇文章,感觉文章不错的,欢送点赞、珍藏、转发。
以上源码曾经上传GitHub,须要的公号【码猿技术专栏】回复关键词9528
获取。