几种流行Webservice框架

Category 世界杯在线直播
admin

一、 几个比较流行的Webservice框架：

Apache Axis1、Apache Axis2、Codehaus XFire、Apache CXF、Apache Wink、Jboss RESTEasy、sun JAX-WS（最简单、方便）、阿里巴巴 Dubbo（除外）等，采用Java作为测试用例，通过本机和远程两种进行测试方式，对这几种框架进行了性能测试，并对测试结果分析和性能比较，最后并对性能优异的框架进行了推荐。

目前三种主流的web服务实现方法：

REST（新型）：表象化状态转变 (软件架构风格）RESTEasy、Wink、CXF、Axis2…….

SOAP（比较成熟）：简单对象访问协议 Xfire、Axis2、CXF、Axis1

XML-RPC（淘汰）：远程过程调用协议（慢慢被soap 所取代）

REST 简单易用，效率高，貌似未来有很大的发展空间，也有宣称rest性能个方便比soap强大的，已经有很多框架宣称对rest进行支持比如spring 3.0、struts…….. （百度观点）

SOAP 成熟度较高，安全性较好

关键词：Axis1、Axis2、XFire、CXF、Spring、SOAP、StAX、WSDL

二、rest理解

先说REST名称REST -- REpresentational State Transfer首先，之所以晦涩是因为前面主语被去掉了，全称是 Resource Representational State Transfer：

通俗来讲就是：资源在网络中以某种表现形式进行状态转移。分解开来：

Resource：资源，即数据（前面说过网络的核心）。比如 newsfeed，friends等；Representational：某种表现形式，比如用JSON，XML，JPEG等；State Transfer：状态变化。通过HTTP动词实现。REST的出处Roy Fielding的毕业论文。这哥们参与设计HTTP协议，也是Apache Web Server项目（可惜现在已经是 nginx 的天下）的co-founder。PhD的毕业学校是 UC Irvine，Irvine在加州，有着充裕的阳光和美丽的海滩，是著名的富人区。Oculus VR 的总部就坐落于此（虚拟现实眼镜，被FB收购，CTO为Quake和Doom的作者 John Carmack）。众说周知，论文都是晦涩难懂的。当年在CMU读书的时候，很多课程都会安排每周两篇的Paper review。现在回想起来每次写Paper review都是我最为痛苦的时候。REST这篇博士论文毫无疑问更甚。

三、java实现http请求的三种方式

目前JAVA实现HTTP请求的方法用的最多的有两种：一种是通过HTTPClient这种第三方的开源框架去实现。HTTPClient对HTTP的封装性比较不错，通过它基本上能够满足我们大部分的需求，HttpClient3.1 是 org.apache.commons.httpclient下操作远程 url的工具包，虽然已不再更新，但实现工作中使用httpClient3.1的代码还是很多，HttpClient4.5是org.apache.http.client下操作远程 url的工具包，最新的；另一种则是通过HttpURLConnection去实现，HttpURLConnection是JAVA的标准类，是JAVA比较原生的一种实现方式。

如何通过Java发送HTTP请求，通俗点讲，如何通过Java（模拟浏览器）发送HTTP请求。

Java有原生的API可用于发送HTTP请求，即java.net.URL、java.net.URLConnection，这些API很好用、很常用，但不够简便；

所以，也流行有许多Java HTTP请求的framework，如，Apache的HttpClient。

第一种方式：java原生HttpURLConnection

package com.powerX.httpClient;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.HttpURLConnection;

import java.net.MalformedURLException;

import java.net.URL;

public class HttpClient {

public static String doGet(String httpurl) {

HttpURLConnection connection = null;

InputStream is = null;

BufferedReader br = null;

String result = null;// 返回结果字符串

try {

// 创建远程url连接对象

URL url = new URL(httpurl);

// 通过远程url连接对象打开一个连接，强转成httpURLConnection类

connection = (HttpURLConnection) url.openConnection();

// 设置连接方式：get

connection.setRequestMethod("GET");

// 设置连接主机服务器的超时时间：15000毫秒

connection.setConnectTimeout(15000);

// 设置读取远程返回的数据时间：60000毫秒

connection.setReadTimeout(60000);

// 发送请求

connection.connect();

// 通过connection连接，获取输入流

if (connection.getResponseCode() == 200) {

is = connection.getInputStream();

// 封装输入流is，并指定字符集

br = new BufferedReader(new InputStreamReader(is, "UTF-8"));

// 存放数据

StringBuffer sbf = new StringBuffer();

String temp = null;

while ((temp = br.readLine()) != null) {

sbf.append(temp);

sbf.append("\r\n");

}

result = sbf.toString();

}

} catch (MalformedURLException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭资源

if (null != br) {

try {

br.close();

} catch (IOException e) {

e.printStackTrace();

}

}

if (null != is) {

try {

is.close();

} catch (IOException e) {

e.printStackTrace();

}

}

connection.disconnect();// 关闭远程连接

}

return result;

}

public static String doPost(String httpUrl, String param) {

HttpURLConnection connection = null;

InputStream is = null;

OutputStream os = null;

BufferedReader br = null;

String result = null;

try {

URL url = new URL(httpUrl);

// 通过远程url连接对象打开连接

connection = (HttpURLConnection) url.openConnection();

// 设置连接请求方式

connection.setRequestMethod("POST");

// 设置连接主机服务器超时时间：15000毫秒

connection.setConnectTimeout(15000);

// 设置读取主机服务器返回数据超时时间：60000毫秒

connection.setReadTimeout(60000);

// 默认值为：false，当向远程服务器传送数据/写数据时，需要设置为true

connection.setDoOutput(true);

// 默认值为：true，当前向远程服务读取数据时，设置为true，该参数可有可无

connection.setDoInput(true);

// 设置传入参数的格式:请求参数应该是 name1=value1&name2=value2 的形式。

connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");

// 设置鉴权信息：Authorization: Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0

connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");

// 通过连接对象获取一个输出流

os = connection.getOutputStream();

// 通过输出流对象将参数写出去/传输出去,它是通过字节数组写出的

os.write(param.getBytes());

// 通过连接对象获取一个输入流，向远程读取

if (connection.getResponseCode() == 200) {

is = connection.getInputStream();

// 对输入流对象进行包装:charset根据工作项目组的要求来设置

br = new BufferedReader(new InputStreamReader(is, "UTF-8"));

StringBuffer sbf = new StringBuffer();

String temp = null;

// 循环遍历一行一行读取数据

while ((temp = br.readLine()) != null) {

sbf.append(temp);

sbf.append("\r\n");

}

result = sbf.toString();

}

} catch (MalformedURLException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭资源

if (null != br) {

try {

br.close();

} catch (IOException e) {

e.printStackTrace();

}

}

if (null != os) {

try {

os.close();

} catch (IOException e) {

e.printStackTrace();

}

}

if (null != is) {

try {

is.close();

} catch (IOException e) {

e.printStackTrace();

}

}

// 断开与远程地址url的连接

connection.disconnect();

}

return result;

}

}

第二种方式：apache HttpClient3.1

package com.powerX.httpClient;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.UnsupportedEncodingException;

import java.util.Iterator;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Set;

import org.apache.commons.httpclient.DefaultHttpMethodRetryHandler;

import org.apache.commons.httpclient.HttpClient;

import org.apache.commons.httpclient.HttpStatus;

import org.apache.commons.httpclient.NameValuePair;

import org.apache.commons.httpclient.methods.GetMethod;

import org.apache.commons.httpclient.methods.PostMethod;

import org.apache.commons.httpclient.params.HttpMethodParams;

public class HttpClient3 {

public static String doGet(String url) {

// 输入流

InputStream is = null;

BufferedReader br = null;

String result = null;

// 创建httpClient实例

HttpClient httpClient = new HttpClient();

// 设置http连接主机服务超时时间：15000毫秒

// 先获取连接管理器对象，再获取参数对象,再进行参数的赋值

httpClient.getHttpConnectionManager().getParams().setConnectionTimeout(15000);

// 创建一个Get方法实例对象

GetMethod getMethod = new GetMethod(url);

// 设置get请求超时为60000毫秒

getMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT, 60000);

// 设置请求重试机制，默认重试次数：3次，参数设置为true，重试机制可用，false相反

getMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER, new DefaultHttpMethodRetryHandler(3, true));

try {

// 执行Get方法

int statusCode = httpClient.executeMethod(getMethod);

// 判断返回码

if (statusCode != HttpStatus.SC_OK) {

// 如果状态码返回的不是ok,说明失败了,打印错误信息

System.err.println("Method faild: " + getMethod.getStatusLine());

} else {

// 通过getMethod实例，获取远程的一个输入流

is = getMethod.getResponseBodyAsStream();

// 包装输入流

br = new BufferedReader(new InputStreamReader(is, "UTF-8"));

StringBuffer sbf = new StringBuffer();

// 读取封装的输入流

String temp = null;

while ((temp = br.readLine()) != null) {

sbf.append(temp).append("\r\n");

}

result = sbf.toString();

}

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭资源

if (null != br) {

try {

br.close();

} catch (IOException e) {

e.printStackTrace();

}

}

if (null != is) {

try {

is.close();

} catch (IOException e) {

e.printStackTrace();

}

}

// 释放连接

getMethod.releaseConnection();

}

return result;

}

