欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

http,https请求工具类包含

程序员文章站 2024-02-08 10:56:10
...
package util;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.StringWriter;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.Proxy;
import java.net.Proxy.Type;
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.Map.Entry;
import java.util.Set;

import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.KeyManager;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

import com.alipay.api.AlipayConstants;
import com.alipay.api.FileItem;
import com.alipay.api.internal.util.AlipayLogger;
import com.alipay.api.internal.util.RequestParametersHolder;
import com.alipay.api.internal.util.StringUtils;

/**
 * 网络工具类。
 * 
 * @author carver.gu
 * @since 1.0, Sep 12, 2009
 */
public abstract class WebUtils {

    private static final String     DEFAULT_CHARSET = AlipayConstants.CHARSET_UTF8;
    private static final String     METHOD_POST     = "POST";
    private static final String     METHOD_GET      = "GET";

    private static SSLContext       ctx             = null;

    private static HostnameVerifier verifier        = null;

    private static SSLSocketFactory socketFactory   = null;

    private static class DefaultTrustManager 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 {
        }
    }

    static {

        try {
            ctx = SSLContext.getInstance("TLS");
            ctx.init(new KeyManager[0], new TrustManager[] { new DefaultTrustManager() },
                new SecureRandom());

            ctx.getClientSessionContext().setSessionTimeout(15);
            ctx.getClientSessionContext().setSessionCacheSize(1000);

            socketFactory = ctx.getSocketFactory();
        } catch (Exception e) {

        }

        verifier = new HostnameVerifier() {
            public boolean verify(String hostname, SSLSession session) {
                return false;//默认认证不通过,进行证书校验。
            }
        };

    }

    private WebUtils() {
    }

    /**
     * 执行HTTP POST请求,可使用代理proxy。
     * 
     * @param url 请求地址
     * @param params 请求参数
     * @param charset 字符集,如UTF-8, GBK, GB2312
     * @param connectTimeout 连接超时时间
     * @param readTimeout 请求超时时间
     * @param proxyHost 代理host,传null表示不使用代理
     * @param proxyPort 代理端口,传0表示不使用代理
     * @return 响应字符串
     * @throws IOException
     */
    public static String doPost(String url, Map<String, String> params, String charset,
                                int connectTimeout, int readTimeout, String proxyHost,
                                int proxyPort) 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, proxyHost, proxyPort);
    }

    /**
     * 执行HTTP POST请求。
     * 
     * @param url 请求地址
     * @param ctype 请求类型
     * @param content 请求字节数组
     * @param connectTimeout 连接超时时间
     * @param readTimeout 请求超时时间
     * @param proxyHost 代理host,传null表示不使用代理
     * @param proxyPort 代理端口,传0表示不使用代理
     * @return 响应字符串
     * @throws IOException
     */
    public static String doPost(String url, String ctype, byte[] content, int connectTimeout,
                                int readTimeout, String proxyHost, int proxyPort) throws IOException {
        HttpURLConnection conn = null;
        OutputStream out = null;
        String rsp = null;
        try {
            try {
                conn = null;
                if (!StringUtils.isEmpty(proxyHost)) {
                    conn = getConnection(new URL(url), METHOD_POST, ctype, proxyHost, proxyPort);
                } else {
                    conn = getConnection(new URL(url), METHOD_POST, ctype);
                }
                conn.setConnectTimeout(connectTimeout);
                conn.setReadTimeout(readTimeout);
            } catch (IOException e) {
                Map<String, String> map = getParamsFromUrl(url);
                AlipayLogger.logCommError(e, url, map.get("app_key"), map.get("method"), content);
                throw e;
            }
            try {
                out = conn.getOutputStream();
                out.write(content);
                rsp = getResponseAsString(conn);
            } catch (IOException e) {
                Map<String, String> map = getParamsFromUrl(url);
                AlipayLogger.logCommError(e, conn, map.get("app_key"), map.get("method"), content);
                throw e;
            }

        } finally {
            if (out != null) {
                out.close();
            }
            if (conn != null) {
                conn.disconnect();

            }
        }

        return rsp;
    }

    /**
     * 执行带文件上传的HTTP POST请求。
     * 
     * @param url 请求地址
     * @param params 文本请求参数
     * @param fileParams 文件请求参数
     * @param charset 字符集,如UTF-8, GBK, GB2312
     * @param connectTimeout 连接超时时间
     * @param readTimeout 请求超时时间
     * @param proxyHost 代理host,传null表示不使用代理
     * @param proxyPort 代理端口,传0表示不使用代理
     * @return 响应字符串
     * @throws IOException
     */
    public static String doPost(String url, Map<String, String> params,
                                Map<String, FileItem> fileParams, String charset,
                                int connectTimeout, int readTimeout, String proxyHost,
                                int proxyPort) throws IOException {
        if (fileParams == null || fileParams.isEmpty()) {
            return doPost(url, params, charset, connectTimeout, readTimeout, proxyHost, proxyPort);
        }

        String boundary = System.currentTimeMillis() + ""; // 随机分隔线
        HttpURLConnection conn = null;
        OutputStream out = null;
        String rsp = null;
        try {
            try {
                String ctype = "multipart/form-data;boundary=" + boundary + ";charset=" + charset;
                conn = null;
                if (!StringUtils.isEmpty(proxyHost)) {
                    conn = getConnection(new URL(url), METHOD_POST, ctype, proxyHost, proxyPort);
                } else {
                    conn = getConnection(new URL(url), METHOD_POST, ctype);
                }
                conn.setConnectTimeout(connectTimeout);
                conn.setReadTimeout(readTimeout);
            } catch (IOException e) {
                Map<String, String> map = getParamsFromUrl(url);
                AlipayLogger.logCommError(e, url, map.get("app_key"), map.get("method"), params);
                throw e;
            }

            try {
                out = conn.getOutputStream();

                byte[] entryBoundaryBytes = ("\r\n--" + boundary + "\r\n").getBytes(charset);

                // 组装文本请求参数
                Set<Entry<String, String>> textEntrySet = params.entrySet();
                for (Entry<String, String> textEntry : textEntrySet) {
                    byte[] textBytes = getTextEntry(textEntry.getKey(), textEntry.getValue(),
                        charset);
                    out.write(entryBoundaryBytes);
                    out.write(textBytes);
                }

                // 组装文件请求参数
                Set<Entry<String, FileItem>> fileEntrySet = fileParams.entrySet();
                for (Entry<String, FileItem> fileEntry : fileEntrySet) {
                    FileItem fileItem = fileEntry.getValue();
                    byte[] fileBytes = getFileEntry(fileEntry.getKey(), fileItem.getFileName(),
                        fileItem.getMimeType(), charset);
                    out.write(entryBoundaryBytes);
                    out.write(fileBytes);
                    out.write(fileItem.getContent());
                }

                // 添加请求结束标志
                byte[] endBoundaryBytes = ("\r\n--" + boundary + "--\r\n").getBytes(charset);
                out.write(endBoundaryBytes);
                rsp = getResponseAsString(conn);
            } catch (IOException e) {
                Map<String, String> map = getParamsFromUrl(url);
                AlipayLogger.logCommError(e, conn, map.get("app_key"), map.get("method"), params);
                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 响应字符串
     * @throws IOException
     */
    public static String doGet(String url, Map<String, String> params) throws IOException {
        return doGet(url, params, DEFAULT_CHARSET);
    }

    /**
     * 执行HTTP GET请求。
     * 
     * @param url 请求地址
     * @param params 请求参数
     * @param charset 字符集,如UTF-8, GBK, GB2312
     * @return 响应字符串
     * @throws IOException
     */
    public static String doGet(String url, Map<String, String> 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);
            } catch (IOException e) {
                Map<String, String> map = getParamsFromUrl(url);
                AlipayLogger.logCommError(e, url, map.get("app_key"), map.get("method"), params);
                throw e;
            }

            try {
                rsp = getResponseAsString(conn);
            } catch (IOException e) {
                Map<String, String> map = getParamsFromUrl(url);
                AlipayLogger.logCommError(e, conn, map.get("app_key"), map.get("method"), params);
                throw e;
            }

        } finally {
            if (conn != null) {
                conn.disconnect();
            }
        }

        return rsp;
    }

    private static HttpURLConnection getConnection(URL url, String method, String ctype) throws IOException {
        return getConnection(url, method, ctype, null);
    }

    private static HttpURLConnection getConnection(URL url, String method, String ctype,
                                                   String proxyHost, int proxyPort) throws IOException {
        Proxy proxy = new Proxy(Type.HTTP, new InetSocketAddress(proxyHost, proxyPort));
        return getConnection(url, method, ctype, proxy);
    }

    private static HttpURLConnection getConnection(URL url, String method, String ctype, Proxy proxy) throws IOException {
        HttpURLConnection conn = null;
        if ("https".equals(url.getProtocol())) {
            HttpsURLConnection connHttps = null;
            if (proxy != null) {
                connHttps = (HttpsURLConnection) url.openConnection(proxy);
            } else {
                connHttps = (HttpsURLConnection) url.openConnection();
            }
            connHttps.setSSLSocketFactory(socketFactory);
            connHttps.setHostnameVerifier(verifier);
            conn = connHttps;
        } else {
            conn = null;
            if (proxy != null) {
                conn = (HttpURLConnection) url.openConnection(proxy);
            } else {
                conn = (HttpURLConnection) url.openConnection();
            }
        }

        conn.setRequestMethod(method);
        conn.setDoInput(true);
        conn.setDoOutput(true);
        conn.setRequestProperty("Accept", "text/xml,text/javascript,text/html");
        conn.setRequestProperty("User-Agent", "aop-sdk-java");
        conn.setRequestProperty("Content-Type", ctype);
        return conn;
    }

    private static URL buildGetUrl(String strUrl, String query) throws IOException {
        URL url = new URL(strUrl);
        if (StringUtils.isEmpty(query)) {
            return url;
        }

        if (StringUtils.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<String, String> params, String charset) throws IOException {
        if (params == null || params.isEmpty()) {
            return null;
        }

        StringBuilder query = new StringBuilder();
        Set<Entry<String, String>> entries = params.entrySet();
        boolean hasParam = false;

        for (Entry<String, String> entry : entries) {
            String name = entry.getKey();
            String value = entry.getValue();
            // 忽略参数名或参数值为空的参数
            if (StringUtils.areNotEmpty(name, value)) {
                if (hasParam) {
                    query.append("&");
                } else {
                    hasParam = true;
                }

                query.append(name).append("=").append(URLEncoder.encode(value, charset));
            }
        }

        return query.toString();
    }

    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 (StringUtils.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 {
            BufferedReader reader = new BufferedReader(new InputStreamReader(stream, charset));
            StringWriter writer = new StringWriter();

            char[] chars = new char[256];
            int count = 0;
            while ((count = reader.read(chars)) > 0) {
                writer.write(chars, 0, count);
            }

            return writer.toString();
        } finally {
            if (stream != null) {
                stream.close();
            }
        }
    }

    private static String getResponseCharset(String ctype) {
        String charset = DEFAULT_CHARSET;

        if (!StringUtils.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 (!StringUtils.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 (!StringUtils.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 (!StringUtils.isEmpty(value)) {
            try {
                result = URLEncoder.encode(value, charset);
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }
        return result;
    }

    private static Map<String, String> getParamsFromUrl(String url) {
        Map<String, String> map = null;
        if (url != null && url.indexOf('?') != -1) {
            map = splitUrlQuery(url.substring(url.indexOf('?') + 1));
        }
        if (map == null) {
            map = new HashMap<String, String>();
        }
        return map;
    }

    /**
     * 从URL中提取所有的参数。
     * 
     * @param query URL地址
     * @return 参数映射
     */
    public static Map<String, String> splitUrlQuery(String query) {
        Map<String, String> result = new HashMap<String, String>();

        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;
    }

    public String buildForm(String baseUrl, RequestParametersHolder requestHolder) {
        return null;
    }

    public static String buildForm(String baseUrl, Map<String, String> parameters) {
        java.lang.StringBuffer sb = new StringBuffer();
        sb.append("<form name=\"punchout_form\" method=\"post\" action=\"");
        sb.append(baseUrl);
        sb.append("\">\n");
        sb.append(buildHiddenFields(parameters));

        sb.append("<input type=\"submit\" value=\"立即支付\" style=\"display:none\" >\n");
        sb.append("</form>\n");
        sb.append("<script>document.forms[0].submit();</script>");
        java.lang.String form = sb.toString();
        return form;
    }

    private static String buildHiddenFields(Map<String, String> parameters) {
        if (parameters == null || parameters.isEmpty()) {
            return "";
        }
        java.lang.StringBuffer sb = new StringBuffer();
        Set<String> keys = parameters.keySet();
        for (String key : keys) {
            String value = parameters.get(key);
            // 除去参数中的空值
            if (key == null || value == null) {
                continue;
            }
            sb.append(buildHiddenField(key, value));
        }
        java.lang.String result = sb.toString();
        return result;
    }

    private static String buildHiddenField(String key, String value) {
        java.lang.StringBuffer sb = new StringBuffer();
        sb.append("<input type=\"hidden\" name=\"");
        sb.append(key);

        sb.append("\" value=\"");
        //转义双引号
        String a = value.replace("\"", """);
        sb.append(a).append("\">\n");
        return sb.toString();
    }

}

  

package util;
import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.StringWriter;import java.net.HttpURLConnection;import java.net.InetSocketAddress;import java.net.Proxy;import java.net.Proxy.Type;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.Map.Entry;import java.util.Set;
import javax.net.ssl.HostnameVerifier;import javax.net.ssl.HttpsURLConnection;import javax.net.ssl.KeyManager;import javax.net.ssl.SSLContext;import javax.net.ssl.SSLSession;import javax.net.ssl.SSLSocketFactory;import javax.net.ssl.TrustManager;import javax.net.ssl.X509TrustManager;
import com.alipay.api.AlipayConstants;import com.alipay.api.FileItem;import com.alipay.api.internal.util.AlipayLogger;import com.alipay.api.internal.util.RequestParametersHolder;import com.alipay.api.internal.util.StringUtils;
/** * 网络工具类。 *  * @author carver.gu * @since 1.0, Sep 12, 2009 */public abstract class WebUtils {
    private static final String     DEFAULT_CHARSET = AlipayConstants.CHARSET_UTF8;    private static final String     METHOD_POST     = "POST";    private static final String     METHOD_GET      = "GET";
    private static SSLContext       ctx             = null;
    private static HostnameVerifier verifier        = null;
    private static SSLSocketFactory socketFactory   = null;
    private static class DefaultTrustManager 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 {        }    }
    static {
        try {            ctx = SSLContext.getInstance("TLS");            ctx.init(new KeyManager[0], new TrustManager[] { new DefaultTrustManager() },                new SecureRandom());
            ctx.getClientSessionContext().setSessionTimeout(15);            ctx.getClientSessionContext().setSessionCacheSize(1000);
            socketFactory = ctx.getSocketFactory();        } catch (Exception e) {
        }
        verifier = new HostnameVerifier() {            public boolean verify(String hostname, SSLSession session) {                return false;//默认认证不通过,进行证书校验。            }        };
    }
    private WebUtils() {    }
    /**     * 执行HTTP POST请求,可使用代理proxy。     *      * @param url 请求地址     * @param params 请求参数     * @param charset 字符集,如UTF-8, GBK, GB2312     * @param connectTimeout 连接超时时间     * @param readTimeout 请求超时时间     * @param proxyHost 代理host,传null表示不使用代理     * @param proxyPort 代理端口,传0表示不使用代理     * @return 响应字符串     * @throws IOException     */    public static String doPost(String url, Map<String, String> params, String charset,                                int connectTimeout, int readTimeout, String proxyHost,                                int proxyPort) 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, proxyHost, proxyPort);    }
    /**     * 执行HTTP POST请求。     *      * @param url 请求地址     * @param ctype 请求类型     * @param content 请求字节数组     * @param connectTimeout 连接超时时间     * @param readTimeout 请求超时时间     * @param proxyHost 代理host,传null表示不使用代理     * @param proxyPort 代理端口,传0表示不使用代理     * @return 响应字符串     * @throws IOException     */    public static String doPost(String url, String ctype, byte[] content, int connectTimeout,                                int readTimeout, String proxyHost, int proxyPort) throws IOException {        HttpURLConnection conn = null;        OutputStream out = null;        String rsp = null;        try {            try {                conn = null;                if (!StringUtils.isEmpty(proxyHost)) {                    conn = getConnection(new URL(url), METHOD_POST, ctype, proxyHost, proxyPort);                } else {                    conn = getConnection(new URL(url), METHOD_POST, ctype);                }                conn.setConnectTimeout(connectTimeout);                conn.setReadTimeout(readTimeout);            } catch (IOException e) {                Map<String, String> map = getParamsFromUrl(url);                AlipayLogger.logCommError(e, url, map.get("app_key"), map.get("method"), content);                throw e;            }            try {                out = conn.getOutputStream();                out.write(content);                rsp = getResponseAsString(conn);            } catch (IOException e) {                Map<String, String> map = getParamsFromUrl(url);                AlipayLogger.logCommError(e, conn, map.get("app_key"), map.get("method"), content);                throw e;            }
        } finally {            if (out != null) {                out.close();            }            if (conn != null) {                conn.disconnect();
            }        }
        return rsp;    }
    /**     * 执行带文件上传的HTTP POST请求。     *      * @param url 请求地址     * @param params 文本请求参数     * @param fileParams 文件请求参数     * @param charset 字符集,如UTF-8, GBK, GB2312     * @param connectTimeout 连接超时时间     * @param readTimeout 请求超时时间     * @param proxyHost 代理host,传null表示不使用代理     * @param proxyPort 代理端口,传0表示不使用代理     * @return 响应字符串     * @throws IOException     */    public static String doPost(String url, Map<String, String> params,                                Map<String, FileItem> fileParams, String charset,                                int connectTimeout, int readTimeout, String proxyHost,                                int proxyPort) throws IOException {        if (fileParams == null || fileParams.isEmpty()) {            return doPost(url, params, charset, connectTimeout, readTimeout, proxyHost, proxyPort);        }
        String boundary = System.currentTimeMillis() + ""; // 随机分隔线        HttpURLConnection conn = null;        OutputStream out = null;        String rsp = null;        try {            try {                String ctype = "multipart/form-data;boundary=" + boundary + ";charset=" + charset;                conn = null;                if (!StringUtils.isEmpty(proxyHost)) {                    conn = getConnection(new URL(url), METHOD_POST, ctype, proxyHost, proxyPort);                } else {                    conn = getConnection(new URL(url), METHOD_POST, ctype);                }                conn.setConnectTimeout(connectTimeout);                conn.setReadTimeout(readTimeout);            } catch (IOException e) {                Map<String, String> map = getParamsFromUrl(url);                AlipayLogger.logCommError(e, url, map.get("app_key"), map.get("method"), params);                throw e;            }
            try {                out = conn.getOutputStream();
                byte[] entryBoundaryBytes = ("\r\n--" + boundary + "\r\n").getBytes(charset);
                // 组装文本请求参数                Set<Entry<String, String>> textEntrySet = params.entrySet();                for (Entry<String, String> textEntry : textEntrySet) {                    byte[] textBytes = getTextEntry(textEntry.getKey(), textEntry.getValue(),                        charset);                    out.write(entryBoundaryBytes);                    out.write(textBytes);                }
                // 组装文件请求参数                Set<Entry<String, FileItem>> fileEntrySet = fileParams.entrySet();                for (Entry<String, FileItem> fileEntry : fileEntrySet) {                    FileItem fileItem = fileEntry.getValue();                    byte[] fileBytes = getFileEntry(fileEntry.getKey(), fileItem.getFileName(),                        fileItem.getMimeType(), charset);                    out.write(entryBoundaryBytes);                    out.write(fileBytes);                    out.write(fileItem.getContent());                }
                // 添加请求结束标志                byte[] endBoundaryBytes = ("\r\n--" + boundary + "--\r\n").getBytes(charset);                out.write(endBoundaryBytes);                rsp = getResponseAsString(conn);            } catch (IOException e) {                Map<String, String> map = getParamsFromUrl(url);                AlipayLogger.logCommError(e, conn, map.get("app_key"), map.get("method"), params);                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 响应字符串     * @throws IOException     */    public static String doGet(String url, Map<String, String> params) throws IOException {        return doGet(url, params, DEFAULT_CHARSET);    }
    /**     * 执行HTTP GET请求。     *      * @param url 请求地址     * @param params 请求参数     * @param charset 字符集,如UTF-8, GBK, GB2312     * @return 响应字符串     * @throws IOException     */    public static String doGet(String url, Map<String, String> 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);            } catch (IOException e) {                Map<String, String> map = getParamsFromUrl(url);                AlipayLogger.logCommError(e, url, map.get("app_key"), map.get("method"), params);                throw e;            }
            try {                rsp = getResponseAsString(conn);            } catch (IOException e) {                Map<String, String> map = getParamsFromUrl(url);                AlipayLogger.logCommError(e, conn, map.get("app_key"), map.get("method"), params);                throw e;            }
        } finally {            if (conn != null) {                conn.disconnect();            }        }
        return rsp;    }
    private static HttpURLConnection getConnection(URL url, String method, String ctype) throws IOException {        return getConnection(url, method, ctype, null);    }
    private static HttpURLConnection getConnection(URL url, String method, String ctype,                                                   String proxyHost, int proxyPort) throws IOException {        Proxy proxy = new Proxy(Type.HTTP, new InetSocketAddress(proxyHost, proxyPort));        return getConnection(url, method, ctype, proxy);    }
    private static HttpURLConnection getConnection(URL url, String method, String ctype, Proxy proxy) throws IOException {        HttpURLConnection conn = null;        if ("https".equals(url.getProtocol())) {            HttpsURLConnection connHttps = null;            if (proxy != null) {                connHttps = (HttpsURLConnection) url.openConnection(proxy);            } else {                connHttps = (HttpsURLConnection) url.openConnection();            }            connHttps.setSSLSocketFactory(socketFactory);            connHttps.setHostnameVerifier(verifier);            conn = connHttps;        } else {            conn = null;            if (proxy != null) {                conn = (HttpURLConnection) url.openConnection(proxy);            } else {                conn = (HttpURLConnection) url.openConnection();            }        }
        conn.setRequestMethod(method);        conn.setDoInput(true);        conn.setDoOutput(true);        conn.setRequestProperty("Accept", "text/xml,text/javascript,text/html");        conn.setRequestProperty("User-Agent", "aop-sdk-java");        conn.setRequestProperty("Content-Type", ctype);        return conn;    }
    private static URL buildGetUrl(String strUrl, String query) throws IOException {        URL url = new URL(strUrl);        if (StringUtils.isEmpty(query)) {            return url;        }
        if (StringUtils.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<String, String> params, String charset) throws IOException {        if (params == null || params.isEmpty()) {            return null;        }
        StringBuilder query = new StringBuilder();        Set<Entry<String, String>> entries = params.entrySet();        boolean hasParam = false;
        for (Entry<String, String> entry : entries) {            String name = entry.getKey();            String value = entry.getValue();            // 忽略参数名或参数值为空的参数            if (StringUtils.areNotEmpty(name, value)) {                if (hasParam) {                    query.append("&");                } else {                    hasParam = true;                }
                query.append(name).append("=").append(URLEncoder.encode(value, charset));            }        }
        return query.toString();    }
    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 (StringUtils.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 {            BufferedReader reader = new BufferedReader(new InputStreamReader(stream, charset));            StringWriter writer = new StringWriter();
            char[] chars = new char[256];            int count = 0;            while ((count = reader.read(chars)) > 0) {                writer.write(chars, 0, count);            }
            return writer.toString();        } finally {            if (stream != null) {                stream.close();            }        }    }
    private static String getResponseCharset(String ctype) {        String charset = DEFAULT_CHARSET;
        if (!StringUtils.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 (!StringUtils.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 (!StringUtils.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 (!StringUtils.isEmpty(value)) {            try {                result = URLEncoder.encode(value, charset);            } catch (IOException e) {                throw new RuntimeException(e);            }        }        return result;    }
    private static Map<String, String> getParamsFromUrl(String url) {        Map<String, String> map = null;        if (url != null && url.indexOf('?') != -1) {            map = splitUrlQuery(url.substring(url.indexOf('?') + 1));        }        if (map == null) {            map = new HashMap<String, String>();        }        return map;    }
    /**     * 从URL中提取所有的参数。     *      * @param query URL地址     * @return 参数映射     */    public static Map<String, String> splitUrlQuery(String query) {        Map<String, String> result = new HashMap<String, String>();
        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;    }
    public String buildForm(String baseUrl, RequestParametersHolder requestHolder) {        return null;    }
    public static String buildForm(String baseUrl, Map<String, String> parameters) {        java.lang.StringBuffer sb = new StringBuffer();        sb.append("<form name=\"punchout_form\" method=\"post\" action=\"");        sb.append(baseUrl);        sb.append("\">\n");        sb.append(buildHiddenFields(parameters));
        sb.append("<input type=\"submit\" value=\"立即支付\" style=\"display:none\" >\n");        sb.append("</form>\n");        sb.append("<script>document.forms[0].submit();</script>");        java.lang.String form = sb.toString();        return form;    }
    private static String buildHiddenFields(Map<String, String> parameters) {        if (parameters == null || parameters.isEmpty()) {            return "";        }        java.lang.StringBuffer sb = new StringBuffer();        Set<String> keys = parameters.keySet();        for (String key : keys) {            String value = parameters.get(key);            // 除去参数中的空值            if (key == null || value == null) {                continue;            }            sb.append(buildHiddenField(key, value));        }        java.lang.String result = sb.toString();        return result;    }
    private static String buildHiddenField(String key, String value) {        java.lang.StringBuffer sb = new StringBuffer();        sb.append("<input type=\"hidden\" name=\"");        sb.append(key);
        sb.append("\" value=\"");        //转义双引号        String a = value.replace("\"", "&quot;");        sb.append(a).append("\">\n");        return sb.toString();    }
}