package com.clouds.util;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import org.apache.log4j.Logger;
public class HttpRequestProxy {
/**
* 连接超时
*/
private static int connectTimeOut = 5000;
/**
* 读取数据超时
*/
private static int readTimeOut = 10000;
/**
* 请求编码
*/
private static String requestEncoding = "GBK";
private static Logger logger = Logger.getLogger(HttpRequestProxy.class);
/**
* @return 连接超时(毫秒)
* @see com.hengpeng.common.web.HttpRequestProxy#connectTimeOut
*/
public static int getConnectTimeOut() {
return HttpRequestProxy.connectTimeOut;
}
/**
* @return 读取数据超时(毫秒)
* @see com.hengpeng.common.web.HttpRequestProxy#readTimeOut
*/
public static int getReadTimeOut() {
return HttpRequestProxy.readTimeOut;
}
/**
* @return 请求编码
* @see com.hengpeng.common.web.HttpRequestProxy#requestEncoding
*/
public static String getRequestEncoding() {
return requestEncoding;
}
/**
* @param connectTimeOut 连接超时(毫秒)
* @see com.hengpeng.common.web.HttpRequestProxy#connectTimeOut
*/
public static void setConnectTimeOut(int connectTimeOut) {
HttpRequestProxy.connectTimeOut = connectTimeOut;
}
/**
* @param readTimeOut 读取数据超时(毫秒)
* @see com.hengpeng.common.web.HttpRequestProxy#readTimeOut
*/
public static void setReadTimeOut(int readTimeOut) {
HttpRequestProxy.readTimeOut = readTimeOut;
}
/**
* @param requestEncoding 请求编码
* @see com.hengpeng.common.web.HttpRequestProxy#requestEncoding
*/
public static void setRequestEncoding(String requestEncoding) {
HttpRequestProxy.requestEncoding = requestEncoding;
}
/**
* <pre>
* 发送带参数的GET的HTTP请求
* </pre>
*
* @param reqUrl HTTP请求URL
* @param parameters 参数映射表
* @return HTTP响应的字符串
*/
public static String doGet(String reqUrl, Map<?, ?> parameters, String recvEncoding) {
HttpURLConnection url_con = null;
String responseContent = null;
try {
StringBuffer params = new StringBuffer();
for (Iterator<?> iter = parameters.entrySet().iterator(); iter.hasNext();) {
Entry<?, ?> element = (Entry<?, ?>) iter.next();
params.append(element.getKey().toString());
params.append("=");
params.append(URLEncoder.encode(element.getValue().toString(), HttpRequestProxy.requestEncoding));
params.append("&");
}
if (params.length() > 0) {
params = params.deleteCharAt(params.length() - 1);
}
URL url = new URL(reqUrl);
url_con = (HttpURLConnection) url.openConnection();
url_con.setRequestMethod("GET");
System.setProperty("sun.net.client.defaultConnectTimeout", String.valueOf(HttpRequestProxy.connectTimeOut));// （单位：毫秒）jdk1.4换成这个,连接超时
System.setProperty("sun.net.client.defaultReadTimeout", String.valueOf(HttpRequestProxy.readTimeOut)); // （单位：毫秒）jdk1.4换成这个,读操作超时
// url_con.setConnectTimeout(5000);//（单位：毫秒）jdk
// 1.5换成这个,连接超时
// url_con.setReadTimeout(5000);//（单位：毫秒）jdk 1.5换成这个,读操作超时
url_con.setDoOutput(true);
byte[] b = params.toString().getBytes();
url_con.getOutputStream().write(b, 0, b.length);
url_con.getOutputStream().flush();
url_con.getOutputStream().close();
InputStream in = url_con.getInputStream();
BufferedReader rd = new BufferedReader(new InputStreamReader(in, recvEncoding));
String tempLine = rd.readLine();
StringBuffer temp = new StringBuffer();
String crlf = System.getProperty("line.separator");
while (tempLine != null) {
temp.append(tempLine);
temp.append(crlf);
tempLine = rd.readLine();
}
responseContent = temp.toString();
rd.close();
in.close();
}
catch (IOException e) {
logger.error("网络故障", e);
}
finally {
if (url_con != null) {
url_con.disconnect();
}
}
return responseContent;
}
/**
* <pre>
* 发送不带参数的GET的HTTP请求
* </pre>
*
* @param reqUrl HTTP请求URL
* @return HTTP响应的字符串
*/
public static String doGet(String reqUrl, String recvEncoding) {
HttpURLConnection url_con = null;
String responseContent = null;
try {
StringBuffer params = new StringBuffer();
String queryUrl = reqUrl;
int paramIndex = reqUrl.indexOf("?");
if (paramIndex > 0) {
queryUrl = reqUrl.substring(0, paramIndex);
String parameters = reqUrl.substring(paramIndex + 1, reqUrl.length());
String[] paramArray = parameters.split("&");
for (int i = 0; i < paramArray.length; i++) {
String string = paramArray[i];
int index = string.indexOf("=");
if (index > 0) {
String parameter = string.substring(0, index);
String value = string.substring(index + 1, string.length());
params.append(parameter);
params.append("=");
params.append(URLEncoder.encode(value, HttpRequestProxy.requestEncoding));
params.append("&");
}
}
params = params.deleteCharAt(params.length() - 1);
}
URL url = new URL(queryUrl);
url_con = (HttpURLConnection) url.openConnection();
url_con.setRequestMethod("GET");
System.setProperty("sun.net.client.defaultConnectTimeout", String.valueOf(HttpRequestProxy.connectTimeOut));// （单位：毫秒）jdk1.4换成这个,连接超时
System.setProperty("sun.net.client.defaultReadTimeout", String.valueOf(HttpRequestProxy.readTimeOut)); // （单位：毫秒）jdk1.4换成这个,读操作超时
// url_con.setConnectTimeout(5000);//（单位：毫秒）jdk
// 1.5换成这个,连接超时
// url_con.setReadTimeout(5000);//（单位：毫秒）jdk 1.5换成这个,读操作超时
url_con.setDoOutput(true);
byte[] b = params.toString().getBytes();
url_con.getOutputStream().write(b, 0, b.length);
url_con.getOutputStream().flush();
url_con.getOutputStream().close();
InputStream in = url_con.getInputStream();
BufferedReader rd = new BufferedReader(new InputStreamReader(in, recvEncoding));
String tempLine = rd.readLine();
StringBuffer temp = new StringBuffer();
String crlf = System.getProperty("line.separator");
while (tempLine != null) {
temp.append(tempLine);
temp.append(crlf);
tempLine = rd.readLine();
}
responseContent = temp.toString();
rd.close();
in.close();
}
catch (IOException e) {
logger.error("网络故障", e);
}
finally {
if (url_con != null) {
url_con.disconnect();
}
}
return responseContent;
}
/**
* <pre>
* 发送带参数的POST的HTTP请求
* </pre>
*
* @param reqUrl HTTP请求URL
* @param parameters 参数映射表
* @return HTTP响应的字符串
*/
public static String doPost(String reqUrl, Map<String, String> parameters, String recvEncoding) {
HttpURLConnection url_con = null;
String responseContent = null;
try {
StringBuffer params = new StringBuffer();
for (Iterator<?> iter = parameters.entrySet().iterator(); iter.hasNext();) {
Entry<?, ?> element = (Entry<?, ?>) iter.next();
params.append(element.getKey().toString());
params.append("=");
params.append(URLEncoder.encode(element.getValue().toString(), HttpRequestProxy.requestEncoding));
params.append("&");
}
if (params.length() > 0) {
params = params.deleteCharAt(params.length() - 1);
}
URL url = new URL(reqUrl);
url_con = (HttpURLConnection) url.openConnection();
url_con.setRequestMethod("POST");
System.setProperty("sun.net.client.defaultConnectTimeout", String.valueOf(HttpRequestProxy.connectTimeOut));// （单位：毫秒）jdk1.4换成这个,连接超时
System.setProperty("sun.net.client.defaultReadTimeout", String.valueOf(HttpRequestProxy.readTimeOut)); // （单位：毫秒）jdk1.4换成这个,读操作超时
// url_con.setConnectTimeout(5000);//（单位：毫秒）jdk
// 1.5换成这个,连接超时
// url_con.setReadTimeout(5000);//（单位：毫秒）jdk 1.5换成这个,读操作超时
url_con.setDoOutput(true);
byte[] b = params.toString().getBytes();
url_con.getOutputStream().write(b, 0, b.length);
url_con.getOutputStream().flush();
url_con.getOutputStream().close();
InputStream in = url_con.getInputStream();
BufferedReader rd = new BufferedReader(new InputStreamReader(in, recvEncoding));
String tempLine = rd.readLine();
StringBuffer tempStr = new StringBuffer();
String crlf = System.getProperty("line.separator");
while (tempLine != null) {
tempStr.append(tempLine);
tempStr.append(crlf);
tempLine = rd.readLine();
}
responseContent = tempStr.toString();
rd.close();
in.close();
}
catch (IOException e) {
logger.error("网络故障", e);
}
finally {
if (url_con != null) {
url_con.disconnect();
}
}
return responseContent;
}
public static void main(String[] args) {
Map<String, String> map = new HashMap<String, String>();
map.put("data","a:3:{s:4:%22spec%22;a:2:{s:1:%228%22;s:2:%2243%22;s:2:%2211%22;s:9:%22%E6%B5%85%E8%93%9D%E8%89%B2%22;}s:13:%22spec_value_id%22;a:2:{s:1:%228%22;s:3:%22119%22;s:2:%2211%22;s:3:%22144%22;}s:21:%22spec_private_value_id%22;a:2:{s:1:%228%22;s:11:%2287175758783%22;s:2:%2211%22;s:11:%2287175758784%22;}}");
String temp = HttpRequestProxy.doPost("http://demo2.test.com/api/unserialize.php", map, "utf-8");
System.out.println("返回的消息是:" + temp);
}
}
分享到：
相关推荐
javahttp的简单使用。javaHttp的get与post自带api简单实现。java get post的使用记录
java做的http测试小工具，支持post、put、get方法发送数据，自带base64编码以及解码，支持返回内容下载或base64解码保存为文件，支持base64编码类型选择，http请求编码类型选择以及超时时间设置 该软件必须在 64位...
自己写的基于Java自带URL请求 处理get,post 不明白的，里面直接运行可以跑,
android 当中涉及到网络编程的部分经常会用到http通信，同时android也为我么您...前面提到的HttpUrlConnection接口是java当中的通信接口，而HttpClient则是java当中自带的通信接口。这个demo就实现了这四种通信方式。
48. get和post的区别？ 22 49. JDK,JRE,JVM的区别？ 22 50. Java中常见类，方法，接口 23 51. 多线程 23 51.1. 线程的基本概念 23 51.2. Java中的线程有四种状态 23 51.3. 多线程有几种实现方法,都是什么?同步有几种...
这里我从了Golang SDK自带的net/http包提供的HTTP相关API，虽然本身提供了http.PostForm()、http.Post()以及http.Get()封装好的方法，但是在处理HTTPrequest的header和cookie处理缺乏灵活性，所以我重新将net/http...
xml java系统源码 框架功能及使用 1. 框架功能介绍 ...主要用于处理get,post的请求 @RequestMapping("") 方法注解, 使用该注解是映射url ,把url 指定到对应的方法中处理数据 @ResponseBody 方法注解,使用
自己写一个loadUrl()方法，不能使用jquery自带的load()． 当客户端调用loadUrl()超时，弹出一个登录框，并加一个背景层下面的整个浏览器．这时浏览器窗口内容不能变，只是上面加了一个登录框和一个背景层 当...
首先，Python中自带urllib及urllib2这两个模块，基本上能满足一般的页面抓取。另外，requests也是非常有用的包，与此类似的，还有httplib2等等。 Requests： import requests response = requests.get(url) ...
不仅能够探测POST中的json数据，还能够判断GET中的json数据，支持urlencode，urldecode等。 两种数据对应格式如下： 得到： GET /?json={"fastjson":"example"} 邮政： POST / ... {"fastjson":"example"} 使用...
如果您希望样式表存储在系统自带的模板目录ui.css中，请将插件对象的样式名留空，则会自动按照插件名来调用相应的样式，例如：xhEdtBtnCut、xhEdtBtnCopy，其中的Cut和Copy是插件名 具体调用方法请参考演示文件夹中...
以 restful 风格重新构建代码 20200401 ,GET/POST/PUT/DELETE [ ] 10. 界面主题优化 [ ] 11. 完全弃用 CI 自带数据库操作，使用 catfan/medoo 进行数据库操作 [X] 12. 系统日志： PHP CodeIgniter 3.1.10 RESTful ...
增加post 删除delete 修改put 查询get id参数的传递都使用/id方式。编辑修改:/categories/90 其他参数采用?name=value/如分页参数/categories?start=6 返回数据,针对控制器 查询多个 返回json属组 增加，查询，修改...
24、httpget与post 38 Handler+Runnable模式 40 Handler+Thread+Message模式 42 Handler+ExecutorService(线程池)+MessageQueue模式 44 Handler+ExecutorService(线程池)+MessageQueue+缓存模式 45 25、Bitmap操作 ...
Interceptors ...okhttp自带的CacheInterceptor只能缓存GET请求，并且需要服务端的支持（或者自定义拦截器模拟服务端支持）。 而有时候出于业务或者其他的因素，我们需要在app端控制缓存，并且可能还需要缓
示例web页面返回，提供Get静态web目录文件回执和向服务端Post数据处理示例； 1、访问页面（http与https） 2、post数据 4、集成实用便捷功能 自带集成多色日志输出、debug消息模式、访问频率保护等功能； （1）多色...
除了匿名访问用户（Anonymous）外，IIS中的FTP将使用Windows 2000自带的用户库（可在“开始→程序→管理工具→计算机管理”中找到“用户”一项来进行用户库的管理）。 最后，关键一步还有就是将你的电脑变为网络中的...