public static String doPost(String url, Map paramMap) {

// 获取输入流

InputStream is = null;

BufferedReader br = null;

String result = null;

// 创建httpClient实例对象

HttpClient httpClient = new HttpClient();

// 设置httpClient连接主机服务器超时时间：15000毫秒

httpClient.getHttpConnectionManager().getParams().setConnectionTimeout(15000);

// 创建post请求方法实例对象

PostMethod postMethod = new PostMethod(url);

// 设置post请求超时时间

postMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT, 60000);

NameValuePair[] nvp = null;

// 判断参数map集合paramMap是否为空

if (null != paramMap && paramMap.size() > 0) {// 不为空

// 创建键值参数对象数组，大小为参数的个数

nvp = new NameValuePair[paramMap.size()];

// 循环遍历参数集合map

Set> entrySet = paramMap.entrySet();

// 获取迭代器

Iterator> iterator = entrySet.iterator();

int index = 0;

while (iterator.hasNext()) {

Entry mapEntry = iterator.next();

// 从mapEntry中获取key和value创建键值对象存放到数组中

try {

nvp[index] = new NameValuePair(mapEntry.getKey(),

new String(mapEntry.getValue().toString().getBytes("UTF-8"), "UTF-8"));

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

}

index++;

}

}

// 判断nvp数组是否为空

