/**

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

     }

     /**

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

     }