HttpClient实现RPC调用

<projectxmlns="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.provider</groupId>
<artifactId>order-sys</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>war</packaging>
<properties>
<!-- spring 依赖 -->
<spring.version>4.3.18.RELEASE</spring.version>
<jstl.version>1.2</jstl.version>
<servlet-api.version>2.5</servlet-api.version>
<jsp-api.version>2.0</jsp-api.version>
<jackson.version>2.9.0</jackson.version>
user-sys
order-sys</properties>
<dependencies>
<!-- jsp 相关依赖 -->
<!-- servlet 依赖 -->
<!-- jstl 依赖 -->
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>${jstl.version}</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>${servlet-api.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jsp-api</artifactId>
<version>${jsp-api.version}</version>
<scope>provided</scope>
</dependency>
<!-- springmvc 依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>${jackson.version}</version>
</dependency>
</dependencies>
<build>
<finalName>order</finalName>
<plugins>
<!-- 配置 Tomcat 插件 -->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId><version>2.2</version>
<configuration>
<path>/order</path>
<port>7070</port>
</configuration>
</plugin>
</plugins>
</build>
</project> 

package com.bjsxt.domain;
/***
* 订单的实体类
* @author Administrator
*
*/
public class Order {
private String id;
private Double total;
private String date;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public Double getTotal() {
return total;
}
public void setTotal(Double total) {
this.total = total;
}
public String getDate() {
return date;
}
public void setDate(String date) {
this.date = date;
}
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc.xsd">
<!-- 扫描 controller -->
<context:component-scan base-package="com.bjsxt.controller" />
<mvc:annotation-driven></mvc:annotation-driven>
</beans> 

<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.consumer</groupId>
<artifactId>user-sys</artifactId>
<version>0.0.1-SNAPSHOT</version>
<!-- 添加 httpClient 依赖 -->
<dependencies>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<version>4.3.5</version>
<artifactId>httpclient</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId><artifactId>fastjson</artifactId>
<version>1.2.47</version>
</dependency>
</dependencies>
</project> 

package com.bjsxt.domain;
/***
* 订单的实体类
* @author Administrator
*
*/
public class Order {
private String id;
private Double total;
private String date;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public Double getTotal() {
return total;
}
public void setTotal(Double total) {
this.total = total;
}
public String getDate() {
return date;
}
public void setDate(String date) {
this.date = date;
}
}4.3 创建测试类
package com.bjsxt.test.client;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import com.alibaba.fastjson.JSON;
import com.bjsxt.domain.Order;
public class TestHttpClient {
public static void main(String[] args)
throws ClientProtocolException, IOException {
/**
* 启动消费者进行服务的消费
* httpClient 发送远程请求，服务提供响应的为 json，
* json 直接可以解析 java 对象，或者 java 对象的集合
* **/
//创建 NameValuePair 对象,封装发送服务提供者的参数
NameValuePair id=new BasicNameValuePair("uid","2002");
/*NameValuePair uname=new BasicNameValuePair("uname","10001");
NameValuePair address=new BasicNameValuePair("address","10001");
*/
List<NameValuePair> params = new ArrayList<>();
params.add(id);//发送远程的 http 请求的地址
String url="http://localhost:7070/order/loadOrderList02";
//创建 HttpClient 客户端对象
HttpClient client=HttpClients.createDefault();
//创建 HttpPost 对象,发送 post 请求
HttpPost method=new HttpPost(url);
//封装请求体数据
method.setEntity(new UrlEncodedFormEntity(params,"UTF-8"));
//发送具体的 http 请求
HttpResponse response = client.execute(method);
//获得响应头信息
Header[] headers = response.getAllHeaders();
for(Header h:headers){
System.out.println(h.getName()+"-----"+h.getValue());
}
//获得服务提供者响应的具体数据
HttpEntity entity = response.getEntity();
//获得 http 的响应体
InputStream content = entity.getContent();
int len=0;
char[] buf = new char[1024];
//将字节流转化为字符流
InputStreamReader reader=new InputStreamReader(content);
//创建 StringBuffer
StringBuffer result = new StringBuffer();
while((len=reader.read(buf))!=-1){
result.append(String.valueOf(buf,0,len));
}
System.out.println(result);
//将 result，json 字符串解析为 Order 集合
List<Order> list = JSON.parseArray(result.toString(), Order.class);
for(Order o:list){System.out.println(o.getId()+"\t"+o.getDate()+"\t"+o.getTotal());
}
}
}