if (null != nvp && nvp.length > 0) {

// 将参数存放到requestBody对象中

postMethod.setRequestBody(nvp);

}

// 执行POST方法

try {

int statusCode = httpClient.executeMethod(postMethod);

// 判断是否成功

if (statusCode != HttpStatus.SC_OK) {

System.err.println("Method faild: " + postMethod.getStatusLine());

}

// 获取远程返回的数据

is = postMethod.getResponseBodyAsStream();

// 封装输入流

br = new BufferedReader(new InputStreamReader(is, "UTF-8"));

StringBuffer sbf = new StringBuffer();

String temp = null;

while ((temp = br.readLine()) != null) {

sbf.append(temp).append("\r\n");

}

result = sbf.toString();

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭资源

if (null != br) {

try {

br.close();

} catch (IOException e) {

e.printStackTrace();

}

}

if (null != is) {

try {

is.close();

} catch (IOException e) {

e.printStackTrace();

}

}

// 释放连接

postMethod.releaseConnection();

}

return result;

}

}

第三种方式：apache httpClient4.5

package com.powerX.httpClient;

import java.io.IOException;

import java.io.UnsupportedEncodingException;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Set;

import org.apache.http.HttpEntity;

import org.apache.http.NameValuePair;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.config.RequestConfig;

