基於JAVA原生HTTP請求工具類 httphelper

原文地址;http://lushuifa.iteye.com/blog/2313896

 

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Map;
import java.util.Set;

import org.apache.log4j.Logger;

/**
 * 提供通過HTTP協議獲取內容的方法 <br/>
 * 所有提供方法中的params參數在內部不會進行自動的url encode，如果提交參數需要進行url encode，請調用方自行處理
 * @Description: HTTP請求代理工具
 * @author lushuifa
 * @date 2016年11月18日 上午11:21:05
 */
public class HttpUtil {
    /**
     * logger
     */
    private static Logger logger = Logger.getLogger(HttpUtil.class);
    
    /**
     * 支持的Http method
     *
     */
    private static enum HttpMethod {
        POST,DELETE,GET,PUT,HEAD;
    };
    
    @SuppressWarnings({ "unchecked", "rawtypes" })
    private static String invokeUrl(String url, Map params, Map<String,String> headers, int connectTimeout, int readTimeout, String encoding, HttpMethod method){
        //構造請求參數字符串
        StringBuilder paramsStr = null;
        if(params != null){
            paramsStr = new StringBuilder();
            Set<Map.Entry> entries = params.entrySet();
            for(Map.Entry entry:entries){
                String value = (entry.getValue()!=null)?(String.valueOf(entry.getValue())):"";
                paramsStr.append(entry.getKey() + "=" + value + "&");
            }
            //只有POST方法才能通過OutputStream(即form的形式)提交參數
            if(method != HttpMethod.POST){
                url += "?"+paramsStr.toString();
            }
        }
        
        URL uUrl = null;
        HttpURLConnection conn = null;
        BufferedWriter out = null;
        BufferedReader in = null;
        try {
            //創建和初始化連接
            uUrl = new URL(url);
            conn = (HttpURLConnection) uUrl.openConnection();
            conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");
            conn.setRequestMethod(method.toString());
            conn.setDoOutput(true);
            conn.setDoInput(true);
            //設置連接超時時間
            conn.setConnectTimeout(connectTimeout);
            //設置讀取超時時間
            conn.setReadTimeout(readTimeout);
            //指定請求header參數
            if(headers != null && headers.size() > 0){
                Set<String> headerSet = headers.keySet();
                for(String key:headerSet){
                    conn.setRequestProperty(key, headers.get(key));
                }
            }

            if(paramsStr != null && method == HttpMethod.POST){
                //發送請求參數
                out = new BufferedWriter(new OutputStreamWriter(conn.getOutputStream(),encoding));
                out.write(paramsStr.toString());
                out.flush();
            }
            
            //接收返回結果
            StringBuilder result = new StringBuilder();
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(),encoding));
            if(in != null){
                String line = "";
                while ((line = in.readLine()) != null) {
                    result.append(line);
                }
            }
            return result.toString();
        } catch (Exception e) {
            logger.error("調用接口["+url+"]失敗！請求URL："+url+"，參數："+params,e);
            //處理錯誤流，提高http連接被重用的幾率
            try {
                byte[] buf = new byte[100];
                InputStream es = conn.getErrorStream();
                if(es != null){
                    while (es.read(buf) > 0) {;}
                    es.close();
                }
            } catch (Exception e1) {
                e1.printStackTrace();
            }
        } finally {
            try {
                if (out!=null) {
                    out.close();
                }
            }catch (Exception e) {
                e.printStackTrace();
            }
            try {
                if (in !=null) {
                    in.close();
                }
            }catch (Exception e) {
                e.printStackTrace();
            }
            //關閉連接
            if (conn != null){
                conn.disconnect();
            }   
        }
        return null;
    }
    
    /**
     * POST方法提交Http請求，語義為“增加” <br/>
     * 注意：Http方法中只有POST方法才能使用body來提交內容
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String post(String url, Map params, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,null,connectTimeout,readTimeout,charset,HttpMethod.POST);
    }
    
    /**
     * POST方法提交Http請求，語義為“增加” <br/>
     * 注意：Http方法中只有POST方法才能使用body來提交內容
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param headers 請求頭參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String post(String url, Map params, Map<String,String> headers, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,headers,connectTimeout,readTimeout,charset,HttpMethod.POST);
    }
    
    /**
     * GET方法提交Http請求，語義為“查詢”
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String get(String url, Map params, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,null,connectTimeout,readTimeout,charset,HttpMethod.GET);
    }
    
    /**
     * GET方法提交Http請求，語義為“查詢”
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param headers 請求頭參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String get(String url, Map params, Map<String,String> headers,int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,headers,connectTimeout,readTimeout,charset,HttpMethod.GET);
    }
    
    /**
     * PUT方法提交Http請求，語義為“更改” <br/>
     * 注意：PUT方法也是使用url提交參數內容而非body，所以參數最大長度收到服務器端實現的限制，Resin大概是8K
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String put(String url, Map params, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,null,connectTimeout,readTimeout,charset,HttpMethod.PUT);
    }
    
    /**
     * PUT方法提交Http請求，語義為“更改” <br/>
     * 注意：PUT方法也是使用url提交參數內容而非body，所以參數最大長度收到服務器端實現的限制，Resin大概是8K
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param headers 請求頭參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String put(String url, Map params, Map<String,String> headers,int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,headers,connectTimeout,readTimeout,charset,HttpMethod.PUT);
    }    
    
    /**
     * DELETE方法提交Http請求，語義為“刪除”
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String delete(String url, Map params, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,null,connectTimeout,readTimeout,charset,HttpMethod.DELETE);
    }
    
    /**
     * DELETE方法提交Http請求，語義為“刪除”
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param headers 請求頭參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String delete(String url, Map params, Map<String,String> headers, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,headers,connectTimeout,readTimeout,charset,HttpMethod.DELETE);
    }
    
    /**
     * HEAD方法提交Http請求，語義同GET方法  <br/>
     * 跟GET方法不同的是，用該方法請求，服務端不返回message body只返回頭信息，能節省帶寬
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String head(String url, Map params, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,null,connectTimeout,readTimeout,charset,HttpMethod.HEAD);
    }
    
    /**
     * HEAD方法提交Http請求，語義同GET方法  <br/>
     * 跟GET方法不同的是，用該方法請求，服務端不返回message body只返回頭信息，能節省帶寬
     * @param url 資源路徑（如果url中已經包含參數，則params應該為null）
     * @param params 參數
     * @param headers 請求頭參數
     * @param connectTimeout 連接超時時間（單位為ms）
     * @param readTimeout 讀取超時時間（單位為ms）
     * @param charset 字符集（一般該為“utf-8”）
     * @return
     */
    public static String head(String url, Map params, Map<String,String> headers, int connectTimeout, int readTimeout, String charset){
        return invokeUrl(url,params,headers,connectTimeout,readTimeout,charset,HttpMethod.HEAD);
    }
    
    public static void main(String[] args) {
        //Map params = new HashMap();
        //params.put("phoneNo", "中文");
        //String str = HttpUtil.get("http://localhost:9092/elis_smp_als_dmz/do/app/activitySupport/demo", params, 3000, 3000, "UTF-8");
        //System.out.println(str);
    }

}