带SSL证书的httpclient 远程接口工具类

package com.iups.wx.util;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Map;
import java.util.Map.Entry;

import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

import net.sf.json.JSONObject;

import org.apache.http.HttpEntity;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.util.EntityUtils;
import org.apache.log4j.Logger;

/**
 * 调用远程接口工具类
 * @author Administrator
 * @date 2017年2月16日 13:44:03
 */
public class HttpsClientUtil {

    //日志
    public static Logger log = Logger.getLogger(HttpsClientUtil.class);
    //编码方式
    private static String UTF8 = "UTF-8";
    //数据格式
    private final String APPLICATION_JSON = "application/json";
    //数据类型标识
     public final String CONTENT_TYPE = "Content-Type";
    //https请求客户端    
    private CloseableHttpClient  httpclient = null;  
    
    private static HttpsClientUtil httpsClientUtil;
    
    private HttpsClientUtil(){
        try{
            // 创建SSLContext对象，并使用我们指定的信任管理器初始化
            SSLContext sslContext = SSLContext.getInstance("SSL");
            sslContext.init(null, new TrustManager[]{
                //证书信任管理器（用于https请求）
                new X509TrustManager(){
                    @Override
                    public void checkClientTrusted(X509Certificate[] arg0,
                            String arg1) throws CertificateException {
                    }
                    @Override
                    public void checkServerTrusted(X509Certificate[] arg0,
                            String arg1) throws CertificateException {
                    }
                    @Override
                    public X509Certificate[] getAcceptedIssuers() {
                        return null;
                    }
                }
            }, new SecureRandom());
            //获取注册建造者
            RegistryBuilder<ConnectionSocketFactory> registryBuilder = RegistryBuilder.create();
            //注册http和https请求
            Registry<ConnectionSocketFactory> socketFactoryRegistry  = registryBuilder.register("http", PlainConnectionSocketFactory.INSTANCE)
                                                                     .register("https", new SSLConnectionSocketFactory(sslContext))
                                                                     .build();    
            //获取HttpClient池管理者
            PoolingHttpClientConnectionManager connManager  = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
            //初始化httpClient
            httpclient = HttpClients.custom().setConnectionManager(connManager).build();
        }catch(KeyManagementException e){
            e.printStackTrace();    
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        }
    };
    
    /**
     * 创建httpsClientUtil对象
     * @return
     */
    public static HttpsClientUtil getInstance(){
        if(httpsClientUtil==null){
            httpsClientUtil = new HttpsClientUtil();
        }
        return httpsClientUtil;
    }
    
    /**
     * 描述:  发送post or get请求并获取结果
     * @param requestUrl 请求地址
     * @param requestMethod 请求方式（GET、POST）
     * @param outputStr 提交的数据
     * @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
     */
    public JSONObject  sendRequest(String requestUrl, String requestMethod, String outputStr){
        String responseObj = null;
        CloseableHttpResponse execute = null;
        try{
            if("POST".equals(requestMethod)){
                HttpPost httpPost = new HttpPost(requestUrl);
                httpPost.addHeader(CONTENT_TYPE, APPLICATION_JSON);
                // 将JSON字符串进行UTF-8编码,以便传输中文
                StringEntity requestEntity = new StringEntity(outputStr,HttpsClientUtil.UTF8);
                httpPost.setEntity(requestEntity);
                execute = httpclient.execute(httpPost);
            }else{
                HttpGet httpGet = new HttpGet(requestUrl);
                httpGet.addHeader(CONTENT_TYPE, APPLICATION_JSON);
                execute = httpclient.execute(httpGet);
            }
            HttpEntity responseEntity = execute.getEntity();
            if(responseEntity!=null){
                responseObj = EntityUtils.toString(responseEntity,HttpsClientUtil.UTF8);
            }
        }catch(UnsupportedEncodingException e){
            e.printStackTrace();
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                //关闭响应流
                if(execute!=null) execute.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        log.info("远程接口响应:"+responseObj);
        return JSONObject.fromObject(responseObj);
    }
    
    /**
     * 描述:  发送post请求并获取结果
     * @param requestUrl 请求地址
     * @param requestUrlParam 请求地址拼接参数
     * @param outputStr 提交的数据
     * @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
     */
    public JSONObject sendPostRequest(String requestUrl,Map<String,String> requestUrlParam, String outputStr){
        return sendRequest(requestUrlParam(requestUrl, requestUrlParam), "POST", outputStr);
    }
    
    /**
     * 描述:  发送get请求并获取结果
     * @param requestUrl 请求地址
     * @param requestUrlParam 请求地址拼接参数
     * @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
     */
    public JSONObject sendGetRequest(String requestUrl,Map<String,String> requestUrlParam){
        return sendRequest(requestUrlParam(requestUrl, requestUrlParam), "GET", null);
    }
    
    /**
     * 描述：拼接URL后接参数
     * @param requestUrl 请求地址
     * @param requestUrlParam 请求地址拼接参数
     * @return 带参数请求地址
     */
    public String requestUrlParam(String requestUrl,Map<String,String> requestUrlParam){
        if(requestUrlParam==null){
            return requestUrl;
        }
        String requestParam = "";
        for (Entry<String, String> entry : requestUrlParam.entrySet()) {
            String key = entry.getKey();
            String value = entry.getValue();
            requestParam += "&"+key+"="+value;
        }
        if(requestParam.length()>0){
            if(requestUrl.indexOf("?")==-1){
                requestUrl = requestUrl+"?"+requestParam.substring(1);
            }else{
                requestUrl = requestUrl+requestParam;
            }
        }
        return requestUrl;
    }
    
}