2. 程式人生 > >http 請求類

http 請求類

阿新 • • 發佈：2018-08-24
con exce div urn open www main out ack 

package com.wenwo.platform.utils;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.util.HashMap;

 
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class HttpClient {
    
    private static final Logger log = LoggerFactory.getLogger(HttpClient.class);

    private static HttpURLConnection conn = null;
    
     
 
/** 
     * 向指定URL發送GET方法的請求 
     * @param url  發送請求的URL 
     * @param param  請求參數，請求參數應該是name1=value1&name2=value2的形式 
     * @return URL所代表遠程資源的響應 
     */  
  
    public static String sendGet(String url) {  
        String result = "";  
        BufferedReader in = null;  
        try {  
            URL realUrl 
 
= new URL(url);  
            // 打開和URL之間的連接  
            URLConnection conn = realUrl.openConnection();  
            // 設置通用的請求屬性  
            conn.setRequestProperty("accept", "*/*");  
            conn.setRequestProperty("connection", "Keep-Alive");  
            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");  
            // 建立實際的連接  
            conn.connect();  
            // 獲取所有響應頭字段  
            Map<String, List<String>> map = conn.getHeaderFields();  
            // 定義BufferedReader輸入流來讀取URL的響應  
            in = new BufferedReader(new InputStreamReader(conn.getInputStream()));  
            String line;  
            while ((line = in.readLine()) != null) {  
                result += "\n" + line;  
            }  
        } catch (Exception e) {  
            log.error("HttpClient snedGet url:"+url+" error ->", e);
        }  
        // 使用finally塊來關閉輸入流  
        finally {  
            try {  
                if (in != null) {  
                    in.close();  
                }  
            } catch (IOException ex) {  
                ex.printStackTrace();  
            }  
        }  
        return result;  
    }  
    
    
    /** 
     * 向指定URL發送GET方法的請求 
     * @param url  發送請求的URL 
     * @param param  請求參數，請求參數應該是name1=value1&name2=value2的形式 
     * @return URL所代表遠程資源的響應 
     */  
  
    public static String sendGet(String url,Map<String, Object> headerMap) {  
        String result = "";  
        BufferedReader in = null;  
        try {  
            URL realUrl = new URL(url);  
            // 打開和URL之間的連接  
            URLConnection conn = realUrl.openConnection();  
            // 設置通用的請求屬性  
//            conn.setRequestProperty("accept", "*/*");  
//            conn.setRequestProperty("connection", "Keep-Alive");  
//            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)"); 
            
            if(headerMap != null) {
                Iterator<Map.Entry<String, Object>> it = headerMap.entrySet().iterator();
                while (it.hasNext()) {
                    Map.Entry<String, Object> element = (Map.Entry<String, Object>) it
                            .next();
                    conn.setRequestProperty(element.getKey(), element.getValue().toString());  
                }
            }
            
            // 建立實際的連接  
            conn.connect();  
            // 獲取所有響應頭字段  
            Map<String, List<String>> map = conn.getHeaderFields();  
            // 定義BufferedReader輸入流來讀取URL的響應  
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(),"UTF-8"));  
            String line;  
            while ((line = in.readLine()) != null) {  
                result += "\n" + line;  
            }  
        } catch (Exception e) {  
            log.error("HttpClient snedGet url:"+url+" error ->", e);
        }  
        // 使用finally塊來關閉輸入流  
        finally {  
            try {  
                if (in != null) {  
                    in.close();  
                }  
            } catch (IOException ex) {  
                ex.printStackTrace();  
            }  
        }  
        return result;  
    }  
    
    
    public static String get(String urlAddr, Map<String, Object> paramMap) throws Exception {
        String content = "";
        StringBuffer params = new StringBuffer();
        if(paramMap != null) {
            Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator();
            while (it.hasNext()) {
                Map.Entry<String, Object> element = (Map.Entry<String, Object>) it
                        .next();
                params.append((String) element.getKey());
                params.append("=");
                params.append(element.getValue());
                params.append("&");
            }
        }

        if (params.length() > 0) {
            params.deleteCharAt(params.length() - 1);
        }
        BufferedReader br = null;
        try {
            URL url = new URL(urlAddr); //new URL(urlAddr + "?" + params.toString());
            if(params.length()>0){
                url = new URL(urlAddr + "?" + params.toString());
            }
            
            conn = ((HttpURLConnection) url.openConnection());
            conn.setConnectTimeout(3000);
            conn.setReadTimeout(3000); 
            conn.setDoOutput(false);
            conn.setRequestMethod("GET");
            conn.setUseCaches(false);
            conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");
            conn.setRequestProperty("Content-Length", "0");
            conn.setDoInput(true);
            conn.connect();

            int code = conn.getResponseCode();
            if (code != 200) {
                log.info("ERROR===" + code);
            } else {
                InputStream in = conn.getInputStream();
                System.out.println("in.available():"+in.available());
                br = new BufferedReader(new InputStreamReader(in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null){
                    content = content + line + "\r\n";
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("urlAddr:"+urlAddr+" get error.->" + params.toString(), e);
        } finally {
            if (br != null){
                br.close();
            }
            if (conn!= null)conn.disconnect();
        }
        return content;
    }
    
    public static String post(String urlAddr, Map<String, Object> paramMap)
            throws Exception {
        String content = "";
        StringBuffer params = new StringBuffer();
        Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator();
        while (it.hasNext()) {
            Map.Entry<String, Object> element = (Map.Entry<String, Object>) it
                    .next();
            params.append((String) element.getKey());
            params.append("=");
            params.append(element.getValue());
            params.append("&");
        }

        if (params.length() > 0) {
            params.deleteCharAt(params.length() - 1);
        }
        BufferedReader br = null;
        try {
            URL url = new URL(urlAddr);
            conn = ((HttpURLConnection) url.openConnection());
            conn.setConnectTimeout(3000);
            conn.setReadTimeout(3000); 
            conn.setDoOutput(true);
            conn.setRequestMethod("POST");
            conn.setUseCaches(false);
            conn.setRequestProperty("Content-Type",
                    "application/x-www-form-urlencoded");
            conn.setRequestProperty("Content-Length",
                    String.valueOf(params.length()));
            conn.setDoInput(true);
            conn.connect();

            OutputStreamWriter out = new OutputStreamWriter(
                    conn.getOutputStream(), "UTF-8");
            out.write(params.toString());
            out.flush();
            out.close();

            int code = conn.getResponseCode();
            if (code != 200) {
                log.info("ERROR===" + code);
                InputStream in = conn.getInputStream();
                br = new BufferedReader(new InputStreamReader(
                        in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null)
                    content = content + line + "\r\n";
            } else {
                InputStream in = conn.getInputStream();
                br = new BufferedReader(new InputStreamReader(
                        in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null)
                    content = content + line + "\r\n";
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("urlAddr:"+urlAddr+" post error. ->" + params.toString(), e);
        } finally {
            if (conn!=null)conn.disconnect();
            if (br != null){
                br.close();
            }
        }
        return content;
    }
    
    
    
    
    public static String sendPost(String urlAddr, Map<String, Object> paramMap, Map<String, Object> headerMap)
            throws Exception {
        String content = "";
        HttpURLConnection conn = null;
        StringBuffer params = new StringBuffer();
        Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator();
        while (it.hasNext()) {
            Map.Entry<String, Object> element = (Map.Entry<String, Object>) it
                    .next();
            params.append((String) element.getKey());
            params.append("=");
            params.append(element.getValue());
            params.append("&");
        }

        if (params.length() > 0) {
            params.deleteCharAt(params.length() - 1);
        }
        BufferedReader br = null;
        try {
            URL url = new URL(urlAddr);
            conn = ((HttpURLConnection) url.openConnection());
            conn.setConnectTimeout(3000);
            conn.setReadTimeout(3000); 
            conn.setDoOutput(true);
            conn.setRequestMethod("POST");
            conn.setUseCaches(false);
            conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");
            conn.setRequestProperty("Content-Length",String.valueOf(params.length()));
            Iterator<Map.Entry<String, Object>> iter = headerMap.entrySet().iterator();
            while (iter.hasNext()) {
                Map.Entry<String, Object> element = (Map.Entry<String, Object>) iter
                        .next();
                conn.setRequestProperty(element.getKey(),
                        (String)element.getValue());
            }
            conn.setDoInput(true);
            conn.connect();

            OutputStreamWriter out = new OutputStreamWriter(
                    conn.getOutputStream(), "UTF-8");
            out.write(params.toString());
            out.flush();
            out.close();
            int code = conn.getResponseCode();
            
            if (code != 200) {
                
                log.info("ERROR===" + code);
                
                InputStream in = conn.getInputStream();

                br = new BufferedReader(new InputStreamReader(
                        in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null){
                    content = content + line + "\r\n";
                }
                
            } else {
                InputStream in = conn.getInputStream();
                br = new BufferedReader(new InputStreamReader(in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null){
                    content = content + line + "\r\n";
                }
            }
            
            log.info(urlAddr + "post info -->" + params.toString() + " result code: " + code + " , data : " +  content);
            
        } catch (Exception e) {
            e.printStackTrace();
            log.error("urlAddr:" + urlAddr+" post error.-> " + params.toString(), e);
        } finally {
            if (conn!=null) 
                conn.disconnect();
            if (br != null){
                br.close();
            }
        }
        return content;
    }
    
    public static String post(String urlAddr, Map<String, Object> paramMap, Map<String, Object> headerMap)
            throws Exception {
        
        String content = "";
        HttpURLConnection conn = null;
        StringBuffer params = new StringBuffer();
        Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator();
        while (it.hasNext()) {
            Map.Entry<String, Object> element = (Map.Entry<String, Object>) it
                    .next();
            params.append((String) element.getKey());
            params.append("=");
            params.append(element.getValue());
            params.append("&");
        }

        if (params.length() > 0) {
            params.deleteCharAt(params.length() - 1);
        }
        BufferedReader br = null;
        try {
            URL url = new URL(urlAddr);
            conn = ((HttpURLConnection) url.openConnection());
            conn.setConnectTimeout(3000);
            conn.setReadTimeout(3000); 
            conn.setDoOutput(true);
            conn.setRequestMethod("POST");
            conn.setUseCaches(false);
            conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");
            conn.setRequestProperty("Content-Length",String.valueOf(params.length()));
            Iterator<Map.Entry<String, Object>> iter = headerMap.entrySet().iterator();
            while (iter.hasNext()) {
                Map.Entry<String, Object> element = (Map.Entry<String, Object>) iter
                        .next();
                conn.setRequestProperty(element.getKey(),
                        (String)element.getValue());
            }
            conn.setDoInput(true);
            conn.connect();

            OutputStreamWriter out = new OutputStreamWriter(
                    conn.getOutputStream(), "UTF-8");
            out.write(params.toString());
            out.flush();
            out.close();

            int code = conn.getResponseCode();
            if (code != 200) {
                log.info("ERROR===" + code);
                InputStream in = conn.getInputStream();

                br = new BufferedReader(new InputStreamReader(
                        in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null)
                    content = content + line + "\r\n";
            } else {
                InputStream in = conn.getInputStream();

                br = new BufferedReader(new InputStreamReader(
                        in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null)
                    content = content + line + "\r\n";
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("urlAddr:"+urlAddr+" post error.-> " + params.toString(), e);
        } finally {
            if (conn!=null) conn.disconnect();
            if (br != null){
                br.close();
            }
        }
        return content;
    }

    public static String post(String urlAddr, String json) throws Exception {
        String content = "";
        HttpURLConnection urlConnection = null;
        BufferedReader br = null;
        try {
            URL url = new URL(urlAddr);  
            urlConnection = (HttpURLConnection) url.openConnection();  
            // 設置doOutput屬性為true表示將使用此urlConnection寫入數據  
            urlConnection.setDoOutput(true);  
            urlConnection.setConnectTimeout(3000);
            urlConnection.setReadTimeout(3000); 
            // 定義待寫入數據的內容類型，我們設置為application/x-www-form-urlencoded類型  
            urlConnection.setRequestProperty("content-type", "text/plain");
            urlConnection.setRequestProperty("user-agent", "curl/7.12.1");  
            urlConnection.setRequestProperty("host", "data.zz.baidu.com");
            urlConnection.setRequestProperty("content-length", String.valueOf(json.length()) );
            // 得到請求的輸出流對象  
            OutputStreamWriter out = new OutputStreamWriter(urlConnection.getOutputStream());  
            // 把數據寫入請求的Body  
            out.write(json);
            out.flush();  
            out.close(); 

            int code = urlConnection.getResponseCode();
            if (code != 200) {
                log.info("urlAddr："+urlAddr+" code ERROR===" + code);
            } else {
                InputStream in = urlConnection.getInputStream();

                 br = new BufferedReader(new InputStreamReader(
                        in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null)
                    content = content + line + "\r\n";
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("urlAddr:"+urlAddr+" post error->" + json, e);
        } finally {
           if (urlConnection!=null) urlConnection.disconnect();
           if (br != null){
               br.close();
           }
        }
        return content;
    }
    
    public static String postBuiness(String urlAddr, String json) {
        String content = "";
        HttpURLConnection urlConnection = null;
        BufferedReader br = null;
        try {
            URL url = new URL(urlAddr);  
            urlConnection = (HttpURLConnection) url.openConnection();  
            // 設置doOutput屬性為true表示將使用此urlConnection寫入數據  
            urlConnection.setDoOutput(true);  
            // 定義待寫入數據的內容類型，我們設置為application/x-www-form-urlencoded類型  
            urlConnection.setRequestProperty("content-type", "text/plain");
            urlConnection.setRequestProperty("user-agent", "curl/7.12.1");  
            urlConnection.setRequestProperty("host", "data.zz.baidu.com");
            urlConnection.setRequestProperty("content-length", String.valueOf(json.length()) );
            // 得到請求的輸出流對象  
            OutputStreamWriter out = new OutputStreamWriter(urlConnection.getOutputStream());  
            // 把數據寫入請求的Body  
            out.write(json);
            out.flush();  
            out.close(); 

            int code = urlConnection.getResponseCode();
            if (code != 200) {
                log.info("ERROR===" + code);
            } else {
                InputStream in = urlConnection.getInputStream();

                  br = new BufferedReader(new InputStreamReader(
                        in, "UTF-8"));
                String line = "";
                while ((line = br.readLine()) != null)
                    content = content + line + "\r\n";
            }
        } catch (Exception e) {
            e.printStackTrace();
            log.error("urlAddr:"+urlAddr+" post error->" + json, e);
        } finally {
           if(urlConnection!=null)urlConnection.disconnect();
           if (br != null){
               try {
                br.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
           }
        } 
        return content;
    }

    public static void main(String[] args) throws Exception {
//        String urlAddr = "http://api.weibo.com/2/proxy/badges/issue.json";
        String ak = "4CZXhoWckYANMkvlCdZNy0kjtS4Aqjqk";
//        params.put("source", "2067112424");
//        params.put("uids", "2365944120");
//        params.put("badge_id", "sAFStotI");
        Map<String, Object> headers = new HashMap<String, Object>();
// 
        
        HttpClient client = new HttpClient();
        String urlAddr = "http://10.8.2.6:9200/_analyze?pretty&analyzer=ik_smart";
        String result = client.post(urlAddr, "感冒的時候，最不易吃哪些東西？？？");
        System.out.println(result);
    }
}

package com.wenwo.platform.utils;

import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStreamWriter;import java.net.HttpURLConnection;import java.net.URL;import java.net.URLConnection;import java.util.HashMap;import java.util.Iterator;import java.util.List;import java.util.Map;
import org.slf4j.Logger;import org.slf4j.LoggerFactory;
public class HttpClient {private static final Logger log = LoggerFactory.getLogger(HttpClient.class);
private static HttpURLConnection conn = null; /** * 向指定URL發送GET方法的請求 * @param url 發送請求的URL * @param param 請求參數，請求參數應該是name1=value1&name2=value2的形式 * @return URL所代表遠程資源的響應 */ public static String sendGet(String url) { String result = ""; BufferedReader in = null; try { URL realUrl = new URL(url); // 打開和URL之間的連接 URLConnection conn = realUrl.openConnection(); // 設置通用的請求屬性 conn.setRequestProperty("accept", "*/*"); conn.setRequestProperty("connection", "Keep-Alive"); conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)"); // 建立實際的連接 conn.connect(); // 獲取所有響應頭字段 Map<String, List<String>> map = conn.getHeaderFields(); // 定義BufferedReader輸入流來讀取URL的響應 in = new BufferedReader(new InputStreamReader(conn.getInputStream())); String line; while ((line = in.readLine()) != null) { result += "\n" + line; } } catch (Exception e) { log.error("HttpClient snedGet url:"+url+" error ->", e); } // 使用finally塊來關閉輸入流 finally { try { if (in != null) { in.close(); } } catch (IOException ex) { ex.printStackTrace(); } } return result; } /** * 向指定URL發送GET方法的請求 * @param url 發送請求的URL * @param param 請求參數，請求參數應該是name1=value1&name2=value2的形式 * @return URL所代表遠程資源的響應 */ public static String sendGet(String url,Map<String, Object> headerMap) { String result = ""; BufferedReader in = null; try { URL realUrl = new URL(url); // 打開和URL之間的連接 URLConnection conn = realUrl.openConnection(); // 設置通用的請求屬性 // conn.setRequestProperty("accept", "*/*"); // conn.setRequestProperty("connection", "Keep-Alive"); // conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)"); if(headerMap != null) { Iterator<Map.Entry<String, Object>> it = headerMap.entrySet().iterator(); while (it.hasNext()) { Map.Entry<String, Object> element = (Map.Entry<String, Object>) it .next(); conn.setRequestProperty(element.getKey(), element.getValue().toString()); } } // 建立實際的連接 conn.connect(); // 獲取所有響應頭字段 Map<String, List<String>> map = conn.getHeaderFields(); // 定義BufferedReader輸入流來讀取URL的響應 in = new BufferedReader(new InputStreamReader(conn.getInputStream(),"UTF-8")); String line; while ((line = in.readLine()) != null) { result += "\n" + line; } } catch (Exception e) { log.error("HttpClient snedGet url:"+url+" error ->", e); } // 使用finally塊來關閉輸入流 finally { try { if (in != null) { in.close(); } } catch (IOException ex) { ex.printStackTrace(); } } return result; } public static String get(String urlAddr, Map<String, Object> paramMap) throws Exception {String content = "";StringBuffer params = new StringBuffer();if(paramMap != null) {Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator();while (it.hasNext()) {Map.Entry<String, Object> element = (Map.Entry<String, Object>) it.next();params.append((String) element.getKey());params.append("=");params.append(element.getValue());params.append("&");}}
if (params.length() > 0) {params.deleteCharAt(params.length() - 1);}BufferedReader br = null;try {URL url = new URL(urlAddr); //new URL(urlAddr + "?" + params.toString());if(params.length()>0){url = new URL(urlAddr + "?" + params.toString());}conn = ((HttpURLConnection) url.openConnection());conn.setConnectTimeout(3000); conn.setReadTimeout(3000); conn.setDoOutput(false);conn.setRequestMethod("GET");conn.setUseCaches(false);conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");conn.setRequestProperty("Content-Length", "0");conn.setDoInput(true);conn.connect();
int code = conn.getResponseCode();if (code != 200) {log.info("ERROR===" + code);} else {InputStream in = conn.getInputStream();System.out.println("in.available():"+in.available());br = new BufferedReader(new InputStreamReader(in, "UTF-8"));String line = "";while ((line = br.readLine()) != null){content = content + line + "\r\n";}}} catch (Exception e) { e.printStackTrace();log.error("urlAddr:"+urlAddr+" get error.->" + params.toString(), e);} finally { if (br != null){ br.close(); }if (conn!= null)conn.disconnect();}return content;}public static String post(String urlAddr, Map<String, Object> paramMap)throws Exception {String content = "";StringBuffer params = new StringBuffer();Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator();while (it.hasNext()) {Map.Entry<String, Object> element = (Map.Entry<String, Object>) it.next();params.append((String) element.getKey());params.append("=");params.append(element.getValue());params.append("&");}
if (params.length() > 0) {params.deleteCharAt(params.length() - 1);}BufferedReader br = null;try {URL url = new URL(urlAddr);conn = ((HttpURLConnection) url.openConnection());conn.setConnectTimeout(3000); conn.setReadTimeout(3000); conn.setDoOutput(true);conn.setRequestMethod("POST");conn.setUseCaches(false);conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");conn.setRequestProperty("Content-Length",String.valueOf(params.length()));conn.setDoInput(true);conn.connect();
OutputStreamWriter out = new OutputStreamWriter(conn.getOutputStream(), "UTF-8");out.write(params.toString());out.flush();out.close();
int code = conn.getResponseCode();if (code != 200) {log.info("ERROR===" + code);InputStream in = conn.getInputStream();br = new BufferedReader(new InputStreamReader(in, "UTF-8"));String line = "";while ((line = br.readLine()) != null)content = content + line + "\r\n";} else {InputStream in = conn.getInputStream();br = new BufferedReader(new InputStreamReader(in, "UTF-8"));String line = "";while ((line = br.readLine()) != null)content = content + line + "\r\n";}} catch (Exception e) { e.printStackTrace();log.error("urlAddr:"+urlAddr+" post error. ->" + params.toString(), e);} finally {if (conn!=null)conn.disconnect();if (br != null){ br.close();}}return content;}public static String sendPost(String urlAddr, Map<String, Object> paramMap, Map<String, Object> headerMap) throws Exception { String content = ""; HttpURLConnection conn = null; StringBuffer params = new StringBuffer(); Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator(); while (it.hasNext()) { Map.Entry<String, Object> element = (Map.Entry<String, Object>) it .next(); params.append((String) element.getKey()); params.append("="); params.append(element.getValue()); params.append("&"); }
if (params.length() > 0) { params.deleteCharAt(params.length() - 1); } BufferedReader br = null; try { URL url = new URL(urlAddr); conn = ((HttpURLConnection) url.openConnection()); conn.setConnectTimeout(3000); conn.setReadTimeout(3000); conn.setDoOutput(true); conn.setRequestMethod("POST"); conn.setUseCaches(false); conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded"); conn.setRequestProperty("Content-Length",String.valueOf(params.length())); Iterator<Map.Entry<String, Object>> iter = headerMap.entrySet().iterator(); while (iter.hasNext()) { Map.Entry<String, Object> element = (Map.Entry<String, Object>) iter .next(); conn.setRequestProperty(element.getKey(), (String)element.getValue()); } conn.setDoInput(true); conn.connect();
OutputStreamWriter out = new OutputStreamWriter( conn.getOutputStream(), "UTF-8"); out.write(params.toString()); out.flush(); out.close(); int code = conn.getResponseCode(); if (code != 200) { log.info("ERROR===" + code); InputStream in = conn.getInputStream();
br = new BufferedReader(new InputStreamReader( in, "UTF-8")); String line = ""; while ((line = br.readLine()) != null){ content = content + line + "\r\n"; } } else { InputStream in = conn.getInputStream(); br = new BufferedReader(new InputStreamReader(in, "UTF-8")); String line = ""; while ((line = br.readLine()) != null){ content = content + line + "\r\n"; } } log.info(urlAddr + "post info -->" + params.toString() + " result code: " + code + " , data : " + content); } catch (Exception e) { e.printStackTrace(); log.error("urlAddr:" + urlAddr+" post error.-> " + params.toString(), e); } finally { if (conn!=null) conn.disconnect(); if (br != null){ br.close(); } } return content; }public static String post(String urlAddr, Map<String, Object> paramMap, Map<String, Object> headerMap)throws Exception { String content = "";HttpURLConnection conn = null;StringBuffer params = new StringBuffer();Iterator<Map.Entry<String, Object>> it = paramMap.entrySet().iterator();while (it.hasNext()) {Map.Entry<String, Object> element = (Map.Entry<String, Object>) it.next();params.append((String) element.getKey());params.append("=");params.append(element.getValue());params.append("&");}
if (params.length() > 0) {params.deleteCharAt(params.length() - 1);}BufferedReader br = null;try {URL url = new URL(urlAddr);conn = ((HttpURLConnection) url.openConnection());conn.setConnectTimeout(3000);conn.setReadTimeout(3000); conn.setDoOutput(true);conn.setRequestMethod("POST");conn.setUseCaches(false);conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");conn.setRequestProperty("Content-Length",String.valueOf(params.length()));Iterator<Map.Entry<String, Object>> iter = headerMap.entrySet().iterator();while (iter.hasNext()) {Map.Entry<String, Object> element = (Map.Entry<String, Object>) iter.next();conn.setRequestProperty(element.getKey(),(String)element.getValue());}conn.setDoInput(true);conn.connect();
OutputStreamWriter out = new OutputStreamWriter(conn.getOutputStream(), "UTF-8");out.write(params.toString());out.flush();out.close();
int code = conn.getResponseCode();if (code != 200) {log.info("ERROR===" + code);InputStream in = conn.getInputStream();
br = new BufferedReader(new InputStreamReader(in, "UTF-8"));String line = "";while ((line = br.readLine()) != null)content = content + line + "\r\n";} else {InputStream in = conn.getInputStream();
br = new BufferedReader(new InputStreamReader(in, "UTF-8"));String line = "";while ((line = br.readLine()) != null)content = content + line + "\r\n";}} catch (Exception e) { e.printStackTrace();log.error("urlAddr:"+urlAddr+" post error.-> " + params.toString(), e);} finally {if (conn!=null) conn.disconnect();if (br != null){ br.close();}}return content;}
public static String post(String urlAddr, String json) throws Exception {String content = "";HttpURLConnection urlConnection = null;BufferedReader br = null;try { URL url = new URL(urlAddr); urlConnection = (HttpURLConnection) url.openConnection(); // 設置doOutput屬性為true表示將使用此urlConnection寫入數據 urlConnection.setDoOutput(true); urlConnection.setConnectTimeout(3000); urlConnection.setReadTimeout(3000); // 定義待寫入數據的內容類型，我們設置為application/x-www-form-urlencoded類型 urlConnection.setRequestProperty("content-type", "text/plain"); urlConnection.setRequestProperty("user-agent", "curl/7.12.1"); urlConnection.setRequestProperty("host", "data.zz.baidu.com"); urlConnection.setRequestProperty("content-length", String.valueOf(json.length()) ); // 得到請求的輸出流對象 OutputStreamWriter out = new OutputStreamWriter(urlConnection.getOutputStream()); // 把數據寫入請求的Body out.write(json); out.flush(); out.close();
int code = urlConnection.getResponseCode();if (code != 200) {log.info("urlAddr："+urlAddr+" code ERROR===" + code);} else {InputStream in = urlConnection.getInputStream();
br = new BufferedReader(new InputStreamReader(in, "UTF-8"));String line = "";while ((line = br.readLine()) != null)content = content + line + "\r\n";}} catch (Exception e) { e.printStackTrace();log.error("urlAddr:"+urlAddr+" post error->" + json, e);} finally { if (urlConnection!=null) urlConnection.disconnect(); if (br != null){ br.close(); }}return content;}public static String postBuiness(String urlAddr, String json) {String content = "";HttpURLConnection urlConnection = null;BufferedReader br = null;try { URL url = new URL(urlAddr); urlConnection = (HttpURLConnection) url.openConnection(); // 設置doOutput屬性為true表示將使用此urlConnection寫入數據 urlConnection.setDoOutput(true); // 定義待寫入數據的內容類型，我們設置為application/x-www-form-urlencoded類型 urlConnection.setRequestProperty("content-type", "text/plain"); urlConnection.setRequestProperty("user-agent", "curl/7.12.1"); urlConnection.setRequestProperty("host", "data.zz.baidu.com"); urlConnection.setRequestProperty("content-length", String.valueOf(json.length()) ); // 得到請求的輸出流對象 OutputStreamWriter out = new OutputStreamWriter(urlConnection.getOutputStream()); // 把數據寫入請求的Body out.write(json); out.flush(); out.close();
int code = urlConnection.getResponseCode();if (code != 200) {log.info("ERROR===" + code);} else {InputStream in = urlConnection.getInputStream();
br = new BufferedReader(new InputStreamReader(in, "UTF-8"));String line = "";while ((line = br.readLine()) != null)content = content + line + "\r\n";}} catch (Exception e) { e.printStackTrace();log.error("urlAddr:"+urlAddr+" post error->" + json, e);} finally { if(urlConnection!=null)urlConnection.disconnect(); if (br != null){ try { br.close(); } catch (IOException e) { e.printStackTrace(); } }} return content;}
public static void main(String[] args) throws Exception {//String urlAddr = "http://api.weibo.com/2/proxy/badges/issue.json";String ak = "4CZXhoWckYANMkvlCdZNy0kjtS4Aqjqk";//params.put("source", "2067112424");//params.put("uids", "2365944120");//params.put("badge_id", "sAFStotI");Map<String, Object> headers = new HashMap<String, Object>();// HttpClient client = new HttpClient();String urlAddr = "http://10.8.2.6:9200/_analyze?pretty&analyzer=ik_smart";String result = client.post(urlAddr, "感冒的時候，最不易吃哪些東西？？？");System.out.println(result);}}

http 請求類

相關推薦

HTTP請求類

fields readline nec phone 通用 line json utf-8 dsa package com.paytest.util; import java.io.BufferedReader; import java.io.IOException; im

http 請求類

con exce div urn open www main out ack package com.wenwo.platform.utils; import java.io.BufferedReader; import java.io.IOException; im

關於微信小程式後臺常用的http請求類

import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.net

c#模擬http請求類

public class HttpHelper { public static string Request(string url, Dictionary<string, dynamic> args, Encoding encod

Java異步執行多個HTTP請求的例子（需要apache http類庫）

ride 同步 conn done 例子 latch block org ftw 直接上代碼 package org.jivesoftware.spark.util; import java.io.IOException; import java.uti

HttpUtils 發送http請求工具類

encoding entryset closeable .get 調用 fig lin nal ping import java.io.IOException; import java.io.UnsupportedEncodingException; import jav

Java代碼調用HTTP請求工具類

style java face follow ebo win targe gin left 匾m睬守肪2w雲磷62炒ohttp://www.facebolw.com/space/2105109/follower k8r讜嗆此8孤jzhttp://www.facebolw.

【原創】標準HTTP請求工具類

dto case 開發 utf ignore pst new mar name 以下是個人在項目開發過程中，總結的Http請求工具類，主要包括四種： 1.處理http POST請求【XML格式、無解壓】； 2.處理http GET請求【XML格式、無解壓】

HTTP請求java工具類

package org.rd.cc.csr.util; import java.io.IOException; import java.nio.charset.Charset; import java.security.KeyManagementException; im

http請求長連線工具類

http請求長連線 import java.io.UnsupportedEncodingException; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.ap

HTTP協議八種請求類型介紹

發出 修改 不同 spa 特定 表單 位置 代理 新的 HTTP 協議中共定義了八種方法或者叫“動作”來表明對 Request-URI 指定的資源的不同操作方式，具體介紹如下： OPTIONS：返回服務器針對特定資源所支持的HTTP請求方法。也可以利用向Web服務器發送

Java http請求工具類

該工具類可以呼叫POST請求或者Get請求，引數以Map的方式傳入，支援獲獲取返回值，返回值接收型別為String  HttpRequestUtil.java package com.util; import java.io.BufferedReader;import java.io.IOEx

雲從科技人臉識別傳送http請求工具類

    下面程式碼為本人專案實際應用程式碼工具類： import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.OutputStream; import java.net

Http請求工具類(Java原生Form+Json)

package com.tzx.cc.common.constant.util; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputSt

常用工具類（二）：HttpUtil 傳送HTTP請求

常用工具類（二）：HttpUtil 傳送HTTP請求 public class HttpUtil { private static Logger logger = LoggerFactory.getLogger(HttpUtil.class); /** *

PHP利用socket傳送HTTP請求（封裝好的類）

<?php /**  * 使用PHP Socket 程式設計模擬Http post和get請求  * @author koma  */ class Http{   private $sp = "\r\n"; //這裡必須要寫成雙引號

MFC封裝CHttpClient類實現HTTP請求

MFC封裝CHttpClient類實現HTTP請求 環境 開發環境：Visual Studio 2010 字符集：使用多位元組字符集 標頭檔案 HttpClient.h #define IE_AGENT _T("Mozilla/4.0 (c

Java Http請求工具類和接收請求的方法

表面現像上面看看GET和POST的區別： 1.GET請求的資料會附在URL之後（就是把資料放置在HTTP協議頭中），以?分割URL和傳輸資料，引數之間以&相連，如：login.action?name=hyddd&password=idontknow&

Http請求工具類 httputil

package com.snowfigure.kits.net; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import

Java模仿http請求工具類

package ln; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.util.H