发送http请求
public static String httpGetSend(String url) {String responseMsg = "";HttpClient httpClient = new HttpClient();GetMethod getMethod = new GetMethod(url);// GET請(qǐng)求try {// http超時(shí)5秒httpClient.getHttpConnectionManager().getParams().setConnectionTimeout(5000);// 設(shè)置 get 請(qǐng)求超時(shí)為 5 秒getMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT, 5000);getMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER, new DefaultHttpMethodRetryHandler());httpClient.executeMethod(getMethod);// 發(fā)送請(qǐng)求// 讀取內(nèi)容byte[] responseBody = getMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody, "utf-8");} catch (Exception e) {Logger.getLogger(HttpUtils.class).error(e.getMessage());e.printStackTrace();} finally {getMethod.releaseConnection();// 關(guān)閉連接
}return responseMsg;}
?
/*** 發(fā)送HTTP請(qǐng)求* * @param url* @param propsMap* 發(fā)送的參數(shù)*/public static String httpSend(String url, Map<String, Object> propsMap) {String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求// postMethod.// 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);try {httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求 // Log.info(postMethod.getStatusCode());// 讀取內(nèi)容byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody);} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {postMethod.releaseConnection();// 關(guān)閉連接 }return responseMsg;} /*** 發(fā)送HTTP請(qǐng)求* * @param url* @param propsMap 發(fā)送的參數(shù)* @throws IOException*/private String httpSend(String url, Map<String, Object> propsMap) {String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求// 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key) == null ? null : propsMap.get(key).toString());}postMethod.addParameters(postData);try {httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求// 讀取內(nèi)容byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容// responseMsg = URLDecoder.decode(new String(responseBody),// "UTF-8");responseMsg = new String(responseBody, "UTF-8");} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {postMethod.releaseConnection();// 關(guān)閉連接 }return responseMsg;}?
?
?
package com.huayuan.wap.common.utils;import java.io.IOException; import java.util.Map; import java.util.Set;import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; 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;import com.huayuan.wap.common.model.HttpResponse;public class HttpUtils {/*** 發(fā)送HTTP請(qǐng)求** @param url* @param propsMap 發(fā)送的參數(shù)*/public static HttpResponse httpPost(String url, Map<String, Object> propsMap) {HttpResponse response = new HttpResponse();String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求if (propsMap != null) {// 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);}postMethod.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "utf-8");postMethod.addRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");try {int statusCode = httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求 response.setStatusCode(statusCode);if (statusCode == HttpStatus.SC_OK) {// 讀取內(nèi)容byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody, "utf-8");}} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {postMethod.releaseConnection();// 關(guān)閉連接 }response.setContent(responseMsg);return response;}/*** 發(fā)送HTTP請(qǐng)求** @param url*/public static HttpResponse httpGet(String url) {HttpResponse response = new HttpResponse();String responseMsg = "";HttpClient httpClient = new HttpClient();GetMethod getMethod = new GetMethod(url);try {int statusCode = httpClient.executeMethod(getMethod);// 發(fā)送請(qǐng)求 response.setStatusCode(statusCode);if (statusCode == HttpStatus.SC_OK) {// 讀取內(nèi)容byte[] responseBody = getMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody, "utf-8");}} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {getMethod.releaseConnection();// 關(guān)閉連接 }response.setContent(responseMsg);return response;} } package com.j1.mai.util;import java.io.IOException; import java.util.Map; import java.util.Set;import org.apache.commons.httpclient.DefaultHttpMethodRetryHandler; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; 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; import org.apache.log4j.Logger;public class HttpUtils {/*** 發(fā)送HTTP請(qǐng)求** @param url* @param propsMap 發(fā)送的參數(shù)*/public static HttpResponse httpPost(String url, Map<String, Object> propsMap) {HttpResponse response = new HttpResponse();String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求if (propsMap != null) {// 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);}postMethod.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "utf-8");postMethod.addRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");try {int statusCode = httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求 response.setStatusCode(statusCode);if (statusCode == HttpStatus.SC_OK) {// 讀取內(nèi)容byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody, "utf-8");}} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {postMethod.releaseConnection();// 關(guān)閉連接 }response.setContent(responseMsg);return response;}/*** 發(fā)送HTTP請(qǐng)求** @param url*/public static HttpResponse httpGet(String url) {HttpResponse response = new HttpResponse();String responseMsg = "";HttpClient httpClient = new HttpClient();GetMethod getMethod = new GetMethod(url);try {int statusCode = httpClient.executeMethod(getMethod);// 發(fā)送請(qǐng)求 response.setStatusCode(statusCode);if (statusCode == HttpStatus.SC_OK) {// 讀取內(nèi)容byte[] responseBody = getMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody, "utf-8");}} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {getMethod.releaseConnection();// 關(guān)閉連接 }response.setContent(responseMsg);return response;}/*** 發(fā)送HTTP--GET請(qǐng)求* * @param url* @param propsMap* 發(fā)送的參數(shù)*/public static String httpGetSend(String url) {String responseMsg = "";HttpClient httpClient = new HttpClient();GetMethod getMethod = new GetMethod(url);// GET請(qǐng)求try {// http超時(shí)5秒httpClient.getHttpConnectionManager().getParams().setConnectionTimeout(5000);// 設(shè)置 get 請(qǐng)求超時(shí)為 5 秒getMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT, 5000);getMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER, new DefaultHttpMethodRetryHandler());httpClient.executeMethod(getMethod);// 發(fā)送請(qǐng)求// 讀取內(nèi)容byte[] responseBody = getMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody, "utf-8");} catch (Exception e) {Logger.getLogger(HttpUtils.class).error(e.getMessage());e.printStackTrace();} finally {getMethod.releaseConnection();// 關(guān)閉連接 }return responseMsg;}/*** 發(fā)送HTTP請(qǐng)求* * @param url* @param propsMap* 發(fā)送的參數(shù)*/public static String httpSend(String url, Map<String, Object> propsMap) {String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求// postMethod.// 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);try {httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求 // Log.info(postMethod.getStatusCode());// 讀取內(nèi)容byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody);} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {postMethod.releaseConnection();// 關(guān)閉連接 }return responseMsg;}/*** 發(fā)送Post HTTP請(qǐng)求* * @param url* @param propsMap* 發(fā)送的參數(shù)* @throws IOException * @throws HttpException */public static PostMethod httpSendPost(String url, Map<String, Object> propsMap,String authrition) throws Exception {HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求postMethod.addRequestHeader("Authorization",authrition);postMethod.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET,"UTF-8"); // 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求return postMethod;}/*** 發(fā)送Post HTTP請(qǐng)求* * @param url* @param propsMap* 發(fā)送的參數(shù)* @throws IOException * @throws HttpException */public static PostMethod httpSendPost(String url, Map<String, Object> propsMap) throws Exception {String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求postMethod.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET,"UTF-8"); // 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求return postMethod;}/*** 發(fā)送Get HTTP請(qǐng)求* * @param url* @param propsMap* 發(fā)送的參數(shù)* @throws IOException * @throws HttpException */public static GetMethod httpSendGet(String url, Map<String, Object> propsMap) throws Exception {String responseMsg = "";HttpClient httpClient = new HttpClient();GetMethod getMethod = new GetMethod(url);// GET請(qǐng)求getMethod.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET,"UTF-8"); // 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {getMethod.getParams().setParameter(key, propsMap.get(key).toString());}httpClient.executeMethod(getMethod);// 發(fā)送請(qǐng)求return getMethod;}} package com.founder.ec.member.util;import java.io.IOException; import java.util.Map; import java.util.Set;import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; import org.apache.commons.httpclient.NameValuePair; import org.apache.commons.httpclient.methods.PostMethod;public class HttpUtils {/*** 發(fā)送HTTP請(qǐng)求* * @param url* @param propsMap* 發(fā)送的參數(shù)*/public static String httpSend(String url, Map<String, Object> propsMap) {String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求// 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);try {httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求// 讀取內(nèi)容byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody);} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {postMethod.releaseConnection();// 關(guān)閉連接 }return responseMsg;} } package com.founder.ec.dec.util;import java.io.IOException;import lombok.extern.log4j.Log4j;import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; import org.apache.commons.httpclient.methods.PostMethod; import org.apache.commons.httpclient.params.HttpMethodParams; import org.apache.log4j.Logger;/*** http請(qǐng)求實(shí)體類* * @author Yang Yang 2015年11月13日 下午5:20:43* @since 1.0.0*/ public class HttpUtils {/*** post發(fā)送http請(qǐng)求* * @param url* @param data* @return*/public static String sendHttpPost(String url, String data) {Logger log = Logger.getRootLogger();String responseMsg = "";HttpClient httpClient = new HttpClient();httpClient.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET, "UTF-8");PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求// 參數(shù)設(shè)置postMethod.addParameter("param", data);try {httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求// 讀取內(nèi)容byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容responseMsg = new String(responseBody, "UTF-8");} catch (HttpException e) {log.error(e.getMessage());} catch (IOException e) {log.error(e.getMessage());} finally {postMethod.releaseConnection();// 關(guān)閉連接 }return responseMsg;} } package com.founder.ec.web.util.payments.yeepay;import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory;import java.io.*; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; import java.util.*; /**** <p>Title: </p>* <p>Description: http utils </p>* <p>Copyright: Copyright (c) 2006</p>* <p>Company: </p>* @author LiLu* @version 1.0*/ public class HttpUtils {private static final String URL_PARAM_CONNECT_FLAG = "&";private static final int SIZE = 1024 * 1024;private static Log log = LogFactory.getLog(HttpUtils.class);private HttpUtils() {}/*** GET METHOD* @param strUrl String* @param map Map* @throws java.io.IOException* @return List*/public static List URLGet(String strUrl, Map map) throws IOException {String strtTotalURL = "";List result = new ArrayList();if(strtTotalURL.indexOf("?") == -1) {strtTotalURL = strUrl + "?" + getUrl(map);} else {strtTotalURL = strUrl + "&" + getUrl(map);} // System.out.println("strtTotalURL:" + strtTotalURL);URL url = new URL(strtTotalURL);HttpURLConnection con = (HttpURLConnection) url.openConnection();con.setUseCaches(false);con.setFollowRedirects(true);BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()),SIZE);while (true) {String line = in.readLine();if (line == null) {break;}else {result.add(line);}}in.close();return (result);}/*** POST METHOD* @param strUrl String* @param content Map* @throws java.io.IOException* @return List*/public static List URLPost(String strUrl, Map map) throws IOException {String content = "";content = getUrl(map);String totalURL = null;if(strUrl.indexOf("?") == -1) {totalURL = strUrl + "?" + content;} else {totalURL = strUrl + "&" + content;}URL url = new URL(strUrl);HttpURLConnection con = (HttpURLConnection) url.openConnection();con.setDoInput(true);con.setDoOutput(true);con.setAllowUserInteraction(false);con.setUseCaches(false);con.setRequestMethod("POST");con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=GBK");BufferedWriter bout = new BufferedWriter(new OutputStreamWriter(con.getOutputStream()));bout.write(content);bout.flush();bout.close();BufferedReader bin = new BufferedReader(new InputStreamReader(con.getInputStream()),SIZE);List result = new ArrayList(); while (true) {String line = bin.readLine();if (line == null) {break;}else {result.add(line);}}return (result);}/*** ���URL* @param map Map* @return String*/private static String getUrl(Map map) {if (null == map || map.keySet().size() == 0) {return ("");}StringBuffer url = new StringBuffer();Set keys = map.keySet();for (Iterator i = keys.iterator(); i.hasNext(); ) {String key = String.valueOf(i.next());if (map.containsKey(key)) {Object val = map.get(key);String str = val!=null?val.toString():"";try {str = URLEncoder.encode(str, "GBK");} catch (UnsupportedEncodingException e) {e.printStackTrace();}url.append(key).append("=").append(str).append(URL_PARAM_CONNECT_FLAG);}}String strURL = "";strURL = url.toString();if (URL_PARAM_CONNECT_FLAG.equals("" + strURL.charAt(strURL.length() - 1))) {strURL = strURL.substring(0, strURL.length() - 1);}return (strURL);}/*** http 發(fā)送方法* @param strUrl 請(qǐng)求URL* @param content 請(qǐng)求內(nèi)容* @return 響應(yīng)內(nèi)容* @throws org.apache.commons.httpclient.HttpException* @throws java.io.IOException*/public static String post(String strUrl,String content)throws IOException {URL url = new URL(strUrl);HttpURLConnection connection = (HttpURLConnection) url.openConnection();connection.setDoOutput(true);connection.setDoInput(true);connection.setRequestMethod("POST");connection.setUseCaches(false);connection.setInstanceFollowRedirects(true);connection.setRequestProperty("Content-Type","text/plain;charset=UTF-8");connection.connect();// POST請(qǐng)求DataOutputStream out = new DataOutputStream(connection.getOutputStream());out.write(content.getBytes("utf-8"));out.flush();out.close();// 讀取響應(yīng)BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));String lines;StringBuffer sb = new StringBuffer("");while ((lines = reader.readLine()) != null) {lines = new String(lines.getBytes(), "utf-8");sb.append(lines);}reader.close();// 斷開連接 connection.disconnect();return sb.toString();}} package com.founder.ec.utils;import net.sf.json.JSONObject;import javax.net.ssl.*; import java.io.*; import java.net.URL; import java.security.KeyManagementException; import java.security.NoSuchAlgorithmException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.Map;public class HttpsUtils {private static class TrustAnyTrustManager implements X509TrustManager {public void checkClientTrusted(X509Certificate[] chain, String authType)throws CertificateException {}public void checkServerTrusted(X509Certificate[] chain, String authType)throws CertificateException {}public X509Certificate[] getAcceptedIssuers() {return new X509Certificate[] {};}}private static class TrustAnyHostnameVerifier implements HostnameVerifier {public boolean verify(String hostname, SSLSession session) {return true;}}/*** post方式請(qǐng)求服務(wù)器(https協(xié)議)** @param url* 請(qǐng)求地址* @param content* 參數(shù)* @param charset* 編碼* @return* @throws NoSuchAlgorithmException* @throws KeyManagementException* @throws IOException*/@SuppressWarnings("static-access")public static String post(String url, Map<String, Object> content, String charset)throws NoSuchAlgorithmException, KeyManagementException,IOException {String responseContent = null;SSLContext sc = SSLContext.getInstance("SSL");sc.init(null, new TrustManager[] { new TrustAnyTrustManager() },new java.security.SecureRandom());URL console = new URL(url);HttpsURLConnection conn = (HttpsURLConnection) console.openConnection();conn.setSSLSocketFactory(sc.getSocketFactory());conn.setHostnameVerifier(new TrustAnyHostnameVerifier());conn.setDoOutput(true);conn.setRequestProperty("Content-Type", "application/json;charset=utf-8");conn.connect();JSONObject obj = new JSONObject();obj = obj.fromObject(content);byte[] b = obj.toString().getBytes();DataOutputStream out = new DataOutputStream(conn.getOutputStream());out.write(b, 0, b.length);// 刷新、關(guān)閉 out.flush();out.close();InputStream in = conn.getInputStream();BufferedReader rd = new BufferedReader(new InputStreamReader(in,"UTF-8"));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();if (conn != null){conn.disconnect();}return responseContent;}} package com.founder.ec.web.util;import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.URL; import java.security.KeyManagementException; import java.security.NoSuchAlgorithmException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.Map;import javax.net.ssl.HostnameVerifier; import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLSession; import javax.net.ssl.TrustManager; import javax.net.ssl.X509TrustManager;import net.sf.json.JSONObject;public class HttpsUtils {private static class TrustAnyTrustManager implements X509TrustManager {public void checkClientTrusted(X509Certificate[] chain, String authType)throws CertificateException {}public void checkServerTrusted(X509Certificate[] chain, String authType)throws CertificateException {}public X509Certificate[] getAcceptedIssuers() {return new X509Certificate[] {};}}private static class TrustAnyHostnameVerifier implements HostnameVerifier {public boolean verify(String hostname, SSLSession session) {return true;}}/*** post方式請(qǐng)求服務(wù)器(https協(xié)議)** @param url* 請(qǐng)求地址* @param content* 參數(shù)* @param charset* 編碼* @return* @throws NoSuchAlgorithmException* @throws KeyManagementException* @throws IOException*/@SuppressWarnings("static-access")public static String post(String url, Map<String, Object> content, String charset)throws NoSuchAlgorithmException, KeyManagementException,IOException {String responseContent = null;SSLContext sc = SSLContext.getInstance("SSL");sc.init(null, new TrustManager[] { new TrustAnyTrustManager() },new java.security.SecureRandom());URL console = new URL(url);HttpsURLConnection conn = (HttpsURLConnection) console.openConnection();conn.setSSLSocketFactory(sc.getSocketFactory());conn.setHostnameVerifier(new TrustAnyHostnameVerifier());conn.setDoOutput(true);conn.setRequestProperty("Content-Type", "application/json;charset=utf-8");conn.connect();JSONObject obj = new JSONObject();obj = obj.fromObject(content);byte[] b = obj.toString().getBytes();DataOutputStream out = new DataOutputStream(conn.getOutputStream());out.write(b, 0, b.length);// 刷新、關(guān)閉 out.flush();out.close();InputStream in = conn.getInputStream();BufferedReader rd = new BufferedReader(new InputStreamReader(in,"UTF-8"));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();if (conn != null){conn.disconnect();}return responseContent;}} /*** 華潤通聯(lián)合登陸*//****聯(lián)合登錄獲取華潤通的用戶信息** appid,* access_token,* openid,* sign,* timestamp,* 通過code獲取token 與openId*/@RequestMapping(value = "/getHrtCode")public String hrt(HttpServletRequest request, HttpServletResponse response,String code,String state) {JSONObject object = new JSONObject();JSONObject data = new JSONObject();String memberKey="";/**** 讀取配置文件拿到華潤通數(shù)據(jù)*/String hrtUrl=PropertyConfigurer.getString("hrtUrl");if(StringUtil.isEmpty(hrtUrl)){hrtUrl = "https://oauth2.huaruntong.cn/oauth2/access_token";}String hrtAppId=PropertyConfigurer.getString("hrtAppId");if(StringUtil.isEmpty(hrtAppId)){hrtAppId = "1655100000004";}String hrtSignKey=PropertyConfigurer.getString("hrtSignKey");if(StringUtil.isEmpty(hrtSignKey)){hrtSignKey = "tmKBcdNCTeyvDLTQFkYtbDdHBUwHZEmSZlNFbUhxHqQOjgev";}// //獲取當(dāng)前時(shí)間SimpleDateFormat sd=new SimpleDateFormat("yyyyMMddHHmmss");String timestamp= sd.format(new Date());String sign = "appid="+hrtAppId+"&code="+code+"&grant_type=authorization_code×tamp="+timestamp+"&app_secret="+hrtSignKey;sign = MD5.getMD5(sign).toUpperCase();/***發(fā)送請(qǐng)求*/try {Map<String,Object> map = new HashMap<String , Object>();map.put("appid", hrtAppId);map.put("gant_type", grantType);map.put("code", code);map.put("timestamp", timestamp);map.put("sign",sign);String back = HttpsUtils.post(hrtUrl, map, "UTF-8");if(!back.isEmpty() || back!=null){object= JSONObject.fromObject(back);data= object.getJSONObject("data");if( data.size()!=0 ){String openId= data.getString("openid");// 異常處理if (null == openId || "".equals(openId) ) {request.setAttribute("errors", "授權(quán)失敗，請(qǐng)重新授權(quán)！");return "/jsp/common/404.jsp";}ServiceMessage<com.j1.member.model.Member> result= memberSsoService.hrtFastLogin(openId);if(result.getStatus() == MsgStatus.NORMAL){com.j1.member.model.Member member= result.getResult();memberKey = result.getResult().getMemberKey();if(member!=null){request.getSession().setAttribute("memberId", member.getMemberId());request.getSession().setAttribute("loginName", member.getLoginName());request.getSession().setAttribute("realName", member.getRealName());request.getSession().setAttribute("member", member);request.getSession().setAttribute("mobile",member.getMobile());request.getSession().setAttribute("memberKey", result.getResult().getMemberKey());return "redirect:https://www.j1.com?memberKey"+memberKey;}}}}} catch (Exception e) {e.printStackTrace();logger.error("華瑞通系統(tǒng)內(nèi)部報(bào)錯(cuò)");}return "redirect:https://www.j1.com?memberKey"+memberKey;}?
package com.founder.ec.web.util.payments.payeco.http;import com.founder.ec.web.util.payments.payeco.http.ssl.SslConnection;import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.util.Iterator; import java.util.SortedMap;/*** 描述： http通訊基礎(chǔ)類* */ public class HttpClient {private int status;public int getStatus() {return status;}public void setStatus(int status) {this.status = status;}public static String REQUEST_METHOD_GET = "GET";public static String REQUEST_METHOD_POST = "POST";public String send(String postURL, String requestBody,String sendCharset, String readCharset) {return send(postURL,requestBody,sendCharset,readCharset,300,300);}public String send(String postURL, String requestBody,String sendCharset, String readCharset,String RequestMethod) {return send(postURL,requestBody,sendCharset,readCharset,300,300,RequestMethod);}/*** @param postURL 訪問地址* @param requestBody paramName1=paramValue1¶mName2=paramValue2* @param sendCharset 發(fā)送字符編碼* @param readCharset 返回字符編碼* @param connectTimeout 連接主機(jī)的超時(shí)時(shí)間 單位:秒* @param readTimeout 從主機(jī)讀取數(shù)據(jù)的超時(shí)時(shí)間 單位:秒* @return 通訊返回*/public String send(String url, String requestBody,String sendCharset, String readCharset,int connectTimeout,int readTimeout) {try {return connection(url,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,REQUEST_METHOD_POST);} catch (Exception ex) {ex.printStackTrace();System.out.print("發(fā)送請(qǐng)求[" + url + "]失敗，" + ex.getMessage());return null;} }/*** @param postURL 訪問地址* @param requestBody paramName1=paramValue1¶mName2=paramValue2* @param sendCharset 發(fā)送字符編碼* @param readCharset 返回字符編碼* @param connectTimeout 連接主機(jī)的超時(shí)時(shí)間 單位:秒* @param readTimeout 從主機(jī)讀取數(shù)據(jù)的超時(shí)時(shí)間 單位:秒* @param RequestMethod GET或POST* @return 通訊返回*/public String send(String url, String requestBody,String sendCharset, String readCharset,int connectTimeout,int readTimeout,String RequestMethod) {try {return connection(url,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,RequestMethod);} catch (Exception ex) {ex.printStackTrace();System.out.print("發(fā)送請(qǐng)求[" + url + "]失敗，" + ex.getMessage());return null;} }public String connection(String postURL, String requestBody,String sendCharset, String readCharset,int connectTimeout,int readTimeout,String RequestMethod)throws Exception {if(REQUEST_METHOD_POST.equals(RequestMethod)){return postConnection(postURL,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,null);}else if(REQUEST_METHOD_GET.equals(RequestMethod)){return getConnection(postURL,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,null);}else{return "";}}@SuppressWarnings("rawtypes")public String getConnection(String url, String requestBody,String sendCharset, String readCharset,int connectTimeout,int readTimeout,SortedMap reqHead)throws Exception {// Post請(qǐng)求的url，與get不同的是不需要帶參數(shù)HttpURLConnection httpConn = null;try {if (!url.contains("https:")) {URL postUrl = new URL(url);// 打開連接httpConn = (HttpURLConnection) postUrl.openConnection();} else {SslConnection urlConnect = new SslConnection();httpConn = (HttpURLConnection) urlConnect.openConnection(url);}httpConn.setRequestProperty("Content-Type","application/x-www-form-urlencoded; charset=" + sendCharset);if(reqHead!=null&&reqHead.size()>0){Iterator iterator =reqHead.keySet().iterator();while (iterator.hasNext()) {String key = (String) iterator.next();String val = (String)reqHead.get(key);httpConn.setRequestProperty(key,val);}}// 設(shè)定傳送的內(nèi)容類型是可序列化的java對(duì)象 // (如果不設(shè)此項(xiàng),在傳送序列化對(duì)象時(shí),當(dāng)WEB服務(wù)默認(rèn)的不是這種類型時(shí)可能拋java.io.EOFException) httpUrlConnection.setRequestProperty("Content-type", "application/x-java-serialized-object"); // 連接主機(jī)的超時(shí)時(shí)間（單位：毫秒）httpConn.setConnectTimeout(1000 * connectTimeout); // 從主機(jī)讀取數(shù)據(jù)的超時(shí)時(shí)間（單位：毫秒） httpConn.setReadTimeout(1000 * readTimeout);// 連接，從postUrl.openConnection()至此的配置必須要在 connect之前完成，// 要注意的是connection.getOutputStream會(huì)隱含的進(jìn)行 connect。 httpConn.connect();int status = httpConn.getResponseCode();setStatus(status);if (status != HttpURLConnection.HTTP_OK) {System.out.print("發(fā)送請(qǐng)求失敗，狀態(tài)碼：[" + status + "] 返回信息："+ httpConn.getResponseMessage());return null;}BufferedReader reader = new BufferedReader(new InputStreamReader(httpConn.getInputStream(), readCharset));StringBuffer responseSb = new StringBuffer();String line = null;while ((line = reader.readLine()) != null) {responseSb.append(line.trim());}reader.close();return responseSb.toString().trim();} finally {httpConn.disconnect();}}@SuppressWarnings("rawtypes")public String postConnection(String postURL, String requestBody,String sendCharset, String readCharset,int connectTimeout,int readTimeout,SortedMap reqHead)throws Exception {// Post請(qǐng)求的url，與get不同的是不需要帶參數(shù)HttpURLConnection httpConn = null;try {if (!postURL.contains("https:")) {URL postUrl = new URL(postURL);// 打開連接httpConn = (HttpURLConnection) postUrl.openConnection();} else {SslConnection urlConnect = new SslConnection();httpConn = (HttpURLConnection) urlConnect.openConnection(postURL);}// 設(shè)置是否向httpUrlConnection輸出，因?yàn)檫@個(gè)是post請(qǐng)求，參數(shù)要放在 // http正文內(nèi)，因此需要設(shè)為true, 默認(rèn)情況下是false; httpConn.setDoOutput(true);// 設(shè)置是否從httpUrlConnection讀入，默認(rèn)情況下是true; httpConn.setDoInput(true);// 設(shè)定請(qǐng)求的方法為"POST"，默認(rèn)是GET httpConn.setRequestMethod("POST");// Post 請(qǐng)求不能使用緩存 httpConn.setUseCaches(false);//進(jìn)行跳轉(zhuǎn)httpConn.setInstanceFollowRedirects(true);httpConn.setRequestProperty("Content-Type","application/x-www-form-urlencoded; charset=" + sendCharset);if(reqHead!=null&&reqHead.size()>0){Iterator iterator =reqHead.keySet().iterator();while (iterator.hasNext()) {String key = (String) iterator.next();String val = (String)reqHead.get(key);httpConn.setRequestProperty(key,val);}}// 設(shè)定傳送的內(nèi)容類型是可序列化的java對(duì)象 // (如果不設(shè)此項(xiàng),在傳送序列化對(duì)象時(shí),當(dāng)WEB服務(wù)默認(rèn)的不是這種類型時(shí)可能拋java.io.EOFException) httpUrlConnection.setRequestProperty("Content-type", "application/x-java-serialized-object"); // 連接主機(jī)的超時(shí)時(shí)間（單位：毫秒）httpConn.setConnectTimeout(1000 * connectTimeout); // 從主機(jī)讀取數(shù)據(jù)的超時(shí)時(shí)間（單位：毫秒） httpConn.setReadTimeout(1000 * readTimeout);// 連接，從postUrl.openConnection()至此的配置必須要在 connect之前完成，// 要注意的是connection.getOutputStream會(huì)隱含的進(jìn)行 connect。 httpConn.connect();DataOutputStream out = new DataOutputStream(httpConn.getOutputStream());out.write(requestBody.getBytes(sendCharset));out.flush();out.close();int status = httpConn.getResponseCode();setStatus(status);if (status != HttpURLConnection.HTTP_OK) {System.out.print("發(fā)送請(qǐng)求失敗，狀態(tài)碼：[" + status + "] 返回信息："+ httpConn.getResponseMessage());return null;}BufferedReader reader = new BufferedReader(new InputStreamReader(httpConn.getInputStream(), readCharset));StringBuffer responseSb = new StringBuffer();String line = null;while ((line = reader.readLine()) != null) {responseSb.append(line.trim());}reader.close();return responseSb.toString().trim();} finally {httpConn.disconnect();}}public static void main(String[] args) {}} package com.founder.ec.web.util.payments.tenpay; import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import java.security.KeyManagementException; import java.security.KeyStore; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; import java.security.SecureRandom; import java.security.UnrecoverableKeyException; import java.security.cert.Certificate; import java.security.cert.CertificateException; import java.security.cert.CertificateFactory; import java.util.HashMap; import java.util.Map;import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.KeyManagerFactory; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManagerFactory; public class HttpClientUtil {public static final String SunX509 = "SunX509";public static final String JKS = "JKS";public static final String PKCS12 = "PKCS12";public static final String TLS = "TLS";/*** get HttpURLConnection* @param strUrl url地址* @return HttpURLConnection* @throws IOException*/public static HttpURLConnection getHttpURLConnection(String strUrl)throws IOException {URL url = new URL(strUrl);HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();return httpURLConnection;}/*** get HttpsURLConnection* @param strUrl url地址* @return HttpsURLConnection* @throws IOException*/public static HttpsURLConnection getHttpsURLConnection(String strUrl)throws IOException {URL url = new URL(strUrl);HttpsURLConnection httpsURLConnection = (HttpsURLConnection) url.openConnection();return httpsURLConnection;}/*** 獲取不帶查詢串的url* @param strUrl* @return String*/public static String getURL(String strUrl) {if(null != strUrl) {int indexOf = strUrl.indexOf("?");if(-1 != indexOf) {return strUrl.substring(0, indexOf);} return strUrl;}return strUrl;}/*** 獲取查詢串* @param strUrl* @return String*/public static String getQueryString(String strUrl) {if(null != strUrl) {int indexOf = strUrl.indexOf("?");if(-1 != indexOf) {return strUrl.substring(indexOf+1, strUrl.length());} return "";}return strUrl;}/*** 查詢字符串轉(zhuǎn)換成Map<br/>* name1=key1&name2=key2&...* @param queryString* @return*/public static Map queryString2Map(String queryString) {if(null == queryString || "".equals(queryString)) {return null;}Map m = new HashMap();String[] strArray = queryString.split("&");for(int index = 0; index < strArray.length; index++) {String pair = strArray[index];HttpClientUtil.putMapByPair(pair, m);}return m;}/*** 把鍵值添加至Map<br/>* pair:name=value* @param pair name=value* @param m*/public static void putMapByPair(String pair, Map m) {if(null == pair || "".equals(pair)) {return;}int indexOf = pair.indexOf("=");if(-1 != indexOf) {String k = pair.substring(0, indexOf);String v = pair.substring(indexOf+1, pair.length());if(null != k && !"".equals(k)) {m.put(k, v);}} else {m.put(pair, "");}}/*** BufferedReader轉(zhuǎn)換成String<br/>* 注意:流關(guān)閉需要自行處理* @param reader* @return String* @throws IOException*/public static String bufferedReader2String(BufferedReader reader) throws IOException {StringBuffer buf = new StringBuffer();String line = null;while( (line = reader.readLine()) != null) {buf.append(line);buf.append("\r\n");}return buf.toString();}/*** 處理輸出<br/>* 注意:流關(guān)閉需要自行處理* @param out* @param data* @param len* @throws IOException*/public static void doOutput(OutputStream out, byte[] data, int len) throws IOException {int dataLen = data.length;int off = 0;while(off < dataLen) {if(len >= dataLen) {out.write(data, off, dataLen);} else {out.write(data, off, len);}//刷新緩沖區(qū) out.flush();off += len;dataLen -= len;}}/*** 獲取SSLContext* @param trustFile * @param trustPasswd* @param keyFile* @param keyPasswd* @return* @throws NoSuchAlgorithmException * @throws KeyStoreException * @throws IOException * @throws CertificateException * @throws UnrecoverableKeyException * @throws KeyManagementException */public static SSLContext getSSLContext(FileInputStream trustFileInputStream, String trustPasswd,FileInputStream keyFileInputStream, String keyPasswd)throws NoSuchAlgorithmException, KeyStoreException,CertificateException, IOException, UnrecoverableKeyException,KeyManagementException {// caTrustManagerFactory tmf = TrustManagerFactory.getInstance(HttpClientUtil.SunX509);KeyStore trustKeyStore = KeyStore.getInstance(HttpClientUtil.JKS);trustKeyStore.load(trustFileInputStream, HttpClientUtil.str2CharArray(trustPasswd));tmf.init(trustKeyStore);final char[] kp = HttpClientUtil.str2CharArray(keyPasswd);KeyManagerFactory kmf = KeyManagerFactory.getInstance(HttpClientUtil.SunX509);KeyStore ks = KeyStore.getInstance(HttpClientUtil.PKCS12);ks.load(keyFileInputStream, kp);kmf.init(ks, kp);SecureRandom rand = new SecureRandom();SSLContext ctx = SSLContext.getInstance(HttpClientUtil.TLS);ctx.init(kmf.getKeyManagers(), tmf.getTrustManagers(), rand);return ctx;}/*** 獲取CA證書信息* @param cafile CA證書文件* @return Certificate* @throws CertificateException* @throws IOException*/public static Certificate getCertificate(File cafile)throws CertificateException, IOException {CertificateFactory cf = CertificateFactory.getInstance("X.509");FileInputStream in = new FileInputStream(cafile);Certificate cert = cf.generateCertificate(in);in.close();return cert;}/*** 字符串轉(zhuǎn)換成char數(shù)組* @param str* @return char[]*/public static char[] str2CharArray(String str) {if(null == str) return null;return str.toCharArray();}/*** 存儲(chǔ)ca證書成JKS格式* @param cert* @param alias* @param password* @param out* @throws KeyStoreException* @throws NoSuchAlgorithmException* @throws CertificateException* @throws IOException*/public static void storeCACert(Certificate cert, String alias,String password, OutputStream out) throws KeyStoreException,NoSuchAlgorithmException, CertificateException, IOException {KeyStore ks = KeyStore.getInstance("JKS");ks.load(null, null);ks.setCertificateEntry(alias, cert);// store keystore ks.store(out, HttpClientUtil.str2CharArray(password));}public static InputStream String2Inputstream(String str) {return new ByteArrayInputStream(str.getBytes());} } package com.founder.ec.common.utils;import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import java.security.KeyManagementException; import java.security.KeyStore; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; import java.security.SecureRandom; import java.security.UnrecoverableKeyException; import java.security.cert.Certificate; import java.security.cert.CertificateException; import java.security.cert.CertificateFactory; import java.util.HashMap; import java.util.Map;import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.KeyManagerFactory; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManagerFactory;import org.apache.commons.httpclient.DefaultHttpMethodRetryHandler; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpStatus; import org.apache.commons.httpclient.methods.GetMethod; import org.apache.commons.httpclient.params.HttpMethodParams; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory;public class HttpClientUtil {private static final Log logger = LogFactory.getLog(HttpClientUtil.class);public static byte[] doHttpClient(String url) {HttpClient c = new HttpClient();GetMethod getMethod = new GetMethod(url);try {getMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT,5000);getMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER,new DefaultHttpMethodRetryHandler());int statusCode = c.executeMethod(getMethod);if (statusCode != HttpStatus.SC_OK) {logger.error("doHttpClient Method failed: "+ getMethod.getStatusLine());}else{return getMethod.getResponseBody();}} catch (Exception e) {logger.error("doHttpClient errot : "+e.getMessage());} finally {getMethod.releaseConnection();}return null;}//財(cái)付通public static final String SunX509 = "SunX509";public static final String JKS = "JKS";public static final String PKCS12 = "PKCS12";public static final String TLS = "TLS";/*** get HttpURLConnection* @param strUrl url地址* @return HttpURLConnection* @throws IOException*/public static HttpURLConnection getHttpURLConnection(String strUrl)throws IOException {URL url = new URL(strUrl);HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();return httpURLConnection;}/*** get HttpsURLConnection* @param strUrl url地址* @return HttpsURLConnection* @throws IOException*/public static HttpsURLConnection getHttpsURLConnection(String strUrl)throws IOException {URL url = new URL(strUrl);HttpsURLConnection httpsURLConnection = (HttpsURLConnection) url.openConnection();return httpsURLConnection;}/*** 獲取不帶查詢串的url* @param strUrl* @return String*/public static String getURL(String strUrl) {if(null != strUrl) {int indexOf = strUrl.indexOf("?");if(-1 != indexOf) {return strUrl.substring(0, indexOf);} return strUrl;}return strUrl;}/*** 獲取查詢串* @param strUrl* @return String*/public static String getQueryString(String strUrl) {if(null != strUrl) {int indexOf = strUrl.indexOf("?");if(-1 != indexOf) {return strUrl.substring(indexOf+1, strUrl.length());} return "";}return strUrl;}/*** 查詢字符串轉(zhuǎn)換成Map<br/>* name1=key1&name2=key2&...* @param queryString* @return*/public static Map queryString2Map(String queryString) {if(null == queryString || "".equals(queryString)) {return null;}Map m = new HashMap();String[] strArray = queryString.split("&");for(int index = 0; index < strArray.length; index++) {String pair = strArray[index];HttpClientUtil.putMapByPair(pair, m);}return m;}/*** 把鍵值添加至Map<br/>* pair:name=value* @param pair name=value* @param m*/public static void putMapByPair(String pair, Map m) {if(null == pair || "".equals(pair)) {return;}int indexOf = pair.indexOf("=");if(-1 != indexOf) {String k = pair.substring(0, indexOf);String v = pair.substring(indexOf+1, pair.length());if(null != k && !"".equals(k)) {m.put(k, v);}} else {m.put(pair, "");}}/*** BufferedReader轉(zhuǎn)換成String<br/>* 注意:流關(guān)閉需要自行處理* @param reader* @return String* @throws IOException*/public static String bufferedReader2String(BufferedReader reader) throws IOException {StringBuffer buf = new StringBuffer();String line = null;while( (line = reader.readLine()) != null) {buf.append(line);buf.append("\r\n");}return buf.toString();}/*** 處理輸出<br/>* 注意:流關(guān)閉需要自行處理* @param out* @param data* @param len* @throws IOException*/public static void doOutput(OutputStream out, byte[] data, int len) throws IOException {int dataLen = data.length;int off = 0;while(off < dataLen) {if(len >= dataLen) {out.write(data, off, dataLen);} else {out.write(data, off, len);}//刷新緩沖區(qū) out.flush();off += len;dataLen -= len;}}/*** 獲取SSLContext* @param trustFile * @param trustPasswd* @param keyFile* @param keyPasswd* @return* @throws NoSuchAlgorithmException * @throws KeyStoreException * @throws IOException * @throws CertificateException * @throws UnrecoverableKeyException * @throws KeyManagementException */public static SSLContext getSSLContext(FileInputStream trustFileInputStream, String trustPasswd,FileInputStream keyFileInputStream, String keyPasswd)throws NoSuchAlgorithmException, KeyStoreException,CertificateException, IOException, UnrecoverableKeyException,KeyManagementException {// caTrustManagerFactory tmf = TrustManagerFactory.getInstance(HttpClientUtil.SunX509);KeyStore trustKeyStore = KeyStore.getInstance(HttpClientUtil.JKS);trustKeyStore.load(trustFileInputStream, HttpClientUtil.str2CharArray(trustPasswd));tmf.init(trustKeyStore);final char[] kp = HttpClientUtil.str2CharArray(keyPasswd);KeyManagerFactory kmf = KeyManagerFactory.getInstance(HttpClientUtil.SunX509);KeyStore ks = KeyStore.getInstance(HttpClientUtil.PKCS12);ks.load(keyFileInputStream, kp);kmf.init(ks, kp);SecureRandom rand = new SecureRandom();SSLContext ctx = SSLContext.getInstance(HttpClientUtil.TLS);ctx.init(kmf.getKeyManagers(), tmf.getTrustManagers(), rand);return ctx;}/*** 獲取CA證書信息* @param cafile CA證書文件* @return Certificate* @throws CertificateException* @throws IOException*/public static Certificate getCertificate(File cafile)throws CertificateException, IOException {CertificateFactory cf = CertificateFactory.getInstance("X.509");FileInputStream in = new FileInputStream(cafile);Certificate cert = cf.generateCertificate(in);in.close();return cert;}/*** 字符串轉(zhuǎn)換成char數(shù)組* @param str* @return char[]*/public static char[] str2CharArray(String str) {if(null == str) return null;return str.toCharArray();}/*** 存儲(chǔ)ca證書成JKS格式* @param cert* @param alias* @param password* @param out* @throws KeyStoreException* @throws NoSuchAlgorithmException* @throws CertificateException* @throws IOException*/public static void storeCACert(Certificate cert, String alias,String password, OutputStream out) throws KeyStoreException,NoSuchAlgorithmException, CertificateException, IOException {KeyStore ks = KeyStore.getInstance("JKS");ks.load(null, null);ks.setCertificateEntry(alias, cert);// store keystore ks.store(out, HttpClientUtil.str2CharArray(password));}public static InputStream String2Inputstream(String str) {return new ByteArrayInputStream(str.getBytes());} } package com.j1.website.util;import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.util.Map; import java.util.Set;import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; import org.apache.commons.httpclient.NameValuePair; import org.apache.commons.httpclient.methods.PostMethod;public class HttpClientUtil {/*** 發(fā)送HTTP請(qǐng)求* * @param url 接口地址* @param propsMap* 發(fā)送的參數(shù)*/public static String httpSend(String url, Map<String, Object> propsMap) {String responseMsg = "";HttpClient httpClient = new HttpClient();PostMethod postMethod = new PostMethod(url);// POST請(qǐng)求// 參數(shù)設(shè)置Set<String> keySet = propsMap.keySet();NameValuePair[] postData = new NameValuePair[keySet.size()];int index = 0;for (String key : keySet) {postData[index++] = new NameValuePair(key, propsMap.get(key).toString());}postMethod.addParameters(postData);try {httpClient.executeMethod(postMethod);// 發(fā)送請(qǐng)求// 讀取內(nèi)容BufferedReader reader = new BufferedReader(new InputStreamReader(postMethod.getResponseBodyAsStream()));// byte[] responseBody = postMethod.getResponseBody();// 處理返回的內(nèi)容// responseMsg = new String(responseBody);StringBuffer stringBuffer = new StringBuffer();String str;while ((str = reader.readLine()) != null) {stringBuffer.append(str);}responseMsg = stringBuffer.toString();} catch (HttpException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();} finally {postMethod.releaseConnection();// 關(guān)閉連接 }return responseMsg;} } package com.founder.ec.web.util.payments.weixin;import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import java.security.KeyManagementException; import java.security.KeyStore; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; import java.security.SecureRandom; import java.security.UnrecoverableKeyException; import java.security.cert.Certificate; import java.security.cert.CertificateException; import java.security.cert.CertificateFactory; import java.util.HashMap; import java.util.Map;import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.KeyManagerFactory; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManagerFactory;import org.apache.http.HttpEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpPost; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.SSLContexts; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients;/*** Http客戶端工具類<br/>* 這是內(nèi)部調(diào)用類，請(qǐng)不要在外部調(diào)用。* @author miklchen**/ public class HttpClientUtil {public static final String SunX509 = "SunX509";public static final String JKS = "JKS";public static final String PKCS12 = "PKCS12";public static final String TLS = "TLS";/*** get HttpURLConnection* @param strUrl url地址* @return HttpURLConnection* @throws IOException*/public static HttpURLConnection getHttpURLConnection(String strUrl)throws IOException {URL url = new URL(strUrl);HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();return httpURLConnection;}/*** get HttpsURLConnection* @param strUrl url地址* @return HttpsURLConnection* @throws IOException*/public static HttpsURLConnection getHttpsURLConnection(String strUrl)throws IOException {URL url = new URL(strUrl);HttpsURLConnection httpsURLConnection = (HttpsURLConnection) url.openConnection();return httpsURLConnection;}/*** 獲取不帶查詢串的url* @param strUrl* @return String*/public static String getURL(String strUrl) {if(null != strUrl) {int indexOf = strUrl.indexOf("?");if(-1 != indexOf) {return strUrl.substring(0, indexOf);} return strUrl;}return strUrl;}/*** 獲取查詢串* @param strUrl* @return String*/public static String getQueryString(String strUrl) {if(null != strUrl) {int indexOf = strUrl.indexOf("?");if(-1 != indexOf) {return strUrl.substring(indexOf+1, strUrl.length());} return "";}return strUrl;}/*** 查詢字符串轉(zhuǎn)換成Map<br/>* name1=key1&name2=key2&...* @param queryString* @return*/public static Map queryString2Map(String queryString) {if(null == queryString || "".equals(queryString)) {return null;}Map m = new HashMap();String[] strArray = queryString.split("&");for(int index = 0; index < strArray.length; index++) {String pair = strArray[index];HttpClientUtil.putMapByPair(pair, m);}return m;}/*** 把鍵值添加至Map<br/>* pair:name=value* @param pair name=value* @param m*/public static void putMapByPair(String pair, Map m) {if(null == pair || "".equals(pair)) {return;}int indexOf = pair.indexOf("=");if(-1 != indexOf) {String k = pair.substring(0, indexOf);String v = pair.substring(indexOf+1, pair.length());if(null != k && !"".equals(k)) {m.put(k, v);}} else {m.put(pair, "");}}/*** BufferedReader轉(zhuǎn)換成String<br/>* 注意:流關(guān)閉需要自行處理* @param reader* @return String* @throws IOException*/public static String bufferedReader2String(BufferedReader reader) throws IOException {StringBuffer buf = new StringBuffer();String line = null;while( (line = reader.readLine()) != null) {buf.append(line);buf.append("\r\n");}return buf.toString();}/*** 處理輸出<br/>* 注意:流關(guān)閉需要自行處理* @param out* @param data* @param len* @throws IOException*/public static void doOutput(OutputStream out, byte[] data, int len)throws IOException {int dataLen = data.length;int off = 0;while (off < data.length) {if (len >= dataLen) {out.write(data, off, dataLen);off += dataLen;} else {out.write(data, off, len);off += len;dataLen -= len;}// 刷新緩沖區(qū) out.flush();}}/*** 獲取SSLContext* @param trustFile * @param trustPasswd* @param keyFile* @param keyPasswd* @return* @throws NoSuchAlgorithmException * @throws KeyStoreException * @throws IOException * @throws CertificateException * @throws UnrecoverableKeyException * @throws KeyManagementException */public static SSLContext getSSLContext(FileInputStream trustFileInputStream, String trustPasswd,FileInputStream keyFileInputStream, String keyPasswd)throws NoSuchAlgorithmException, KeyStoreException,CertificateException, IOException, UnrecoverableKeyException,KeyManagementException {// caTrustManagerFactory tmf = TrustManagerFactory.getInstance(HttpClientUtil.SunX509);KeyStore trustKeyStore = KeyStore.getInstance(HttpClientUtil.JKS);trustKeyStore.load(trustFileInputStream, HttpClientUtil.str2CharArray(trustPasswd));tmf.init(trustKeyStore);final char[] kp = HttpClientUtil.str2CharArray(keyPasswd);KeyManagerFactory kmf = KeyManagerFactory.getInstance(HttpClientUtil.SunX509);KeyStore ks = KeyStore.getInstance(HttpClientUtil.PKCS12);ks.load(keyFileInputStream, kp);kmf.init(ks, kp);SecureRandom rand = new SecureRandom();SSLContext ctx = SSLContext.getInstance(HttpClientUtil.TLS);ctx.init(kmf.getKeyManagers(), tmf.getTrustManagers(), rand);return ctx;}/*** 獲取CA證書信息* @param cafile CA證書文件* @return Certificate* @throws CertificateException* @throws IOException*/public static Certificate getCertificate(File cafile)throws CertificateException, IOException {CertificateFactory cf = CertificateFactory.getInstance("X.509");FileInputStream in = new FileInputStream(cafile);Certificate cert = cf.generateCertificate(in);in.close();return cert;}/*** 字符串轉(zhuǎn)換成char數(shù)組* @param str* @return char[]*/public static char[] str2CharArray(String str) {if(null == str) return null;return str.toCharArray();}/*** 存儲(chǔ)ca證書成JKS格式* @param cert* @param alias* @param password* @param out* @throws KeyStoreException* @throws NoSuchAlgorithmException* @throws CertificateException* @throws IOException*/public static void storeCACert(Certificate cert, String alias,String password, OutputStream out) throws KeyStoreException,NoSuchAlgorithmException, CertificateException, IOException {KeyStore ks = KeyStore.getInstance("JKS");ks.load(null, null);ks.setCertificateEntry(alias, cert);// store keystore ks.store(out, HttpClientUtil.str2CharArray(password));}public static InputStream String2Inputstream(String str) {return new ByteArrayInputStream(str.getBytes());}/*** InputStream轉(zhuǎn)換成Byte* 注意:流關(guān)閉需要自行處理* @param in* @return byte* @throws Exception*/public static byte[] InputStreamTOByte(InputStream in) throws IOException{ int BUFFER_SIZE = 4096; ByteArrayOutputStream outStream = new ByteArrayOutputStream(); byte[] data = new byte[BUFFER_SIZE]; int count = -1; while((count = in.read(data,0,BUFFER_SIZE)) != -1) outStream.write(data, 0, count); data = null; byte[] outByte = outStream.toByteArray();outStream.close();return outByte; } /*** InputStream轉(zhuǎn)換成String* 注意:流關(guān)閉需要自行處理* @param in* @param encoding 編碼* @return String* @throws Exception*/public static String InputStreamTOString(InputStream in,String encoding) throws IOException{ return new String(InputStreamTOByte(in),encoding);}/*** 微信退款http請(qǐng)求* * @param certFilePath* @param password* @param orderRefundUrl* @param packageXml* @return* @throws Exception*/public static String refund4WxHttpClient(String certFilePath, String password, String orderRefundUrl, StringBuffer packageXml) throws Exception{StringBuffer retXmlContent = new StringBuffer();//獲取商戶證書KeyStore keyStore = KeyStore.getInstance("PKCS12");FileInputStream instream = new FileInputStream(new File(certFilePath));try {keyStore.load(instream, password.toCharArray());} finally {instream.close();}// Trust own CA and all self-signed certsSSLContext sslcontext = SSLContexts.custom().loadKeyMaterial(keyStore, password.toCharArray()).build();// Allow TLSv1 protocol onlySSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext,new String[] { "TLSv1" },null,SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);CloseableHttpClient httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).build();try {HttpPost httppost = new HttpPost(orderRefundUrl);StringEntity myEntity = new StringEntity(packageXml.toString(), "UTF-8"); httppost.setEntity(myEntity);CloseableHttpResponse response = httpclient.execute(httppost);try {HttpEntity entity = response.getEntity();if (entity != null) {BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(entity.getContent(), "utf-8"));String text;while ((text = bufferedReader.readLine()) != null) {retXmlContent.append(text);}} // EntityUtils.consume(entity);} finally {response.close();}} finally {httpclient.close();}return retXmlContent.toString();} } package com.founder.ec.web.util.payments.weixin.client;import com.founder.ec.web.util.payments.weixin.HttpClientUtil;import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLSocketFactory; import java.io.*; import java.net.HttpURLConnection; import java.security.KeyManagementException; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; import java.security.UnrecoverableKeyException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate;/*** 財(cái)付通http或者h(yuǎn)ttps網(wǎng)絡(luò)通信客戶端<br/>* ========================================================================<br/>* api說明：<br/>* setReqContent($reqContent),設(shè)置請(qǐng)求內(nèi)容，無論post和get，都用get方式提供<br/>* getResContent(), 獲取應(yīng)答內(nèi)容<br/>* setMethod(method),設(shè)置請(qǐng)求方法,post或者get<br/>* getErrInfo(),獲取錯(cuò)誤信息<br/>* setCertInfo(certFile, certPasswd),設(shè)置證書，雙向https時(shí)需要使用<br/>* setCaInfo(caFile), 設(shè)置CA，格式未pem，不設(shè)置則不檢查<br/>* setTimeOut(timeOut)， 設(shè)置超時(shí)時(shí)間，單位秒<br/>* getResponseCode(), 取返回的http狀態(tài)碼<br/>* call(),真正調(diào)用接口<br/>* getCharset()/setCharset(),字符集編碼<br/>* * ========================================================================<br/>**/ public class TenpayHttpClient {private static final String USER_AGENT_VALUE = "Mozilla/4.0 (compatible; MSIE 6.0; Windows XP)";private static final String JKS_CA_FILENAME = "tenpay_cacert.jks";private static final String JKS_CA_ALIAS = "tenpay";private static final String JKS_CA_PASSWORD = "1222075301";/** ca證書文件 */private File caFile;/** 證書文件 */private File certFile;/** 證書密碼 */private String certPasswd;/** 請(qǐng)求內(nèi)容，無論post和get，都用get方式提供 */private String reqContent;/** 應(yīng)答內(nèi)容 */private String resContent;/** 請(qǐng)求方法 */private String method;/** 錯(cuò)誤信息 */private String errInfo;/** 超時(shí)時(shí)間,以秒為單位 */private int timeOut;/** http應(yīng)答編碼 */private int responseCode;/** 字符編碼 */private String charset;private InputStream inputStream;public TenpayHttpClient() {this.caFile = null;this.certFile = null;this.certPasswd = "";this.reqContent = "";this.resContent = "";this.method = "POST";this.errInfo = "";this.timeOut = 30;//30秒this.responseCode = 0;this.charset = "GBK";this.inputStream = null;}/*** 設(shè)置證書信息* @param certFile 證書文件* @param certPasswd 證書密碼*/public void setCertInfo(File certFile, String certPasswd) {this.certFile = certFile;this.certPasswd = certPasswd;}/*** 設(shè)置ca* @param caFile*/public void setCaInfo(File caFile) {this.caFile = caFile;}/*** 設(shè)置請(qǐng)求內(nèi)容* @param reqContent 表求內(nèi)容*/public void setReqContent(String reqContent) {this.reqContent = reqContent;}/*** 獲取結(jié)果內(nèi)容* @return String* @throws IOException */public String getResContent() {try {this.doResponse();} catch (IOException e) {this.errInfo = e.getMessage();//return ""; }return this.resContent;}/*** 設(shè)置請(qǐng)求方法post或者get* @param method 請(qǐng)求方法post/get*/public void setMethod(String method) {this.method = method;}/*** 獲取錯(cuò)誤信息* @return String*/public String getErrInfo() {return this.errInfo;}/*** 設(shè)置超時(shí)時(shí)間,以秒為單位* @param timeOut 超時(shí)時(shí)間,以秒為單位*/public void setTimeOut(int timeOut) {this.timeOut = timeOut;}/*** 獲取http狀態(tài)碼* @return int*/public int getResponseCode() {return this.responseCode;}/*** 執(zhí)行http調(diào)用。true:成功 false:失敗* @return boolean*/public boolean call() {boolean isRet = false;//httpif(null == this.caFile && null == this.certFile) {try {this.callHttp();isRet = true;} catch (IOException e) {this.errInfo = e.getMessage();}return isRet;}//httpstry {this.callHttps();isRet = true;} catch (UnrecoverableKeyException e) {this.errInfo = e.getMessage();} catch (KeyManagementException e) {this.errInfo = e.getMessage();} catch (CertificateException e) {this.errInfo = e.getMessage();} catch (KeyStoreException e) {this.errInfo = e.getMessage();} catch (NoSuchAlgorithmException e) {this.errInfo = e.getMessage();} catch (IOException e) {this.errInfo = e.getMessage();}return isRet;}protected void callHttp() throws IOException {if("POST".equals(this.method.toUpperCase())) {String url = HttpClientUtil.getURL(this.reqContent);String queryString = HttpClientUtil.getQueryString(this.reqContent);byte[] postData = queryString.getBytes(this.charset);this.httpPostMethod(url, postData);return ;}this.httpGetMethod(this.reqContent);} protected void callHttps() throws IOException, CertificateException,KeyStoreException, NoSuchAlgorithmException,UnrecoverableKeyException, KeyManagementException {// ca目錄String caPath = this.caFile.getParent();File jksCAFile = new File(caPath + "/"+ TenpayHttpClient.JKS_CA_FILENAME);if (!jksCAFile.isFile()) {X509Certificate cert = (X509Certificate) HttpClientUtil.getCertificate(this.caFile);FileOutputStream out = new FileOutputStream(jksCAFile);// store jks file HttpClientUtil.storeCACert(cert, TenpayHttpClient.JKS_CA_ALIAS,TenpayHttpClient.JKS_CA_PASSWORD, out);out.close();}FileInputStream trustStream = new FileInputStream(jksCAFile);FileInputStream keyStream = new FileInputStream(this.certFile);SSLContext sslContext = HttpClientUtil.getSSLContext(trustStream,TenpayHttpClient.JKS_CA_PASSWORD, keyStream, this.certPasswd);//關(guān)閉流 keyStream.close();trustStream.close();if("POST".equals(this.method.toUpperCase())) {String url = HttpClientUtil.getURL(this.reqContent);String queryString = HttpClientUtil.getQueryString(this.reqContent);byte[] postData = queryString.getBytes(this.charset);this.httpsPostMethod(url, postData, sslContext);return ;}this.httpsGetMethod(this.reqContent, sslContext);}public boolean callHttpPost(String url, String postdata) {boolean flag = false;byte[] postData;try {postData = postdata.getBytes(this.charset);this.httpPostMethod(url, postData);flag = true;} catch (IOException e1) {e1.printStackTrace();}return flag;}/*** 以http post方式通信* @param url* @param postData* @throws IOException*/protected void httpPostMethod(String url, byte[] postData)throws IOException {HttpURLConnection conn = HttpClientUtil.getHttpURLConnection(url);this.doPost(conn, postData);}/*** 以http get方式通信* * @param url* @throws IOException*/protected void httpGetMethod(String url) throws IOException {HttpURLConnection httpConnection =HttpClientUtil.getHttpURLConnection(url);this.setHttpRequest(httpConnection);httpConnection.setRequestMethod("GET");this.responseCode = httpConnection.getResponseCode();this.inputStream = httpConnection.getInputStream();}/*** 以https get方式通信* @param url* @param sslContext* @throws IOException*/protected void httpsGetMethod(String url, SSLContext sslContext)throws IOException {SSLSocketFactory sf = sslContext.getSocketFactory();HttpsURLConnection conn = HttpClientUtil.getHttpsURLConnection(url);conn.setSSLSocketFactory(sf);this.doGet(conn);}protected void httpsPostMethod(String url, byte[] postData,SSLContext sslContext) throws IOException {SSLSocketFactory sf = sslContext.getSocketFactory();HttpsURLConnection conn = HttpClientUtil.getHttpsURLConnection(url);conn.setSSLSocketFactory(sf);this.doPost(conn, postData);}/*** 設(shè)置http請(qǐng)求默認(rèn)屬性* @param httpConnection*/protected void setHttpRequest(HttpURLConnection httpConnection) {//設(shè)置連接超時(shí)時(shí)間httpConnection.setConnectTimeout(this.timeOut * 1000);//User-AgenthttpConnection.setRequestProperty("User-Agent", TenpayHttpClient.USER_AGENT_VALUE);//不使用緩存httpConnection.setUseCaches(false);//允許輸入輸出httpConnection.setDoInput(true);httpConnection.setDoOutput(true);}/*** 處理應(yīng)答* @throws IOException*/protected void doResponse() throws IOException {if(null == this.inputStream) {return;}//獲取應(yīng)答內(nèi)容this.resContent=HttpClientUtil.InputStreamTOString(this.inputStream,this.charset); //關(guān)閉輸入流this.inputStream.close();}/*** post方式處理* @param conn* @param postData* @throws IOException*/protected void doPost(HttpURLConnection conn, byte[] postData)throws IOException {// 以post方式通信conn.setRequestMethod("POST");// 設(shè)置請(qǐng)求默認(rèn)屬性this.setHttpRequest(conn);// Content-Typeconn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");BufferedOutputStream out = new BufferedOutputStream(conn.getOutputStream());final int len = 1024; // 1KB HttpClientUtil.doOutput(out, postData, len);// 關(guān)閉流 out.close();// 獲取響應(yīng)返回狀態(tài)碼this.responseCode = conn.getResponseCode();// 獲取應(yīng)答輸入流this.inputStream = conn.getInputStream();}/*** get方式處理* @param conn* @throws IOException*/protected void doGet(HttpURLConnection conn) throws IOException {//以GET方式通信conn.setRequestMethod("GET");//設(shè)置請(qǐng)求默認(rèn)屬性this.setHttpRequest(conn);//獲取響應(yīng)返回狀態(tài)碼this.responseCode = conn.getResponseCode();//獲取應(yīng)答輸入流this.inputStream = conn.getInputStream();}}?
總結(jié)
- 上一篇： 关于Vista的AppInfo服务被禁的
- 下一篇： css字体自定义，bootstrap自定