如何在springboot中使用feign实现跨服务调用-mile米乐体育

这篇文章给大家介绍如何在springboot中使用feign实现跨服务调用，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

springboot整合feign

引入依赖, 这里注意, spring-cloud.version记得要和spring-boot版本匹配, 我这里spring-boot版本是2.1.3, 所以spring-cloud选择greenwich.sr2版本.

大致的版本对应关系如下

更详细的请去https://start.spring.io/actuator/info查询!

 greenwich.sr2       org.springframework.cloud spring-cloud-dependencies ${spring-cloud.version} pom import        org.springframework.cloud spring-cloud-starter-openfeign    io.github.openfeign feign-httpclient  

然后我们去项目的启动类上加上注解@enablefeignclients

最后, 加上feign的配置application.properties

server.port=9999 #******************openfeign配置，参数采用的是默认的配置，可根据实际情况调整*********************** #启用apachehttpclient。默认就是true，使用httpclientconnectionmanager管理连接复用 feign.httpclient.enabled=true #连接池的最大连接数，默认200 feign.httpclient.max-connections=200 #每个路由(服务器)分配的组最大连接数，默认50 feign.httpclient.max-connections-per-route=50 #连接最大存活时间，默认900秒 feign.httpclient.time-to-live=900 #连接最大存活时间单位秒 feign.httpclient.time-to-live-unit=seconds #feignacceptgzipencodinginterceptor拦截器被激活，会在header中添加accept-encoding：gzip,deflate,表明服务端在返回值时可以使用如下两个方式压缩返回结果 feign.compression.response.enabled=true #feigncontentgzipencodinginterceptor拦截器被激活，会在header中添加content-encoding：gzip,deflate,表明body中的参数是使用这两个方式的压缩 feign.compression.request.enabled=true #content-length大于2048就进行请求参数的gzip压缩 feign.compression.request.minrequestsize=2048  #开启断路器 feign.hystrix.enabled=true #断路器的隔离策略，默认就是线程池，semaphore模式下，就是主线程调用的远程的服务，即同步的 hystrix.command.default.execution.isolation.strategy=thread #断路器超时设置 hystrix.command.default.execution.timeout.enabled=true #总体请求在45秒还是无法得到响应，建议触发熔断（ribbon每个请求读取15秒超时，两个实例重试就是30秒，openfeign外层默认会进行一次调用，4次重试） hystrix.command.default.execution.isolation.thread.timeoutinmilliseconds=45000 #断路器的线程池存在一个问题，在队列满了以后，不会再去创建新的线程直到maximumsize #核心线程池大小 hystrix.threadpool.default.coresize=10 #最大线程池大小 hystrix.threadpool.default.maximumsize=10 #超过这个空闲时间,多于coresize数量的线程会被回收，1分钟 hystrix.threadpool.default.keepalivetimeminutes=1 #队列的大小，默认为-1，即没有队列 hystrix.threadpool.default.maxqueuesize=200 #队列任务达到此阈值后，就开始拒绝；实际使用此参数进行队列是否满的判断 hystrix.threadpool.default.queuesizerejectionthreshold=180  #负载均衡配置 #读取超时15秒，与原resttemplate保持一致 ribbon.readtimeout=15000 #连接超时15秒，与原resttemplate保持一致 ribbon.connecttimeout=15000 ##每台服务器最多重试次数，但是首次调用不包括在内 ribbon.maxautoretries=0 ##最多重试多少台服务器，与实际实例数保持一致（不包括首台） ribbon.maxautoretriesnextserver=1 #是否所有操作都重试, #false：get请求中，连接超时，读取超时都会重试，其他请求(put,post)连接超时重试，读取超时不重试。 #true：get请求中，连接超时，读取超时都会重试，其他请求(put,post)连接超时重试，读取超时重试。 #对于请求(put,post)要做好接口的幂等性 ribbon.oktoretryonalloperations=true

spring-boot整合feign完成, 接下来我们编写测试代码

测试代码

两个服务

• sb-alibaba-nacos (被调用方服务, 127.0.0.1:8081), 提供 getinfobyid接口

• sb-feign (调用方服务, 127.0.0.1:9999), 提供 getinfobyid 测试接口

sb-alibaba-nacos提供的测试接口

@getmapping(value="getinfobyid") publicstringgetinfobyid(@requestparam(value="id")longid){ return"example-servicereturn:" id; }

sb-feign相关代码

我们新建个包 feign,用来放所有涉及跨服务调用的类

examplecontrollerfeignclient.java:

packagecom.mrcoder.sbfeign.feign;  importfeign.hystrix.fallbackfactory; importorg.slf4j.logger; importorg.slf4j.loggerfactory; importorg.springframework.cloud.openfeign.feignclient; importorg.springframework.stereotype.component; importorg.springframework.web.bind.annotation.getmapping; importorg.springframework.web.bind.annotation.requestparam;  @feignclient(name="sb-alibaba-nacos",url="http://127.0.0.1:8081/",fallbackfactory=examplecontrollerfeignclient.examplecontrollerfeignclientfallbackfactory.class) publicinterfaceexamplecontrollerfeignclient{  @getmapping(value="getinfobyid") stringgetinfobyid(@requestparam(value="id")longid);  /** *服务降级内部类 */ @component classexamplecontrollerfeignclientfallbackfactoryimplementsfallbackfactory{  privateloggerlogger=loggerfactory.getlogger(examplecontrollerfeignclientfallbackfactory.class);  @override publicexamplecontrollerfeignclientcreate(throwablecause){ returnnewexamplecontrollerfeignclient(){ @override publicstringgetinfobyid(longsigninglogid){ logger.error("跨服务调用失败，原因是:" cause.getmessage()); return"失败，原因是:" cause.getmessage(); } }; } } }

关键代码就是

@feignclient(name="sb-alibaba-nacos",url="http://127.0.0.1:8081/",fallbackfactory=examplecontrollerfeignclient.examplecontrollerfeignclientfallbackfactory.class)

• name 就是被调用方的服务名称 (这里如果你没有配置服务注册中心的化,其实可以随便写)

• url 就是被调用方的地址(如果配置了服务注册中心, 可以不写!, 不过两个服务必须都注册!,这样才能找到!)

• fallbackfactory 就是调用失败时指定的处理类

最后, 我们写个测试方法

packagecom.mrcoder.sbfeign.controller;  importcom.mrcoder.sbfeign.feign.examplecontrollerfeignclient; importorg.springframework.beans.factory.annotation.autowired; importorg.springframework.web.bind.annotation.*;  @crossorigin @restcontroller publicclasstestcontroller{  @autowired privateexamplecontrollerfeignclientexamplecontrollerfeignclient;  @requestmapping(value="getinfobyid",method=requestmethod.get) publicstringtest(@requestparam(value="id")longid){ returnexamplecontrollerfeignclient.getinfobyid(id); } }

开启两个服务sb-alibaba-nacos, sb-feign

而后访问sb-feign的测试方法

http://localhost:9999/getinfobyid?id=22

出现

sb-alibaba-nacos return :22

关于如何在springboot中使用feign实现跨服务调用就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。