如何使用RestTemplate访问restful服务
@RestController
public class TestController
{
@RequestMapping(value = “testPost“, method = RequestMethod.POST)
public ResponseBean testPost(@RequestBody RequestBean requestBean)
{
ResponseBean responseBean = new ResponseBean();
responseBean.setRetCode(“0000“);
responseBean.setRetMsg(“succ“);
return responseBean;
}
}
使用RestTemplate访问该服务
//请求地址
String url = “http://localhost:8080/testPost“;
//入参
RequestBean requestBean = new RequestBean();
requestBean.setTest1(“1“);
requestBean.setTest2(“2“);
requestBean.setTest3(“3“);
RestTemplate restTemplate = new RestTemplate();
ResponseBean responseBean = restTemplate.postForObject(url, requestBean, ResponseBean.class);
resttemplate转发占用cpu
resttemplate转发占用cpu,可以包含3种:①浏览器和其它应用未关闭所造成的缓冲超负荷,②页面过多.
Spring5之WebClient简单使用
Spring3.0引入了RestTemplate,但是在后来的官方源码中介绍,RestTemplate有可能在未来的版本中被弃用,所谓替代RestTemplate,在Spring5中引入了WebClient作为非阻塞式Reactive Http客户端。
采用阻塞IO模式获取输入数据。每个连接都需要独立的线程,完成数据输入、业务处理、返回。传统阻塞IO模型的问题是,当并发数很大时,就要创建大量线程,占用很大的系统资源。连接创建后,如果当前线程暂时没有数据可读,该线程会阻塞在read操作,造成线程资源浪费。
SpringMVC或Struct等框架都是基于Servlet的,其底层IO模型是阻塞IO模型。Spring社区为了解决SpringMVC的阻塞模型在高并发场景下的性能瓶颈,推出了Spring WebFlux,WebFlux底层实现是久经考验的Netty非阻塞IO通信框架。其实WebClient处理单个HTTP请求的响应时长并不比RestTemplate更快,但是它处理并发的能力更强。 所以响应式非阻塞IO模型的核心意义在于,提高了单位时间内有限资源下的服务请求的并发处理能力,而不是缩短了单个服务请求的响应时长。
uriBuilderFactory:自定义UriBuilderFactory灵活配置使用Url
defaultHeader:为HTTP请求设置Headers请求头
defaultCookie:为HTTP请求设置Cookies
defaultRequest:自定义HttpRequest
filter:为HTTP请求增加客户端过滤器
exchangeStrategies:HTTP读写信息自定义
clientConnector:HTTP客户端连接器设置
使用Mono和Flux接收返回结果,一个Mono对象包含0个或1个元素,而一个Flux对象包含1个或多个元素。
微服务之间相互调用方法
微服务之间相互调用常用到的是
HttpUrlConnection 或者经典的网络访问框架 HttpClient
只是在 Spring 项目中,使用 RestTemplate 显然更方便一些
RestTemplate
RestTemplate 是从 Spring3.0 开始支持的一个 HTTP 请求工具,它提供了常见的REST请求方案的模版,例如 GET 请求、POST 请求、PUT 请求、DELETE 请求以及一些通用的请求执行方法 exchange 以及 execute。RestTemplate 继承自 InterceptingHttpAccessor 并且实现了 RestOperations 接口,其中 RestOperations 接口定义了基本的 RESTful 操作,这些操作在 RestTemplate 中都得到了实现。
用法
第一个参数是 url ,url 中有一个占位符 {1} ,如果有多个占位符分别用 {2} 、 {3} … 去表示,第二个参数是接口返回的数据类型,最后是一个可变长度的参数,用来给占位符填值。
另两种参数格式
方法使用与上述类似,唯一不同之处是: getForObject 的返回值就是服务提供者返回的数据,使用 getForObject 无法获取到响应头。
postForEntity 方法第一个参数是请求地址,第二个参数 map 对象中存放着请求参数 key/value,第三个参数则是返回的数据类型
postForObject 和 postForEntity 基本一致,就是返回类型不同而已,这里不再赘述。
提供方
调用方
提供方
调用方
报文编码格式改为UTF-8
这两天项目需要将报文以xml格式推送给核心,过程中使用到RestTemplate,并且在自己拼接xml时使用了StringBuffer;
StringBuffer的.toString()是不会生成UTF-8格式的String的。
new String(sb.toString().getByte(“你当前的编码方式“),“UTF-8“);
这种方式我没有测试过,因为我无法确定当前的编码方式。
所以我选择的是转换为 byte bytes 后
String str = new String(bytes, “UTF-8“);
在发送的时候,使用了RestTemplate的postForObject(),
而RestTemplate会使用StringHttpMessageConverter,其默认编码集是ISO8859-1;
此时我选择设置Http请求头:
还有方法是在xml配置文件中配置restTempalate的Bean的StringHttpMessageConverter编码;
这里由于项目原因我没法在xml配置文件中直接修改。
我使用的方法不是单例模式的,修改xml配置文件是单例模式的。
resttemplate支持ipv6吗
支持基本的微服务环境搭建,由 provider 提供服务, consumer 通过 DiscoveryClient 先去 eureka 上获取 provider 的服务的地址,获取到地址之后再去调用相关的服务。在服务的调用过程中,使用到了一个工具,叫做 RestTemplate,RestTemplate 是由 Spring 提供的一个 HTTP 请求工具。在上文的案例中,开发者也可以不使用 RestTemplate ,使用 Java 自带的 HttpUrlConnection 或者经典的网络访问框架 HttpClient 也可以完成上文的案例,只是在 Spring 项目中,使用 RestTemplate 显然更方便一些。在传统的项目架构中,因为不涉及到服务之间的调用,大家对 RestTemplate 的使用可能比较少,因此,本文我们就先来带领大家来学习下 RestTemplate 的各种不同用法,只有掌握了这些用法,才能在微服务调用中随心所欲地发送请求。
RestTemplate 简介
RestTemplate 是从 Spring3.0 开始支持的一个 HTTP 请求工具,它提供了常见的REST请求方案的模版,例如 GET 请求、POST 请求、PUT 请求、DELETE 请求以及一些通用的请求执行方法 exchange 以及 execute。RestTemplate 继承自 InterceptingHttpAccessor 并且实现了 RestOperations 接口,其中 RestOperations 接口定义了基本的 RESTful 操作,这些操作在 RestTemplate 中都得到了实现。接下来我们就来看看这些操作方法的使用。
用法实战
在开始下面的案例之前,我们需要先创建一个工程,命名为 RestTemplate 。和上篇文章的项目结构一样,在 RestTemplate 中,我们也分别创建子项目 eureka 、provider 以及 consumer ,将 provider 和 consumer 分别注册到 eureka 上面去。这个具体的步骤大家可以参考上篇文章,本文我就不赘述了,这是我们的准备工作。
GET 请求
做好了准备工作,先来看使用 RestTemplate 发送 GET 请求。在 RestTemplate 中,和 GET 请求相关的方法有如下几个:
图片描述
这里的方法一共有两类,getForEntity 和 getForObject,每一类有三个重载方法,下面我们分别予以介绍。
getForEntity
既然 RestTemplate 发送的是 HTTP 请求,那么在响应的数据中必然也有响应头,如果开发者需要获取响应头的话,那么就需要使用 getForEntity 来发送 HTTP 请求,此时返回的对象是一个 ResponseEntity 的实例。这个实例中包含了响应数据以及响应头。例如,在 provider 中提供一个 HelloController 接口,HelloController 接口中定义一个 sayHello 的方法,如下:
在 consumer 中定义一个 UseHelloController 的类,再定义一个 /hello 接口,在接口中调用 provider 提供的服务,如下:
1
关于 DiscoveryClient 那一段本文先不做讨论,主要来看 getForEntity 方法。第一个参数是 url ,url 中有一个占位符 {1} ,如果有多个占位符分别用 {2} 、 {3} … 去表示,第二个参数是接口返回的数据类型,最后是一个可变长度的参数,用来给占位符填值。在返回的 ResponseEntity 中,可以获取响应头中的信息,其中 getStatusCode 方法用来获取响应状态码, getBody 方法用来获取响应数据, getHeaders 方法用来获取响应头,在浏览器中访问该接口,结果如下:
图片描述
当然,这里参数的传递除了这一种方式之外,还有另外两种方式,也就是 getForEntity 方法的另外两个重载方法。
第一个是占位符不使用数字,而是使用参数的 key,同时将参数放入到一个 map 中。map 中的 key 和占位符的 key 相对应,map 中的 value 就是参数的具体值,例如还是上面的请求,利用 map 来传递参数,请求方式如下:
这种方式传参可能看起来更直观一些。
第二个是使用 Uri 对象,使用 Uri 对象时,参数可以直接拼接在地址中,例如下面这样:
但需要注意的是,这种传参方式,参数如果是中文的话,需要对参数进行编码,使用 URLEncoder.encode 方法来实现。
getForObject
getForObject 方法和 getForEntity 方法类似,getForObject 方法也有三个重载的方法,参数和 getForEntity 一样,因此这里我就不重复介绍参数了,这里主要说下 getForObject 和 getForEntity 的差异,这两个的差异主要体现在返回值的差异上, getForObject 的返回值就是服务提供者返回的数据,使用 getForObject 无法获取到响应头。例如,还是上面的请求,利用 getForObject 来发送 HTTP 请求,结果如下:
注意,这里返回的 s 就是 provider 的返回值,如果开发者只关心 provider 的返回值,并不关系 HTTP 请求的响应头,那么可以使用该方法。
resttemplate远程接口调用,传一个map怎么调用map参数
spring rest mvc使用RestTemplate远程接口调用
主要代码如下:
import java.util.HashMap;
import java.util.Map;
import org.springframework.web.client.RestTemplate;
参数直接放在URL中 String message =restTemplate.getForObjectocalhost:8080/yongbarservice/appstore/appgoods/restTemplate?name=zhaoshijie&id=80“,Str参数使用MAP传递
Map《String ,Object》 urlVariables = new HashMap《String,Object》();
urlVariables.put(“name“, “zhaoshijie“);
urlVariables.put(“id“, 80);
String message2restTemplate.getForObject
delete方法没有返回值,说明,id=0这个参数在服务器端可以不定义该参数,直接使用request获取
restTemplate.putyongbarservice/appstore/appgoods/restTemplate?name=zhaoshijie&id=80“,null);
System.out.println(message);
System.out.println(message2);
System.out.println(message3); }
如何使用RestTemplate访问restful服务
一. 什么是RestTemplate
传统情况下在Java代码里访问restful服务,一般使用Apache的HttpClient。不过此种方法使用起来太过繁琐。spring提供了一种简单便捷的模板类来进行操作,这就是RestTempla其实RestTemplate的功能非常强大
spring 5 webclient使用指南
之前写了一篇restTemplate使用实例,由于spring 5全面引入reactive,同时也有了restTemplate的reactive版webclient,本文就来对应展示下webclient的基本使用。
webclient是新一代的async rest template,api也相对简洁,而且是reactive的,非常值得使用。
Spring Cloud客户端负载均衡 – Ribbon
注册restTemplate
使用restTemplate发送GET请求
通过@LoadBalanced注解可知该注解用来给restTemplate做标记,使用客户端负载均衡进行配置,搜索LoadBalancerClient类
ServiceInstanceChooser用来根据serviceId进行选择服务
通过以上得知,客户端负载均衡器应具备的几种能力
LoadBalancerAutoConfiguration为实现客户端负载均衡器的自动化配置类
该配置类需要满足两个条件
在示例中没有retryTemplate,则会创建一个LoadBalancerInterceptor对象
在LoadBalancerInterceptor的构造方法中注入了LoadBalancerClient的实现
当一个被@LoadBalance标注的RestTemplate向外发送Http请求时,会被interceptor拦截,调用execute发起实际请求
LoadBalancerClient的具体实现为org.springframework.cloud.netflix.ribbon.RibbonLoadBalancerClient
execute方法
首先根据传入的serviceId获取具体的服务实例
根据getServer接口,可知并没有使用choose函数,而是使用了ribbon本身的chooseServer函数
在ribbonClientConfiguration中可知默认采用了ZoneAwareLoadBalancer实现负载均衡器
回到RibbonBalancerClient的execute函数
通过ZoneAwareLoadBalancer的chooseServer获取负载均衡策略分配到的服务实例后,将其包装成RibbonServer对象,RibbonServer对象除了包含服务实例对象外,还包含serviceId等信息,然后使用该对象回调LoadBalancerInteceptor请求拦截器中LoadBalancerRequest的apply函数,向一个实际的具体服务发起请求
ServiceInstance对象是对服务的抽象定义,包含了每个服务实例需要提供一些基础信息
而RibbonServer就是ServiceInsta
DiscoveryEnabledNIWSServerList从eureka中拿到server列表后,继续通过DomainExtractingServerList的setZone进行处理,加入了一些必要属性
更新服务待续,没看明白
ZoneAwareLoadBalancer继承自DynamicServerListLoadBalancer并重写了setServerListForZones
个性化配置