微服务请求第三方服务实现

系统业务免不了与第三方公司进行交互，需要远程调用，RestTemplate到底是什么玩意？

RestTemplate是Spring提供的用于访问Rest服务的客户端工具，它提供了多种便捷访问远程Http服务的方法，能够大大提高客户端的编写效率。
弱弱呼吁一句：对于那些在Spring环境下还在使用HttpClient（或其它Client）的同学，今儿看完本文后，建议切换到RestTemplate （有特殊需求的当然除外喽~）。

RestTemplate简化了与http服务的通信，程序代码可以给它提供URL，并提取结果。它默认使用的JDK 的HttpURLConnection进行通信，然而我们是可以通过RestTemplate.setRequestFactory切换到不同的HTTP源：如Apache HttpComponents、Netty、OkHttp等等。

关于响应：

xxxForObject：返回响应体（也就直接是body体力的内容） （T）
xxxForEntity：返回的相应行、响应头、响应码、响应体等等 （ResponseEntity<T>）
xxxForLocation：提交成功之后，返回新资源的URI。这个只需要服务提供者返回一个 URI 即可，该 URI 表示新资源的位置，可谓非常轻量。 （URI）

注意：使用字符串类型的url默认会对url进行转义，如http://example.com/hotel list在执行时会转义为http://example.com/hotel%20list，隐式的转义这样是没有问题的。但如果你自己已经转义过了，那就不ok了。
若不想要这种隐式的转义，建议使用URI（URI uri = uriComponents.toUri()）来构造。

请求方式、载体、编码等都需要注意

public class RestTemplateUtil {private static final Logger LOGGER = LoggerFactory.getLogger(RestTemplateUtil.class);/*** RestTemplate 工具方法* @param url* @param object* @return*/public static String postRestTemplate(String url, Map<String,Object> object){SimpleClientHttpRequestFactory httpRequestFactory = new SimpleClientHttpRequestFactory();httpRequestFactory.setReadTimeout(35000);httpRequestFactory.setConnectTimeout(5000);List<HttpMessageConverter<?>> messageConverters = new ArrayList<HttpMessageConverter<?>>();FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();List<MediaType> supportedMediaTypes = new ArrayList<>();supportedMediaTypes.add(MediaType.APPLICATION_JSON);supportedMediaTypes.add(MediaType.APPLICATION_JSON_UTF8);supportedMediaTypes.add(MediaType.APPLICATION_ATOM_XML);supportedMediaTypes.add(MediaType.APPLICATION_FORM_URLENCODED);supportedMediaTypes.add(MediaType.APPLICATION_OCTET_STREAM);supportedMediaTypes.add(MediaType.APPLICATION_PDF);supportedMediaTypes.add(MediaType.APPLICATION_RSS_XML);supportedMediaTypes.add(MediaType.APPLICATION_XHTML_XML);supportedMediaTypes.add(MediaType.APPLICATION_XML);supportedMediaTypes.add(MediaType.IMAGE_GIF);supportedMediaTypes.add(MediaType.IMAGE_JPEG);supportedMediaTypes.add(MediaType.IMAGE_PNG);supportedMediaTypes.add(MediaType.TEXT_EVENT_STREAM);supportedMediaTypes.add(MediaType.TEXT_HTML);supportedMediaTypes.add(MediaType.TEXT_MARKDOWN);supportedMediaTypes.add(MediaType.TEXT_PLAIN);supportedMediaTypes.add(MediaType.TEXT_XML);fastConverter.setSupportedMediaTypes(supportedMediaTypes);FastJsonConfig fastJsonConfig = new FastJsonConfig();fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat);fastConverter.setFastJsonConfig(fastJsonConfig);messageConverters.add(fastConverter);RestTemplate restTemplate = new RestTemplate(httpRequestFactory);restTemplate.setMessageConverters(messageConverters);LOGGER.info("请求地址"+url);LOGGER.info("入参"+ JSON.toJSONString(object));String s = restTemplate.postForObject(url, object, String.class);LOGGER.info(url+"出参" + s);return s;}/*** RestTemplate 工具方法* @param url* @param object* @return*/public static String postRestTemplate(String url, Map<String,Object> object,Map<String, String> headers){RestTemplate restTemplate = getRestTemplate();HttpHeaders httpHeaders = new HttpHeaders();if (Objects.nonNull(headers)) {headers.forEach((key, value) -> {httpHeaders.add(key, value);});}HttpEntity<Map<String, Object>> httpEntity = new HttpEntity<Map<String, Object>>(object, httpHeaders);LOGGER.info("请求地址"+url+"Header"+JSON.toJSONString(object));LOGGER.info("请求地址"+url);LOGGER.info("入参"+ JSON.toJSONString(httpEntity));String s = restTemplate.postForObject(url, httpEntity,  String.class);LOGGER.info("出参" + s);return s;}/*** RestTemplate 工具方法* @param url* @param object* @return*/public static String postRestTemplate(String url, Map<String,Object> object,Map<String, String> headers,SmpSendLogBO reqBO ){RestTemplate restTemplate = getRestTemplate();HttpHeaders httpHeaders = new HttpHeaders();if (Objects.nonNull(headers)) {headers.forEach((key, value) -> {httpHeaders.add(key, value);});}HttpEntity<Map<String, Object>> httpEntity = new HttpEntity<Map<String, Object>>(object, httpHeaders);LOGGER.info("请求地址"+url+"     Header"+JSON.toJSONString(object));reqBO.setSendData( new Gson().toJson(httpEntity));LOGGER.info("入参"+ new Gson().toJson(httpEntity));String s = restTemplate.postForObject(url, httpEntity,  String.class);reqBO.setReceiveData(s);LOGGER.info("出参" + s);return s;}public static RestTemplate  getRestTemplate() {SimpleClientHttpRequestFactory httpRequestFactory = new SimpleClientHttpRequestFactory();httpRequestFactory.setReadTimeout(35000);httpRequestFactory.setConnectTimeout(10000);List<HttpMessageConverter<?>> messageConverters = new ArrayList<HttpMessageConverter<?>>();FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();List<MediaType> supportedMediaTypes = new ArrayList<>();supportedMediaTypes.add(MediaType.APPLICATION_JSON);supportedMediaTypes.add(MediaType.APPLICATION_JSON_UTF8);supportedMediaTypes.add(MediaType.APPLICATION_ATOM_XML);supportedMediaTypes.add(MediaType.APPLICATION_FORM_URLENCODED);supportedMediaTypes.add(MediaType.APPLICATION_OCTET_STREAM);supportedMediaTypes.add(MediaType.APPLICATION_PDF);supportedMediaTypes.add(MediaType.APPLICATION_RSS_XML);supportedMediaTypes.add(MediaType.APPLICATION_XHTML_XML);supportedMediaTypes.add(MediaType.APPLICATION_XML);supportedMediaTypes.add(MediaType.IMAGE_GIF);supportedMediaTypes.add(MediaType.IMAGE_JPEG);supportedMediaTypes.add(MediaType.IMAGE_PNG);supportedMediaTypes.add(MediaType.TEXT_EVENT_STREAM);supportedMediaTypes.add(MediaType.TEXT_HTML);supportedMediaTypes.add(MediaType.TEXT_MARKDOWN);supportedMediaTypes.add(MediaType.TEXT_PLAIN);supportedMediaTypes.add(MediaType.TEXT_XML);fastConverter.setSupportedMediaTypes(supportedMediaTypes);FastJsonConfig fastJsonConfig = new FastJsonConfig();fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat);fastConverter.setFastJsonConfig(fastJsonConfig);messageConverters.add(fastConverter);RestTemplate restTemplate = new RestTemplate(httpRequestFactory);restTemplate.setMessageConverters(messageConverters);return restTemplate;}
}

