HttpClient 4.4 请求

4.2 版本

    /**
     * url 请求 paramUrl
     * 
     * @time 2015年11月10日下午4:40:22
     * @packageName com.rom.utils
     * @param url         url请求地址
     * @param header    请求头信息
     * @param params     url请求参数
     * @param paramstype 参数类型 1:json格式 ; 其他:正常格式;
     * @param resulttype 返回值类型 1: 压缩流字符串 2：正常字符串
     * @return
     */
    public synchronized static String paramUrl(String url, Map<String, String> header, Map<String, Object> params,
            String paramstype, String resulttype) {

        String result = "";
        HttpClient httpClient = new DefaultHttpClient();
        httpClient.getParams().setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 10000);

        HttpPost httpPost = new HttpPost(url);

        if (header != null) {
            Set<String> headerkey = header.keySet();
            Iterator<String> headerkeyit = headerkey.iterator();
            while (headerkeyit.hasNext()) {
                String key = (String) headerkeyit.next();
                httpPost.setHeader(key, header.get(key).toString());
            }
        }

        try {
            // 如果参数类型为1 证明参数传递方式为 json格式
            if (paramstype != null && paramstype.equals("1")) {
                if (params != null) {
                    StringEntity entity = new StringEntity(JSONObject.fromObject(params).toString(), "utf-8");// 解决中文乱码问题
                    entity.setContentEncoding("UTF-8");
                    entity.setContentType("application/json");
                    httpPost.setEntity(entity);
                }
            } else {
                // 参数格式为 键值对形式
                if (params != null) {
                    List<NameValuePair> formparams = new ArrayList<NameValuePair>();
                    Set<String> keySet = params.keySet();
                    Iterator<String> keyit = keySet.iterator();
                    while (keyit.hasNext()) {
                        String key = (String) keyit.next();
                        formparams.add(new BasicNameValuePair(key, params.get(key).toString()));
                    }
                    UrlEncodedFormEntity uefEntity = new UrlEncodedFormEntity(formparams, "UTF-8");
                    httpPost.setEntity(uefEntity);
                }
            }

            HttpResponse response = httpClient.execute(httpPost);
            HttpEntity entity = response.getEntity();
            if (entity != null) {
                // 返回类型如果不为空 并且 等于1 证明该返回结果经过zip压缩
                if (resulttype != null && resulttype.equals("1")) {
                    result = EntityUtils.toString(new GzipDecompressingEntity(entity), "utf-8");
                } else {
                    result = EntityUtils.toString(entity, "utf-8");
                }
            }
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
            log.error(e.getMessage());
        } catch (ClientProtocolException e) {
            e.printStackTrace();
            log.error(e.getMessage());
        } catch (IOException e) {
            e.printStackTrace();
            log.error(e.getMessage());
        } finally {
            httpClient.getConnectionManager().shutdown(); 
        }
        return result;
    }

4.4 版本

    /**
     * url 请求 paramUrl
     * 
     * @time 2015年11月10日下午4:40:22
     * @packageName com.rom.utils
     * @param url         url请求地址
     * @param header    请求头信息
     * @param params     url请求参数
     * @param paramstype 参数类型 1:json格式 ; 其他:正常格式;
     * @return
     */
    public  static JSONObject paramUrl(String url ,Map<String, String> header,
            Map<String, Object> params,String paramstype){
        
        RequestConfig config = RequestConfig.custom()
                .setConnectionRequestTimeout(10000).setConnectTimeout(10000)
                .setSocketTimeout(10000).build();
        
        HttpPost httpPost = new HttpPost(url);
        
        httpPost.setConfig(config);
        if (header != null) {
            Set<String> headerkey = header.keySet();
            Iterator<String> headerkeyit = headerkey.iterator();
            while (headerkeyit.hasNext()) {
                String key = (String) headerkeyit.next();
                httpPost.setHeader(key, header.get(key).toString());
            }
        }
        
        if (params != null) {
            // 如果参数类型为1 证明参数传递方式为 json格式
            if (paramstype != null && paramstype.equals("1")) {
                StringEntity entity = new StringEntity(JSONObject.fromObject(params).toString(), "utf-8");// 解决中文乱码问题
                entity.setContentEncoding("UTF-8");
                entity.setContentType("application/json");
                httpPost.setEntity(entity);
            } else {
                // 参数格式为 键值对形式
                List<NameValuePair> formparams = new ArrayList<NameValuePair>();
                Set<String> keySet = params.keySet();
                Iterator<String> keyit = keySet.iterator();
                while (keyit.hasNext()) {
                    String key = (String) keyit.next();
                    formparams.add(new BasicNameValuePair(key, params.get(key).toString()));
                }
                UrlEncodedFormEntity uefEntity = null;
                try {
                    uefEntity = new UrlEncodedFormEntity(formparams, "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
                httpPost.setEntity(uefEntity);
            }
        }
        
        CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(null).build();//设置进去
        
        CloseableHttpResponse response = null;
        StringBuffer out;
        try {
            response = httpClient.execute(httpPost); 
            
            HttpEntity entity = response.getEntity();
            
            InputStream in = entity.getContent();
            
            out = new StringBuffer();  
            byte[] b = new byte[4096];  
            for (int n; (n = in.read(b)) != -1;) {  
                out.append(new String(b, 0, n));  
            }
            JSONObject json = JSONObject.fromObject(out.toString());
            in = null;
            return json;
        } catch (ClientProtocolException e) {
            log.error(e.getMessage());
        } catch (IllegalStateException e) {
            log.error(e.getMessage());
        } catch (IOException e) {
            log.error(e.getMessage());
        } finally{
            try {
                if (httpClient!=null) {
                    httpClient.close();
                }
            } catch (IOException e) {
                log.error(e);
            }
        }
        return null;
    }