使用Java原生API编写发送HTTP_POST请求的工具类
2017-08-11 14:21
295 查看
package com.jadyer.util;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 使用Java原生API编写发送HTTP_POST请求的工具类
* @see ------------------------------------------------------------------------------------------
* @see 与之类似的还有一个HttpClientUtil工具类
* @see 地址为http://blog.csdn.net/jadyer/article/details/8087960
* @see ------------------------------------------------------------------------------------------
* @see 本方法的美中不足是:服务器返回500时,它会直接抛出类似下面的异常
* @see java.io.IOException: Server returned HTTP response code: 500 for URL: http://xxxx/xxxx
* @see 原因很简单:因为这里用到的是SUN提供的基于HTTP协议的框架实现
* @see ------------------------------------------------------------------------------------------
* @see 个人更推荐使用Socket发送HTTP请求
* @see 例子见http://blog.csdn.net/jadyer/article/details/8788272
* @see ------------------------------------------------------------------------------------------
* @create Mar 4, 2013 2:47:57 PM
* @editor Apr 4, 2013 10:02:18 AM
* @author 玄玉<http://blog.csdn.net/jadyer>
*/
public class NativeHTTPUtil {
private NativeHTTPUtil(){}
/**
* 发送HTTP_POST请求
* @see 本方法默认的连接和读取超时均为30秒
* @see 请求参数含有中文时,亦可直接传入本方法中,本方法内部会自动根据reqCharset参数进行<code>URLEncoder.encode()</code>
* @see 解码响应正文时,默认取响应头[Content-Type=text/html; charset=GBK]字符集,若无Content-Type,则使用UTF-8解码
* @param reqURL 请求地址
* @param reqParams 请求正文数据
* @param reqCharset 请求报文的编码字符集(主要针对请求参数值含中文而言)
* @return respCode-->HTTP响应码,respBody-->HTTP响应报文体,respMsg-->HTTP响应完整报文
*/
public static Map<String, String> sendPostRequest(String reqURL, Map<String, String> reqParams, String reqCharset) {
StringBuilder reqData = new StringBuilder();
for (Map.Entry<String, String> entry : reqParams.entrySet()) {
try {
reqData.append(entry.getKey()).append("=").append(URLEncoder.encode(entry.getValue(), reqCharset)).append("&");
} catch (UnsupportedEncodingException e) {
System.out.println("编码字符串[" + entry.getValue() + "]时发生异常:系统不支持该字符集[" + reqCharset + "]");
reqData.append(entry.getKey()).append("=").append(entry.getValue()).append("&");
}
}
if (reqData.length() > 0) {
reqData.setLength(reqData.length() - 1); //删除最后一个&符号
}
return sendPostRequest(reqURL, reqData.toString(), reqCharset);
}
/**
* 发送HTTP_POST请求
* @see you can see {@link NativeHTTPUtil#sendPostRequest(String, Map, String)}
* @see 注意:若欲直接调用本方法,切记请求参数值含中文时,一定要对该参数值<code>URLEncoder.encode(value, reqCharset)</code>
* @see 注意:这里只是对key=value中的'value'进行encode,而非'key='..encode完毕后,再组织成key=newValue传给本方法
*/
public static Map<String, String> sendPostRequest(String reqURL, String reqData, String reqCharset) {
Map<String, String> respMap = new HashMap<String, String>();
HttpURLConnection httpURLConnection = null;
OutputStream out = null; //写
InputStream in = null; //读
String respBody = null; //HTTP响应报文体
String respCharset = "UTF-8";
try {
URL sendUrl = new URL(reqURL);
httpURLConnection = (HttpURLConnection)sendUrl.openConnection();
httpURLConnection.setDoInput(true); //true表示允许获得输入流,读取服务器响应的数据,该属性默认值为true
httpURLConnection.setDoOutput(true); //true表示允许获得输出流,向远程服务器发送数据,该属性默认值为false
httpURLConnection.setUseCaches(false); //禁止缓存
httpURLConnection.setReadTimeout(30000); //30秒读取超时
httpURLConnection.setConnectTimeout(30000); //30秒连接超时
httpURLConnection.setRequestMethod("POST");
out = httpURLConnection.getOutputStream();
out.write(reqData.getBytes());
out.flush(); //发送数据
/**
* 获取HTTP响应头
* @see URLConnection类提供了读取远程服务器响应数据的一系列方法
* @see getHeaderField(String name)可以返回响应头中参数name指定的属性的值
* @see 注意:经过我的测试,此处获取到头属性的顺序与服务器响应的真实头属性顺序或可不一致
* @see 注意:测试时,我让服务器返回的头属性中,Content-Type排在第一个,Content-Length排在第二个
* @see 注意:结果在此处获取到的响应头属性中,Content-Length排在第一个,Content-Type排在第二个
*/
StringBuilder respHeader = new StringBuilder();
Map<String, List<String>> headerFields = httpURLConnection.getHeaderFields();
for(Map.Entry<String, List<String>> entry : headerFields.entrySet()){
StringBuilder sb = new StringBuilder();
for(int i=0; i<entry.getValue().size(); i++){
sb.append(entry.getValue().get(i));
}
if(null == entry.getKey()){
respHeader.append(sb.toString());
}else{
respHeader.append(entry.getKey()).append(": ").append(sb.toString());
}
respHeader.append("\r\n");
}
/**
* 获取Content-Type中的charset值
* @see 如Content-Type: text/html; charset=GBK
*/
String contentType = httpURLConnection.getContentType();
if(null!=contentType && contentType.toLowerCase().contains("charset")){
respCharset = contentType.substring(contentType.lastIndexOf("=") + 1);
}
/**
* 获取HTTP响应正文
* @see ---------------------------------------------------------------------------------------------
* @see SUN提供了基于HTTP协议的框架实现,不过,这些实现类并没有在JDK类库中公开,它们都位于sun.net.www包或者其子包中
* @see 并且,URLConnection具体子类(HttpURLConnection类)的getInputStream()方法仅仅返回响应正文部分的输入流
* @see HTTP响应结果包括HTTP响应码,响应头和响应正文3部分,获得输入流后,就能读取服务器发送的响应正文
* @see ----------------------------------------------------------------------------------------------
* @see 使用httpURLConnection.getContentLength()时,要保证服务器给返回Content-Length头属性
* @see byte[] byteDatas = new byte[httpURLConnection.getContentLength()];
* @see httpURLConnection.getInputStream().read(byteDatas);
* @see respBody = new String(byteDatas, respCharset);
* @see ----------------------------------------------------------------------------------------------
* @see in = httpURLConnection.getInputStream();
* @see byte[] byteDatas = new byte[in.available()];
* @see 关于InputStream.available()说明如下,更详细说明见JDK API DOC
* @see 有些InputStream的实现将返回流中的字节总数,但也有很多实现不会这样做
* @see 试图使用in.available()方法的返回值分配缓冲区,以保存此流所有数据的做法是不正确的
* @see ----------------------------------------------------------------------------------------------
*/
in = httpURLConnection.getInputStream();
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
byte[] buff = new byte[1024];
int len = -1;
while((len=in.read(buff)) != -1){
buffer.write(buff, 0, len);
}
respBody = buffer.toString(respCharset);
//使用httpURLConnection.getResponseMessage()可以获取到[HTTP/1.0 200 OK]中的[OK]
respMap.put("respCode", String.valueOf(httpURLConnection.getResponseCode()));
respMap.put("respBody", respBody);
respMap.put("respMsg", respHeader.toString() + "\r\n" + respBody);
return respMap;
} catch (Exception e) {
System.out.println("与[" + reqURL + "]通信异常,堆栈信息如下");
e.printStackTrace();
return respMap;
} finally {
if (out != null) {
try {
out.close();
} catch (Exception e) {
System.out.println("关闭输出流时发生异常,堆栈信息如下");
e.printStackTrace();
}
}
if (in != null) {
try {
in.close();
} catch (Exception e) {
System.out.println("关闭输入流时发生异常,堆栈信息如下");
e.printStackTrace();
}
}
if (httpURLConnection != null) {
httpURLConnection.disconnect();
httpURLConnection = null;
}
}
}
}
下面是测试代码
[java] view
plain copy
public static void main(String[] args) {
Map<String, String> params = new HashMap<String, String>();
params.put("merNo", "301100100001630");
params.put("signType", "MD5");
params.put("merBindAgrNo", "00003018007000006450000013866742");
params.put("interfaceVersion", "1.0.0.0");
params.put("amount", "1000");
params.put("orderDate", "20120823");
params.put("orderNo", "UDP1208230917531231111");
params.put("merReqTime", "20120823091802");
params.put("goodsDesc", "为号码交费充值元");
params.put("goodsName", "中国联通交费充值");
params.put("userIdeMark", "3");
params.put("bankAgrMode", "9");
params.put("signMsg", "3ced24a118461043901d47815e6905a8");
Map<String, String> respMap = sendPostRequest("http://127.0.0.1/tra/bind/payment.htm", params, "UTF-8");
System.out.println("=============================================================================");
System.out.println("HTT响应码如下");
System.out.println(respMap.get("respCode"));
System.out.println("=============================================================================");
System.out.println("HTT响应正文如下");
System.out.println(respMap.get("respBody"));
System.out.println("=============================================================================");
System.out.println("HTTP响应完整报文如下");
System.out.println(respMap.get("respMsg"));
System.out.println("=============================================================================");
}
下面是控制台输出
[java] view
plain copy
//控制台输出如下
//=============================================================================
// HTT响应码如下
// 200
// =============================================================================
// HTT响应正文如下
// interfaceVersion=1.0.0.0
// merReqTime=
// payJournl=
// amount=
// orderNo=UDP1208230917531231111
// orderTime=20120823
// payBankNo=
// bankAccNo=
// bankAccName=
// transRet=ILLEGAL_MERCHANT_NO
// resultDis=商户签名key查询失败致使无法验签
// acceptDate=
// acceptTime=
// signType=MD5
// signMsg=29a312ab08b7273d7500a960c8c86b73
// =============================================================================
// HTTP响应完整报文如下
// HTTP/1.1 200 OK
// Content-Length: 289
// Content-Type: text/html; charset=GBK
//
// interfaceVersion=1.0.0.0
// merReqTime=
// payJournl=
// amount=
// orderNo=UDP1208230917531231111
// orderTime=20120823
// payBankNo=
// bankAccNo=
// bankAccName=
// transRet=ILLEGAL_MERCHANT_NO
// resultDis=商户签名key查询失败致使无法验签
// acceptDate=
// acceptTime=
// signType=MD5
// signMsg=29a312ab08b7273d7500a960c8c86b73
// =============================================================================
//
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* 使用Java原生API编写发送HTTP_POST请求的工具类
* @see ------------------------------------------------------------------------------------------
* @see 与之类似的还有一个HttpClientUtil工具类
* @see 地址为http://blog.csdn.net/jadyer/article/details/8087960
* @see ------------------------------------------------------------------------------------------
* @see 本方法的美中不足是:服务器返回500时,它会直接抛出类似下面的异常
* @see java.io.IOException: Server returned HTTP response code: 500 for URL: http://xxxx/xxxx
* @see 原因很简单:因为这里用到的是SUN提供的基于HTTP协议的框架实现
* @see ------------------------------------------------------------------------------------------
* @see 个人更推荐使用Socket发送HTTP请求
* @see 例子见http://blog.csdn.net/jadyer/article/details/8788272
* @see ------------------------------------------------------------------------------------------
* @create Mar 4, 2013 2:47:57 PM
* @editor Apr 4, 2013 10:02:18 AM
* @author 玄玉<http://blog.csdn.net/jadyer>
*/
public class NativeHTTPUtil {
private NativeHTTPUtil(){}
/**
* 发送HTTP_POST请求
* @see 本方法默认的连接和读取超时均为30秒
* @see 请求参数含有中文时,亦可直接传入本方法中,本方法内部会自动根据reqCharset参数进行<code>URLEncoder.encode()</code>
* @see 解码响应正文时,默认取响应头[Content-Type=text/html; charset=GBK]字符集,若无Content-Type,则使用UTF-8解码
* @param reqURL 请求地址
* @param reqParams 请求正文数据
* @param reqCharset 请求报文的编码字符集(主要针对请求参数值含中文而言)
* @return respCode-->HTTP响应码,respBody-->HTTP响应报文体,respMsg-->HTTP响应完整报文
*/
public static Map<String, String> sendPostRequest(String reqURL, Map<String, String> reqParams, String reqCharset) {
StringBuilder reqData = new StringBuilder();
for (Map.Entry<String, String> entry : reqParams.entrySet()) {
try {
reqData.append(entry.getKey()).append("=").append(URLEncoder.encode(entry.getValue(), reqCharset)).append("&");
} catch (UnsupportedEncodingException e) {
System.out.println("编码字符串[" + entry.getValue() + "]时发生异常:系统不支持该字符集[" + reqCharset + "]");
reqData.append(entry.getKey()).append("=").append(entry.getValue()).append("&");
}
}
if (reqData.length() > 0) {
reqData.setLength(reqData.length() - 1); //删除最后一个&符号
}
return sendPostRequest(reqURL, reqData.toString(), reqCharset);
}
/**
* 发送HTTP_POST请求
* @see you can see {@link NativeHTTPUtil#sendPostRequest(String, Map, String)}
* @see 注意:若欲直接调用本方法,切记请求参数值含中文时,一定要对该参数值<code>URLEncoder.encode(value, reqCharset)</code>
* @see 注意:这里只是对key=value中的'value'进行encode,而非'key='..encode完毕后,再组织成key=newValue传给本方法
*/
public static Map<String, String> sendPostRequest(String reqURL, String reqData, String reqCharset) {
Map<String, String> respMap = new HashMap<String, String>();
HttpURLConnection httpURLConnection = null;
OutputStream out = null; //写
InputStream in = null; //读
String respBody = null; //HTTP响应报文体
String respCharset = "UTF-8";
try {
URL sendUrl = new URL(reqURL);
httpURLConnection = (HttpURLConnection)sendUrl.openConnection();
httpURLConnection.setDoInput(true); //true表示允许获得输入流,读取服务器响应的数据,该属性默认值为true
httpURLConnection.setDoOutput(true); //true表示允许获得输出流,向远程服务器发送数据,该属性默认值为false
httpURLConnection.setUseCaches(false); //禁止缓存
httpURLConnection.setReadTimeout(30000); //30秒读取超时
httpURLConnection.setConnectTimeout(30000); //30秒连接超时
httpURLConnection.setRequestMethod("POST");
out = httpURLConnection.getOutputStream();
out.write(reqData.getBytes());
out.flush(); //发送数据
/**
* 获取HTTP响应头
* @see URLConnection类提供了读取远程服务器响应数据的一系列方法
* @see getHeaderField(String name)可以返回响应头中参数name指定的属性的值
* @see 注意:经过我的测试,此处获取到头属性的顺序与服务器响应的真实头属性顺序或可不一致
* @see 注意:测试时,我让服务器返回的头属性中,Content-Type排在第一个,Content-Length排在第二个
* @see 注意:结果在此处获取到的响应头属性中,Content-Length排在第一个,Content-Type排在第二个
*/
StringBuilder respHeader = new StringBuilder();
Map<String, List<String>> headerFields = httpURLConnection.getHeaderFields();
for(Map.Entry<String, List<String>> entry : headerFields.entrySet()){
StringBuilder sb = new StringBuilder();
for(int i=0; i<entry.getValue().size(); i++){
sb.append(entry.getValue().get(i));
}
if(null == entry.getKey()){
respHeader.append(sb.toString());
}else{
respHeader.append(entry.getKey()).append(": ").append(sb.toString());
}
respHeader.append("\r\n");
}
/**
* 获取Content-Type中的charset值
* @see 如Content-Type: text/html; charset=GBK
*/
String contentType = httpURLConnection.getContentType();
if(null!=contentType && contentType.toLowerCase().contains("charset")){
respCharset = contentType.substring(contentType.lastIndexOf("=") + 1);
}
/**
* 获取HTTP响应正文
* @see ---------------------------------------------------------------------------------------------
* @see SUN提供了基于HTTP协议的框架实现,不过,这些实现类并没有在JDK类库中公开,它们都位于sun.net.www包或者其子包中
* @see 并且,URLConnection具体子类(HttpURLConnection类)的getInputStream()方法仅仅返回响应正文部分的输入流
* @see HTTP响应结果包括HTTP响应码,响应头和响应正文3部分,获得输入流后,就能读取服务器发送的响应正文
* @see ----------------------------------------------------------------------------------------------
* @see 使用httpURLConnection.getContentLength()时,要保证服务器给返回Content-Length头属性
* @see byte[] byteDatas = new byte[httpURLConnection.getContentLength()];
* @see httpURLConnection.getInputStream().read(byteDatas);
* @see respBody = new String(byteDatas, respCharset);
* @see ----------------------------------------------------------------------------------------------
* @see in = httpURLConnection.getInputStream();
* @see byte[] byteDatas = new byte[in.available()];
* @see 关于InputStream.available()说明如下,更详细说明见JDK API DOC
* @see 有些InputStream的实现将返回流中的字节总数,但也有很多实现不会这样做
* @see 试图使用in.available()方法的返回值分配缓冲区,以保存此流所有数据的做法是不正确的
* @see ----------------------------------------------------------------------------------------------
*/
in = httpURLConnection.getInputStream();
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
byte[] buff = new byte[1024];
int len = -1;
while((len=in.read(buff)) != -1){
buffer.write(buff, 0, len);
}
respBody = buffer.toString(respCharset);
//使用httpURLConnection.getResponseMessage()可以获取到[HTTP/1.0 200 OK]中的[OK]
respMap.put("respCode", String.valueOf(httpURLConnection.getResponseCode()));
respMap.put("respBody", respBody);
respMap.put("respMsg", respHeader.toString() + "\r\n" + respBody);
return respMap;
} catch (Exception e) {
System.out.println("与[" + reqURL + "]通信异常,堆栈信息如下");
e.printStackTrace();
return respMap;
} finally {
if (out != null) {
try {
out.close();
} catch (Exception e) {
System.out.println("关闭输出流时发生异常,堆栈信息如下");
e.printStackTrace();
}
}
if (in != null) {
try {
in.close();
} catch (Exception e) {
System.out.println("关闭输入流时发生异常,堆栈信息如下");
e.printStackTrace();
}
}
if (httpURLConnection != null) {
httpURLConnection.disconnect();
httpURLConnection = null;
}
}
}
}
下面是测试代码
[java] view
plain copy
public static void main(String[] args) {
Map<String, String> params = new HashMap<String, String>();
params.put("merNo", "301100100001630");
params.put("signType", "MD5");
params.put("merBindAgrNo", "00003018007000006450000013866742");
params.put("interfaceVersion", "1.0.0.0");
params.put("amount", "1000");
params.put("orderDate", "20120823");
params.put("orderNo", "UDP1208230917531231111");
params.put("merReqTime", "20120823091802");
params.put("goodsDesc", "为号码交费充值元");
params.put("goodsName", "中国联通交费充值");
params.put("userIdeMark", "3");
params.put("bankAgrMode", "9");
params.put("signMsg", "3ced24a118461043901d47815e6905a8");
Map<String, String> respMap = sendPostRequest("http://127.0.0.1/tra/bind/payment.htm", params, "UTF-8");
System.out.println("=============================================================================");
System.out.println("HTT响应码如下");
System.out.println(respMap.get("respCode"));
System.out.println("=============================================================================");
System.out.println("HTT响应正文如下");
System.out.println(respMap.get("respBody"));
System.out.println("=============================================================================");
System.out.println("HTTP响应完整报文如下");
System.out.println(respMap.get("respMsg"));
System.out.println("=============================================================================");
}
下面是控制台输出
[java] view
plain copy
//控制台输出如下
//=============================================================================
// HTT响应码如下
// 200
// =============================================================================
// HTT响应正文如下
// interfaceVersion=1.0.0.0
// merReqTime=
// payJournl=
// amount=
// orderNo=UDP1208230917531231111
// orderTime=20120823
// payBankNo=
// bankAccNo=
// bankAccName=
// transRet=ILLEGAL_MERCHANT_NO
// resultDis=商户签名key查询失败致使无法验签
// acceptDate=
// acceptTime=
// signType=MD5
// signMsg=29a312ab08b7273d7500a960c8c86b73
// =============================================================================
// HTTP响应完整报文如下
// HTTP/1.1 200 OK
// Content-Length: 289
// Content-Type: text/html; charset=GBK
//
// interfaceVersion=1.0.0.0
// merReqTime=
// payJournl=
// amount=
// orderNo=UDP1208230917531231111
// orderTime=20120823
// payBankNo=
// bankAccNo=
// bankAccName=
// transRet=ILLEGAL_MERCHANT_NO
// resultDis=商户签名key查询失败致使无法验签
// acceptDate=
// acceptTime=
// signType=MD5
// signMsg=29a312ab08b7273d7500a960c8c86b73
// =============================================================================
//
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- 使用Java原生API编写发送HTTP_POST请求的工具类
- 【使用Java原生API编写发送HTTP_POST请求的工具类】
- 使用Java原生API编写发送HTTP_POST请求的工具类
- 使用JavaSocket编写发送HTTP_POST请求的工具类
- 多种方式实现（jdk原生api实现/httpClient的实现） java 发送http（post/get）请求并携带参数（讲解超详细）
- Java使用HttpURLConnection发送POST和GET请求
- 使用java代码发送HTTP Post请求
- java中使用scoket模拟http post请求发送图片或文件
- 使用java程序模拟页面发送http的post请求
- 使用java程序模拟页面发送http的post请求
- java中使用scoket模拟http post请求发送图片或文件
- JAVA使用http发送post或get请求实例
- java中使用scoket模拟http post请求发送图片或文件
- java发送http的get、post请求工具类
- 使用java程序模拟页面发送http的post请求
- 在JAVA中使用HttpURLConnection发送POST请求
- JAVA使用apache http组件发送POST请求
- Java使用HttpURLConnection发送Get及Post请求简单过程
- java中使用scoket模拟http post请求发送图片或文件
- 使用java程序模拟页面发送http的post请求