深入理解RestTemplatehttps://segmentfault.com/a/1190000020405004

微服务请求第三方服务实现相关推荐

PhalAPI学习笔记 ——— 第二章接口服务请求
PhalAPI学习笔记 --- 第二章接口服务请求前言接口服务请求接口服务请求案例自定义接口路由开启匹配路由配置路由规则 nginx apache 服务请求结束语前言公司业务需要转学 ...
.net中调用esb_大型ESB服务总线平台服务运行分析和监控预警实践
今天准备谈下ESB总线平台建设项目中的服务运行统计分析,服务心跳监测,服务监控预警方面的设计和实现.可以看到,在一个ESB服务总线平台上线后,SOA治理管控就变得相当重要,而这些运行监控分析本身也是提 ...
微服务请求驱动和事件驱动_如何驯服事件驱动的微服务
微服务请求驱动和事件驱动现代微服务体系结构是事件驱动的,响应式的和编排的(与通过协调器进行集中控制相反). 这使得它们松散耦合并且易于更改. 对? TL; DR:不太容易! 您将在理解和管理事件流 ...
打通版微社区（4）：微信第三方服务部署——JSP的IIS部署
写在前面: 本机环境2008R2.tomcat8 网上搜了很多JSP的IIS部署,内容大部分是相近的,这些文章最早出现在2012的样子.大概的原理就是通过ISAPI方式对IIS进行扩展(这个扩展是to ...
Spring Cloud构建微服务架构：服务容错保护（Hystrix服务降级）【Dalston版】
前言在微服务架构中,我们将系统拆分成了一个个的服务单元,各单元应用间通过服务注册与订阅的方式互相依赖.由于每个单元都在不同的进程中运行,依赖通过远程调用的方式执行,这样就有可能因为网络原因或是依赖服 ...
SpringCloud 微服务 (十五) 服务容错 Hystrix
2019独角兽企业重金招聘Python工程师标准>>> 壹工作中的微服务架构,某个服务通常会被多个服务调用或者多层调用完成需求,如果某个服务不可用,导致一个系统功能不可用或者服务直 ...
微服务架构的优缺点_微服务架构DNS服务注册与发现实现原理
微服务架构已经成为中小型企业必备的项目支撑能力,尤其互联网BATJ企业在04年已经非常成熟,在大规模的核心业务实战中总结了很多大规模服务调度与大数据集的处理方案.微服务架构中涉及到很多模块,本文以微服 ...
Spring Cloud构建微服务架构：服务容错保护（Hystrix服务降级）【Dalston版】 1
前言在微服务架构中,我们将系统拆分成了一个个的服务单元,各单元应用间通过服务注册与订阅的方式互相依赖.由于每个单元都在不同的进程中运行,依赖通过远程调用的方式执行,这样就有可能因为网络原因或是依赖服 ...
微服务架构的服务与发现-Spring Cloud
https://www.jianshu.com/p/5eac16e9804a 作者:谦小易链接:https://www.jianshu.com/p/5eac16e9804a 来源:简书简书著作权归 ...

微服务请求第三方服务实现

微服务请求第三方服务实现相关推荐

最新文章

热门文章