import org.apache.http.client.entity.UrlEncodedFormEntity;

import org.apache.http.client.methods.CloseableHttpResponse;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClients;

import org.apache.http.message.BasicNameValuePair;

import org.apache.http.util.EntityUtils;

public class HttpClient4 {

public static String doGet(String url) {

CloseableHttpClient httpClient = null;

CloseableHttpResponse response = null;

String result = "";

try {

// 通过址默认配置创建一个httpClient实例

httpClient = HttpClients.createDefault();

// 创建httpGet远程连接实例

HttpGet httpGet = new HttpGet(url);

// 设置请求头信息，鉴权

httpGet.setHeader("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");

// 设置配置请求参数

RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(35000)// 连接主机服务超时时间

.setConnectionRequestTimeout(35000)// 请求超时时间

.setSocketTimeout(60000)// 数据读取超时时间

.build();

// 为httpGet实例设置配置

httpGet.setConfig(requestConfig);

// 执行get请求得到返回对象

response = httpClient.execute(httpGet);

// 通过返回对象获取返回数据

HttpEntity entity = response.getEntity();

// 通过EntityUtils中的toString方法将结果转换为字符串

result = EntityUtils.toString(entity);

} catch (ClientProtocolException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭资源

if (null != response) {

try {

response.close();

} catch (IOException e) {

e.printStackTrace();

}

}

if (null != httpClient) {

try {

httpClient.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

return result;

}

public static String doPost(String url, Map paramMap) {

CloseableHttpClient httpClient = null;

CloseableHttpResponse httpResponse = null;

String result = "";

// 创建httpClient实例

httpClient = HttpClients.createDefault();

// 创建httpPost远程连接实例

HttpPost httpPost = new HttpPost(url);

// 配置请求参数实例

RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(35000)// 设置连接主机服务超时时间

.setConnectionRequestTimeout(35000)// 设置连接请求超时时间

.setSocketTimeout(60000)// 设置读取数据连接超时时间

.build();

// 为httpPost实例设置配置

httpPost.setConfig(requestConfig);

// 设置请求头

httpPost.addHeader("Content-Type", "application/x-www-form-urlencoded");

// 封装post请求参数

if (null != paramMap && paramMap.size() > 0) {

List nvps = new ArrayList();

// 通过map集成entrySet方法获取entity

Set> entrySet = paramMap.entrySet();

// 循环遍历，获取迭代器

Iterator> iterator = entrySet.iterator();

while (iterator.hasNext()) {

Entry mapEntry = iterator.next();

nvps.add(new BasicNameValuePair(mapEntry.getKey(), mapEntry.getValue().toString()));

}

// 为httpPost设置封装好的请求参数

try {

httpPost.setEntity(new UrlEncodedFormEntity(nvps, "UTF-8"));

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

}

}

try {

// httpClient对象执行post请求,并返回响应参数对象

httpResponse = httpClient.execute(httpPost);

// 从响应对象中获取响应内容

HttpEntity entity = httpResponse.getEntity();

result = EntityUtils.toString(entity);

} catch (ClientProtocolException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭资源

if (null != httpResponse) {

try {

httpResponse.close();

} catch (IOException e) {

e.printStackTrace();

}

}

if (null != httpClient) {

try {

httpClient.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

return result;

}

}

参考资料：

http://www.cnblogs.com/firstdream/p/5575928.html

https://www.zhihu.com/question/28557115

https://blog.csdn.net/chenxiaochan/article/details/52988323 (restful接口的两种使用方式)

https://www.cnblogs.com/hhhshct/p/8523697.html（java实现http请求的三种方式）

http://www.cnblogs.com/nick-huang/p/3859353.html（java.net.URLConnection发送http请求）

Copyright © 2088 羽毛球世界杯_世界女排世界杯 - umiloo.com All Rights Reserved.
友情链接