package ${basePackage}.frame.utils; import javax.net.ssl.*; import java.io.*; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLDecoder; import java.net.URLEncoder; import java.security.SecureRandom; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.HashMap; import java.util.Map; import java.util.Set; /** * WebUtils - 模拟http访问工具类 * * @author wangbing * @version 0.0.1 * @since 2017-01-01 */ public class WebUtils { private static final String DEFAULT_CHARSET = "UTF-8"; private static final String METHOD_POST = "POST"; private static final String METHOD_GET = "GET"; //private static final Certificate verisign; // private static boolean ignoreSSLCheck; // 忽略SSL检查 private static class TrustAllTrustManager implements X509TrustManager { public X509Certificate[] getAcceptedIssuers() { return null; } public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { } public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { } } private WebUtils() { } public static void setIgnoreSSLCheck(boolean ignoreSSLCheck) { WebUtils.ignoreSSLCheck = ignoreSSLCheck; } /** * 执行HTTP POST请求。 * * @param url 请求地址 * @param params 请求参数 * @return 响应字符串 */ public static String doPost(String url, Map params, int connectTimeout, int readTimeout) throws IOException { return doPost(url, params, DEFAULT_CHARSET, connectTimeout, readTimeout); } /** * 执行HTTP POST请求。 * * @param url 请求地址 * @param params 请求参数 * @param charset 字符集,如UTF-8, GBK, GB2312 * @return 响应字符串 */ public static String doPost(String url, Map params, String charset, int connectTimeout, int readTimeout) throws IOException { return doPost(url, params, charset, connectTimeout, readTimeout, null); } public static String doPost(String url, Map params, String charset, int connectTimeout, int readTimeout, Map headerMap) throws IOException { String ctype = "application/x-www-form-urlencoded;charset=" + charset; String query = buildQuery(params, charset); byte[] content = {}; if (query != null) { content = query.getBytes(charset); } return _doPost(url, ctype, content, connectTimeout, readTimeout, headerMap); } /** * 执行HTTP POST请求。 * * @param url 请求地址 * @param ctype 请求类型 * @param content 请求字节数组 * @return 响应字符串 */ public static String doPost(String url, String ctype, byte[] content, int connectTimeout, int readTimeout) throws IOException { return _doPost(url, ctype, content, connectTimeout, readTimeout, null); } private static String _doPost(String url, String ctype, byte[] content, int connectTimeout, int readTimeout, Map headerMap) throws IOException { HttpURLConnection conn = null; OutputStream out = null; String rsp = null; try { try { conn = getConnection(new URL(url), METHOD_POST, ctype, headerMap); conn.setConnectTimeout(connectTimeout); conn.setReadTimeout(readTimeout); } catch (IOException e) { throw e; } try { out = conn.getOutputStream(); out.write(content); rsp = getResponseAsString(conn); } catch (IOException e) { throw e; } } finally { if (out != null) { out.close(); } if (conn != null) { conn.disconnect(); } } return rsp; } private static byte[] getTextEntry(String fieldName, String fieldValue, String charset) throws IOException { StringBuilder entry = new StringBuilder(); entry.append("Content-Disposition:form-data;name=\""); entry.append(fieldName); entry.append("\"\r\nContent-Type:text/plain\r\n\r\n"); entry.append(fieldValue); return entry.toString().getBytes(charset); } private static byte[] getFileEntry(String fieldName, String fileName, String mimeType, String charset) throws IOException { StringBuilder entry = new StringBuilder(); entry.append("Content-Disposition:form-data;name=\""); entry.append(fieldName); entry.append("\";filename=\""); entry.append(fileName); entry.append("\"\r\nContent-Type:"); entry.append(mimeType); entry.append("\r\n\r\n"); return entry.toString().getBytes(charset); } /** * 执行HTTP GET请求。 * * @param url 请求地址 * @param params 请求参数 * @return 响应字符串 */ public static String doGet(String url, Map params) throws IOException { return doGet(url, params, DEFAULT_CHARSET); } /** * 执行HTTP GET请求。 * * @param url 请求地址 * @param params 请求参数 * @param charset 字符集,如UTF-8, GBK, GB2312 * @return 响应字符串 */ public static String doGet(String url, Map params, String charset) throws IOException { HttpURLConnection conn = null; String rsp = null; try { String ctype = "application/x-www-form-urlencoded;charset=" + charset; String query = buildQuery(params, charset); try { conn = getConnection(buildGetUrl(url, query), METHOD_GET, ctype, null); } catch (IOException e) { throw e; } try { rsp = getResponseAsString(conn); } catch (IOException e) { throw e; } } finally { if (conn != null) { conn.disconnect(); } } return rsp; } private static HttpURLConnection getConnection(URL url, String method, String ctype, Map headerMap) throws IOException { HttpURLConnection conn = (HttpURLConnection) url.openConnection(); if (conn instanceof HttpsURLConnection) { HttpsURLConnection connHttps = (HttpsURLConnection) conn; if (ignoreSSLCheck) { try { SSLContext ctx = SSLContext.getInstance("TLS"); ctx.init(null, new TrustManager[]{new TrustAllTrustManager()}, new SecureRandom()); connHttps.setSSLSocketFactory(ctx.getSocketFactory()); connHttps.setHostnameVerifier(new HostnameVerifier() { public boolean verify(String hostname, SSLSession session) { return true; } }); } catch (Exception e) { throw new IOException(e); } } else { try { //SSLContext ctx = SSLContext.getInstance("TLS"); //ctx.init(null, new TrustManager[] { new VerisignTrustManager() }, new SecureRandom()); //connHttps.setSSLSocketFactory(ctx.getSocketFactory()); } catch (Exception e) { throw new IOException(e); } } conn = connHttps; } conn.setRequestMethod(method); conn.setDoInput(true); conn.setDoOutput(true); conn.setRequestProperty("Accept", "text/xml,text/javascript"); conn.setRequestProperty("User-Agent", "top-sdk-java"); conn.setRequestProperty("Content-Type", ctype); if (headerMap != null) { for (Map.Entry entry : headerMap.entrySet()) { conn.setRequestProperty(entry.getKey(), entry.getValue()); } } return conn; } private static URL buildGetUrl(String strUrl, String query) throws IOException { URL url = new URL(strUrl); if (isEmpty(query)) { return url; } if (isEmpty(url.getQuery())) { if (strUrl.endsWith("?")) { strUrl = strUrl + query; } else { strUrl = strUrl + "?" + query; } } else { if (strUrl.endsWith("&")) { strUrl = strUrl + query; } else { strUrl = strUrl + "&" + query; } } return new URL(strUrl); } public static String buildQuery(Map params, String charset) throws IOException { if (params == null || params.isEmpty()) { return null; } StringBuilder query = new StringBuilder(); Set> entries = params.entrySet(); boolean hasParam = false; for (Map.Entry entry : entries) { String name = entry.getKey(); String value = entry.getValue(); // 忽略参数名或参数值为空的参数 if (areNotEmpty(name, value)) { if (hasParam) { query.append("&"); } else { hasParam = true; } query.append(name).append("=").append(URLEncoder.encode(value, charset)); } } return query.toString(); } public static boolean isEmpty(String value) { int strLen; if (value == null || (strLen = value.length()) == 0) { return true; } for (int i = 0; i < strLen; i++) { if ((Character.isWhitespace(value.charAt(i)) == false)) { return false; } } return true; } /** * 检查指定的字符串列表是否不为空。 */ public static boolean areNotEmpty(String... values) { boolean result = true; if (values == null || values.length == 0) { result = false; } else { for (String value : values) { result &= !isEmpty(value); } } return result; } protected static String getResponseAsString(HttpURLConnection conn) throws IOException { String charset = getResponseCharset(conn.getContentType()); InputStream es = conn.getErrorStream(); if (es == null) { return getStreamAsString(conn.getInputStream(), charset); } else { String msg = getStreamAsString(es, charset); if (isEmpty(msg)) { throw new IOException(conn.getResponseCode() + ":" + conn.getResponseMessage()); } else { throw new IOException(msg); } } } private static String getStreamAsString(InputStream stream, String charset) throws IOException { try { Reader reader = new InputStreamReader(stream, charset); StringBuilder response = new StringBuilder(); final char[] buff = new char[1024]; int read = 0; while ((read = reader.read(buff)) > 0) { response.append(buff, 0, read); } return response.toString(); } finally { if (stream != null) { stream.close(); } } } private static String getResponseCharset(String ctype) { String charset = DEFAULT_CHARSET; if (!isEmpty(ctype)) { String[] params = ctype.split(";"); for (String param : params) { param = param.trim(); if (param.startsWith("charset")) { String[] pair = param.split("=", 2); if (pair.length == 2) { if (!isEmpty(pair[1])) { charset = pair[1].trim(); } } break; } } } return charset; } /** * 使用默认的UTF-8字符集反编码请求参数值。 * * @param value 参数值 * @return 反编码后的参数值 */ public static String decode(String value) { return decode(value, DEFAULT_CHARSET); } /** * 使用默认的UTF-8字符集编码请求参数值。 * * @param value 参数值 * @return 编码后的参数值 */ public static String encode(String value) { return encode(value, DEFAULT_CHARSET); } /** * 使用指定的字符集反编码请求参数值。 * * @param value 参数值 * @param charset 字符集 * @return 反编码后的参数值 */ public static String decode(String value, String charset) { String result = null; if (!isEmpty(value)) { try { result = URLDecoder.decode(value, charset); } catch (IOException e) { throw new RuntimeException(e); } } return result; } /** * 使用指定的字符集编码请求参数值。 * * @param value 参数值 * @param charset 字符集 * @return 编码后的参数值 */ public static String encode(String value, String charset) { String result = null; if (!isEmpty(value)) { try { result = URLEncoder.encode(value, charset); } catch (IOException e) { throw new RuntimeException(e); } } return result; } private static Map getParamsFromUrl(String url) { Map map = null; if (url != null && url.indexOf('?') != -1) { map = splitUrlQuery(url.substring(url.indexOf('?') + 1)); } if (map == null) { map = new HashMap(); } return map; } /** * 从URL中提取所有的参数。 * * @param query URL地址 * @return 参数映射 */ public static Map splitUrlQuery(String query) { Map result = new HashMap(); String[] pairs = query.split("&"); if (pairs != null && pairs.length > 0) { for (String pair : pairs) { String[] param = pair.split("=", 2); if (param != null && param.length == 2) { result.put(param[0], param[1]); } } } return result; } }