问题:
使用原生的HttpClient实现RPC远程调用时,如果是Post请求请求实体数据的代码编写比较麻烦,而且请求响应数据的获取也比较麻烦。还需要我们自己将Json字符串数据转换为JavaBean对象。所以,使用原生的HttpClient实现PRC,代码编写过于麻烦。
解决:
将HttpCilent的执行流程进行封装,对外暴露关键参数的传递。返回值直接就是JavaBean
实现:
Spring的restTemplate类。
使用:
1.添加Spring的相关依赖(webmvc.jar)
2.配置restTemplate的bean
3.使用restTemplate的实例化对象完成rpc远程调用。
4.Post方式
5.Get方式
一.pom.xml文件
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.bjsxt.rpc</groupId>
<artifactId>06-restTemplate</artifactId>
<version>0.0.1-SNAPSHOT</version>
<dependencies>
<!--导入SpringMVC的依赖 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>4.3.18.RELEASE</version>
</dependency>
<!--导入json依赖 -->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.0</version>
</dependency>
</dependencies>
</project>
二.spring配置文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
"
default-autowire="byName"
>
<!--配置RestTemplate的bean -->
<bean id="restTemplate" class="org.springframework.web.client.RestTemplate"></bean>
</beans>
三.实现流程
RestTemplate实现RPC的流程
1、需要配置WebMVC的依赖和Json的依赖
2、在applicationcontext.xml文件中配置RestTemplate的bean
3、使用RestTemplate对象完成RPC远程调用
Post方式:
1.postForObject方式
使用:RestTemplate对象.postForObject(String url, Object request, Class type);
参数:
- url:此次请求的地址
- request:此次的请求参数
- type:此次请求的响应的josn字符串需要被转换的javabean的Class对象
如果请求参数中需要body和headers两份请求数据,则需要创建HttpEntity对象来封装请求数据。
如果请求参数中只用body数据,则直接将存储了请求实体数据的LinkedMultiValueMap传给request即可。
如果响应的是一个实体类的对象,则type值为该实体类的Class对象。
如果响应的是实体类的List集合,则type的值为该实体类的数组的Class对象。
示例:
rest.postForObject(url, map, Pet.class);
示例:
rest.postForObject(url, map, Pet[].class);
返回值:返回的是响应的josn字符串转换后的javaBean对象。
2.postForEntity方式
使用:RestTemplate对象.postForEntity(String url, Object request, Class type);
参数:
- url:此次请求的地址
- request:此次的请求参数
- type:此次请求的响应的josn字符串需要被转换的javabean的Class对象
如果请求参数中需要body和headers两份请求数据,则需要创建HttpEntity对象来封装请求数据。
如果请求参数中只用body数据,则直接将存储了请求实体数据的LinkedMultiValueMap传给request即可。
如果响应的是一个实体类的对象,则type值为该实体类的Class对象。
如果响应的是实体类的List集合,则type的值为该实体类的数组的Class对象。
示例:
rest.postForObject(url, map, Pet.class);
示例:
rest.postForObject(url, map, Pet[].class);
返回值:ResponseEntity
返回的是存储了响应行,头,体的对象。
Get方式
1.getForEntity(String url,Class Type)
参数:
- url:请求地址
- type:响应数据需要转的JavaBean的Class
- 返回值:ResponseEntity
- 返回的是存储了响应行,头,体的对象。
2.getForObject(String url,Class Type)
参数:
- url:请求地址
- type:响应数据需要转的JavaBean的Class
- 返回值:返回的是响应的josn字符串转换后的javaBean对象。
注意:
请求实体参数直接拼接在URL中即可,示例:
String urlGet="http://localhost:7070/server/pet2?pname=张三&color=red";
四.服务消费方代码
package com.bjsxt.test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.http.HttpEntity;
import org.springframework.http.ResponseEntity;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.web.client.RestTemplate;
import com.bjsxt.pojo.Pet;
public class TestTemplate {
public static void main(String[] args) {
//获取Spring容器对象
ApplicationContext ac=new ClassPathXmlApplicationContext("applicationcontext.xml");
//获取restTemplate对象
RestTemplate rest=(RestTemplate) ac.getBean("restTemplate");
//创建请求地址
String urlPost="http://localhost:7070/server/pet2";
String urlGet="http://localhost:7070/server/pet2?pname=张三&color=red";
//创建Map集合存储请求数据
LinkedMultiValueMap<String,Object> map=new LinkedMultiValueMap<>();
map.add("pname", "小黑");
map.add("color", "白色");
//post请求方式
//post请求方式一 postForObject
//创建对象封装请求数据
//HttpEntity<LinkedMultiValueMap<String, Object>> he=new HttpEntity<>(map);
//发送请求
/*Pet[] postForObject = rest.postForObject(urlPost, map, Pet[].class);
System.out.println(postForObject[0]);*/
//post请求方式二postForEntity
//ResponseEntity<Pet[]> postForEntity = rest.postForEntity(urlPost, map, Pet[].class);
//获取响应实体
/*Pet[] body = postForEntity.getBody();
System.out.println(body[0]);*/
//获取响应状态码
/*int code = postForEntity.getStatusCodeValue();
System.out.println(code);*/
//get请求方式
ResponseEntity<Pet[]> forEntity = rest.getForEntity(urlGet, Pet[].class);
//获取响应体
Pet[] body = forEntity.getBody();
System.out.println(body[0]);
}
}