您好,登录后才能下订单哦!
本篇内容主要讲解“Java使用OpenFeign管理多个第三方服务的方法”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Java使用OpenFeign管理多个第三方服务的方法”吧!
背景
应用
maven依赖
配置和服务声明
服务地址配置
第三方服务配置
接口声明和使用
小结
最近开发了一个统一调度类的项目,需要依赖多个第三方服务,这些服务都提供了HTTP接口供我调用。
组件架构
服务多、接口多,如何进行第三方服务管理和调用就成了问题。
常用的服务间调用往往采用zk、Eureka等注册中心进行服务管理(SpringBoot常使用SpringCloud)。OpenFeign也是SpringCloud的解决方案之一。我们单独使用OpenFeign, 无需对原有第三方服务进行改动,本服务开发时的引入也很轻量。
下面给出我的用法。
引入maven依赖:
<dependency> <groupId>io.github.openfeign</groupId> <artifactId>feign-core</artifactId> <version>10.2.3</version> </dependency> <dependency> <groupId>io.github.openfeign</groupId> <artifactId>feign-gson</artifactId> <version>10.2.3</version> </dependency> <dependency> <groupId>io.github.openfeign.form</groupId> <artifactId>feign-form</artifactId> <version>3.8.0</version> </dependency> <dependency> <groupId>io.github.openfeign.form</groupId> <artifactId>feign-form-spring</artifactId> <version>3.8.0</version> </dependency>
其中,form相关引入是为了解决ContentType为application/x-www-form-urlencoded和multipart/form-data的编码问题。
第三方服务的地址通过配置来注入。
ThirdpartServiceConfig.java
@Data @Component @ConfigurationProperties(prefix = "thirdpart-service") public class ThirdpartServiceConfig { private String serviceA; private String serviceB; private String serviceC; }
服务配置(超时时间配置等也可以写在这里) application.yaml
thirdpart-service: serviceA: http://****:***/ serviceB: http://****:***/ serviceC: http://****:***/
因为声明方法一致,所以省略了多个第三方声明。 ThirdPartClientConfig.java
@Configuration public class ThirdParttClientConfig { @Resource private ThirdpartServiceConfig thirdpartServiceConfig; @Bean public ServiceAClient serviceAClient() { return Feign.builder() .encoder(new FormEncoder(new GsonEncoder())) .decoder(new GsonDecoder()) .target(ServiceAClient.class, thirdpartServiceConfig.getServiceA()); } }
完成了服务的声明和服务的配置之后,就可以进行服务接口的声明了。具体声明方法可以参看OpenFeign文档:# 翻译: Spring Cloud Feign使用文档
下面给出使用示例:
GET请求(feign可直接将返回的结果反序列化为本服务中定义的POJO)
@RequestLine("GET testGet?a={a}&b={b}") ServiceResp testGet(@Param("a") String a,@Param("b")String b);
GET 下载使用feign.Response接收请求结果
@RequestLine("GET export?exportId={exportId}") Response exportFromServiceA(@Param("exportId")String exportId);
@Resource private ServiceAClient serviceAClient ; // 导出方法 public void export(exportId) { Response serviceResponse = serviceserviceAClient.exportFromServiceA(exportId); Response.Body body = serviceResponse.body(); try(InputStream inputStream = body.asInputStream(); // 处理获取到的inputStream } catch (IOException e) { log.error("导出发生异常",e); }
POST application/json"
@RequestLine("POST /save") @Headers("Cofntent-Type: application/json") ServiceResp saveEntity(EntityPOJO entityPOJO);
POST form
@RequestLine("POST uqa/repo/qa/batch") @Headers("Content-Type:multipart/form-data") ServiceResp uploadFile(@Param("id")String id, @Param("batch_file") File file);
注意:除了file类型,其他参数会被序列化为String,所以若第三方接口参数的值为POJO(或Map),可能会出错。
对于POJO参数,若第三方参数名含有Java中不合法的属性字符(如 ”-“,”#“,”.“等),可使用注解进行序列化时的转化。由于声明Feign Client时使用的encoder是Gson,所以使用如下注解:
@SerializedName(value="aaa-bbb") private String aaaBbb;
如果使用的是其他序列化工具,改为对应的注解即可。
使用声明式的第三方和接口写法,基本覆盖了请求第三方接口的需求,也易于拓展和管理。
我计划在后续添加统一的鉴权、日志打印和异常捕获处理功能,使依赖组件引入的风险更为可控。OpenFeign帮我们实现了服务声明、接口声明、HTTP请求发送和结果处理等逻辑,在项目需要调用多个第三方服务时可以使用。
到此,相信大家对“Java使用OpenFeign管理多个第三方服务的方法”有了更深的了解,不妨来实际操作一番吧!这里是亿速云网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。