使用java开发微信公众号系列-公共类
在开发微信公众号时，需要不时请求URL和数据封装。为了不做重复的工作。提取公共部分进行封装。产生了相应的公众类。今天先来写下请求类，代码如下：
public class HttpRequestProxy {
/**
* 连接超时
*/
private static int connectTimeOut = 5000;
/**
* 读取数据超时
*/
private static int readTimeOut = 10000;
/**
* 发送GET的HTTP请求
* @param reqUrl HTTP请求URL
* @param parameters 参数映射表
* @param recvEncoding 请求编码
* @return HTTP响应的字符串
*/
public static String doGet(String reqUrl, Map<String,String> parameters,
String recvEncoding) {
HttpURLConnection url_con = null;
String responseContent = null;
try {
//请求URL的封装
url_con = doHttpGetConnection(reqUrl,parameters);
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) {
} finally {
if (url_con != null) {
url_con.disconnect();
}
}
return responseContent;
}
/**
* 请求URL的封装
* @param reqUrl HTTP请求URL
* @param parameters 参数映射表
* @return URL的封装
* @throws IOException
*/
private static HttpURLConnection doHttpGetConnection(String reqUrl,
Map<String,String> parameters) throws IOException {
HttpURLConnection url_con = null;
String params = getMapParamsToStr(parameters,WeiXinConstant.REQUEST_ENCODING);
URL url = new URL(reqUrl);
url_con = (HttpURLConnection) url.openConnection();
url_con.setRequestMethod(WeiXinConstant.REQUEST_GET);
url_con.setConnectTimeout(
HttpRequestProxy.connectTimeOut);// （单位：毫秒）
url_con.setReadTimeout(
HttpRequestProxy.readTimeOut);// （单位：毫秒）
url_con.setDoOutput(true);
OutputStreamWriter out = new OutputStreamWriter(url_con.getOutputStream(),WeiXinConstant.REQUEST_ENCODING);
out.write(params);
out.flush();
out.close();
return url_con;
}
/**
* 发送POST的HTTP请求
*
* @param reqUrl HTTP请求URL
* @param parameters 参数映射表
* @param recvEncoding
* @return HTTP响应的字符串
*/
public static String doPost(String reqUrl, Map<String, String> parameters, String recvEncoding) {
HttpURLConnection url_con = null;
String responseContent = null;
try {
URL url = new URL(reqUrl);
url_con = (HttpURLConnection) url.openConnection();
url_con.setConnectTimeout(
HttpRequestProxy.connectTimeOut);// （单位：毫秒）
url_con.setReadTimeout(
HttpRequestProxy.readTimeOut);// （单位：毫秒）
url_con.setRequestMethod(WeiXinConstant.REQUEST_POST);
if (parameters!=null) {
url_con.setDoOutput(true);
String params = getMapParamsToStr(parameters, WeiXinConstant.REQUEST_ENCODING);
OutputStreamWriter out = new OutputStreamWriter(url_con.getOutputStream(),
WeiXinConstant.REQUEST_ENCODING);
out.write(params);
out.flush();
out.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) {
} finally {
if (url_con != null) {
url_con.disconnect();
}
}
return responseContent;
}
/**
* 发送POST的JSON HTTP请求
*
* @param reqUrl HTTP请求URL
* @param parameters 参数映射表
* @param recvEncoding
* @return HTTP响应的字符串
*/
public static String doJsonPost(String reqUrl, Map<String, String> parameters, String jsonData) {
HttpURLConnection url_con = null;
String responseContent = null;
try {
String params = getMapParamsToStr(parameters, WeiXinConstant.REQUEST_ENCODING);
URL url = new URL(reqUrl + "&" + params);
url_con = (HttpURLConnection) url.openConnection();
url_con.setRequestMethod(WeiXinConstant.REQUEST_POST);
url_con.setConnectTimeout(
HttpRequestProxy.connectTimeOut);// （单位：毫秒）
url_con.setReadTimeout(
HttpRequestProxy.readTimeOut);// （单位：毫秒）
url_con.setDoOutput(true);
url_con.setRequestProperty("Accept", "application/json"); // 设置接收数据的格式
url_con.setRequestProperty("Content-Type", "application/json"); // 设置发送数据的格式
OutputStreamWriter out = new OutputStreamWriter(url_con.getOutputStream(), WeiXinConstant.REQUEST_ENCODING);
out.write(jsonData);
out.flush();
out.close();
InputStream in = url_con.getInputStream();
BufferedReader rd = new BufferedReader(new InputStreamReader(in, WeiXinConstant.REQUEST_ENCODING));
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) {
} finally {
if (url_con != null) {
url_con.disconnect();
}
}
return responseContent;
}
/**
* post 文件的封装
* @param reqUrl HTTP请求URL
* @param parameters 参数映射表
* @param encoding 编码
* @param fileIn 数据流
* @param file 文件
* @param contentType 传输类型
* @param name 传输名称
* @return 响应结果
*/
public static String uploadMedia(String reqUrl, Map<String, String> parameters, String encoding,
InputStream fileIn, File file, String contentType,String name) {
HttpURLConnection url_con = null;
String responseContent = null;
try {
// 设置边界
String BOUNDARY = "----------" + System.currentTimeMillis();
String params = getMapParamsToStr(parameters, WeiXinConstant.REQUEST_ENCODING);
URL urlObj = new URL(reqUrl + "&" + params.toString());
// 连接
url_con = (HttpURLConnection) urlObj.openConnection();
/**
* 设置关键值
*/
url_con.setRequestMethod(
WeiXinConstant.REQUEST_POST); // 以Post方式提交表单，默认get方式
url_con.setDoInput(true);
url_con.setDoOutput(true);
url_con.setUseCaches(false); // post方式不能使用缓存
// 设置请求头信息
url_con.setRequestProperty("Connection", "Keep-Alive");
url_con.setRequestProperty("Charset", encoding);
// 设置边界
url_con.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY);
// 请求正文信息
// 第一部分：
StringBuilder sb = new StringBuilder();
sb.append("--"); // 必须多两道线
sb.append(BOUNDARY);
sb.append("rn");
sb.append("Content-Disposition: form-data;name=""+name+"";filelength="" + file.length() + "";filename=""
+ file.getName() + ""rn");
sb.append("Content-Type:application/octet-streamrnrn");
byte[] head = sb.toString().getBytes(encoding);
// 获得输出流
OutputStream out = new DataOutputStream(url_con.getOutputStream());
// 输出表头
out.write(head);
// 文件正文部分
// 把文件已流文件的方式 推入到url中
DataInputStream in = new DataInputStream(fileIn);
int bytes = 0;
byte[] bufferOut = new byte[1024];
while ((bytes = in.read(bufferOut)) != -1) {
out.write(bufferOut, 0, bytes);
}
in.close();
// 结尾部分
byte[] foot = ("rn--" + BOUNDARY + "--rn").getBytes(encoding);// 定义最后数据分隔线
out.write(foot);
out.flush();
out.close();
InputStream iddn = url_con.getInputStream();
BufferedReader rd = new BufferedReader(new InputStreamReader(iddn, encoding));
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();
} catch (IOException e) {
} finally {
if (url_con != null) {
url_con.disconnect();
}
}
return responseContent;
}
/**
* 将参数转换成string
*
* @param paramMap 参数映射表
* @param requestEncoding 编码
* @return
* @throws UnsupportedEncodingException
*/
private static String getMapParamsToStr(Map<String, String> paramMap, String requestEncoding) throws IOException {
StringBuffer params = new StringBuffer();
// 设置边界
Set<String> set = paramMap.keySet();
for (String key : set) {
params.append(key);
params.append("=");
params.append(URLEncoder.encode(paramMap.get(key), requestEncoding));
params.append("&");
}
if (params.length() > 0) {
params = params.deleteCharAt(params.length() - 1);
}
return params.toString();
}
}
