Java，get/post请求

Posted 2021-01-21 南方的墙

URLConnection

package com.shuzf.http;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLConnection;

public class HttpRequestURLConnection {

    /**
     * 向指定URL发送GET方法的请求
     * 
     * @param url   发送请求的URL
     * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
     * @return URL 所代表远程资源的响应结果
     */
    public static String sendGet(String url, String param) {
        URLConnection conn = null;    
        BufferedReader in = null;
        String result = "";
        try {
            String strUrl= url + "?" + param;
            URL realUrl = new URL(strUrl);
            // 打开和URL之间的连接
            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();
            // 定义 BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(),"UTF-8"));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("发送GET请求出现异常！" + e);
            e.printStackTrace();
        }
        // 使用finally块来关闭输入流
        finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return result;
    }

    /**
     * 向指定 URL 发送POST方法的请求
     * 
     * @param url   发送请求的 URL
     * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
     * @return 所代表远程资源的响应结果
     */
    public static String sendPost(String url, String param) {
        URLConnection conn = null;
        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        try {
            URL realUrl = new URL(url);
            // 打开和URL之间的连接
            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)");
            // 发送POST请求必须设置如下两行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 获取URLConnection对象对应的输出流
            out = new PrintWriter(conn.getOutputStream());
            // 发送请求参数
            out.print(param);
            //flush输出流的缓冲
            out.flush();
            // 定义BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(),"UTF-8"));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("发送 POST 请求出现异常！" + e);
            e.printStackTrace();
        }
        // 使用finally块来关闭输出流、输入流
        finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        return result;
    }

    public static void main(String[] args) {
        //发送 GET 请求
        String s=HttpRequestURLConnection.sendGet("http://www.baidu.com/abc", "key=123&v=456");
        System.out.println(s);
        
        //发送 POST 请求
        String sr=HttpRequestURLConnection.sendPost("http://www.baidu.com/abc", "key=123&v=456");
        System.out.println(sr);
    }
}

 

HttpURLConnection

package com.shuzf.http;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.List;
import java.util.Map;


public final class HttpRequestHttpURLConnection {

    //charset=utf-8 必须要，不然会出现乱码
    public static String CONTENT_TYPE_FORM_URLENCODED = "application/x-www-form-urlencoded;charset=utf-8";
    public static String CONTENT_TYPE_FORM_DATA = "multipart/form-data;charset=utf-8";
    public static String CONTENT_TYPE_JSON = "application/json;charset=utf-8";
    public static String CONTENT_TYPE_PLAIN = "text/plain;charset=utf-8";
     
    //输出所有响应头字段
    private static void headersInfo(HttpURLConnection conn) {
        Map<String, List<String>> map = conn.getHeaderFields();
        // 遍历所有响应头字段
        for (String key : map.keySet()) {
            System.out.println(key + "--->" + map.get(key));
        }
    }
    
    //输出响应信息
    private static void ResponseHeadersInfo(HttpURLConnection conn, URL url) throws IOException {
        System.out.println("conn.getResponseCode():" + conn.getResponseCode());
        System.out.println("conn.getURL():" + conn.getURL());
        System.out.println("conn.getRequestMethod():" + conn.getRequestMethod());
        System.out.println("conn.getContentType():" + conn.getContentType());
        System.out.println("conn.getReadTimeout():" + conn.getReadTimeout());
        System.out.println("conn.getResponseMessage():" + conn.getResponseMessage());
        System.out.println("url.getDefaultPort():" + url.getDefaultPort());
        System.out.println("url.getFile():" + url.getFile());
        System.out.println("url.getHost():" + url.getHost());
        System.out.println("url.getPath():" + url.getPath());
        System.out.println("url.getPort():" + url.getPort());
        System.out.println("url.getProtocol():" + url.getProtocol());
        System.out.println("url.getQuery():" + url.getQuery());
        System.out.println("url.getRef():" + url.getRef());
        System.out.println("url.getUserInfo():" + url.getUserInfo());
    }
   
    /**
     * @Name: get。
     * @Description: 发送get请求，并返回响应数据。
     * @Parameters: URL，要访问的url。
     * @Return: String，响应数据。
     */
    public static String get(String url) {

        HttpURLConnection conn = null;
        BufferedReader  in = null;

        try {
            // 把字符串转换为URL请求地址
            URL realUrl = new URL(url);
            // 打开连接
            conn = (HttpURLConnection)realUrl.openConnection();
            // 连接会话
            conn.connect();
            // 获取输入流
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
            String line;
            StringBuilder result = new StringBuilder();
            while ((line = in.readLine()) != null) {
                result.append(line);
            }
            return result.toString();

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                //关闭流
                if (in != null) {
                    in.close();
                }
                // 销毁连接
                if (conn != null) {
                    conn.disconnect();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

    /**
     * post。
     * @Description: 发送post请求，并返回响应数据。
     * @Parameters: URL，要访问的url。
     * @Parameters: parms，访问参数,Map形式。
     * @Return: String，响应数据。
     */
    public static String post(String URL, Map<String, String> params) {
        StringBuilder parm = new StringBuilder();
        //IsEmpty()是Java中用于判断某种容器是否有元素的系统库函数
        if (params != null && !params.isEmpty()) {
            for (Map.Entry<String, String> entry : params.entrySet()) {
                parm.append(entry.getKey()).append("=").append(entry.getValue()).append("&");
            }
        }
        return post(URL, parm.toString());
    }
      
    /**
     * @Name: post。
     * @Description: 发送post请求，并返回响应数据。
     * @Parameters: URL，要访问的url。
     * @Parameters: parm，访问参数。
     * @Return: String，响应数据。
     */
    public static String post(String url, String parm) {

        HttpURLConnection conn = null;
        // 数据输出流，输出参数信息
        DataOutputStream out = null;
        // 数据输入流，处理服务器响应数据
        BufferedReader in = null;

        try {
            URL realUrl = new URL(url);

            // 将url以open方法返回的urlConnection连接强转为HttpURLConnection连接(标识一个url所引用的远程对象连接)
            // 此时cnnection只是为一个连接对象,待连接中
            conn = (HttpURLConnection) realUrl.openConnection();

            // 设置连接输出流为true,默认false (post请求是以流的方式隐式的传递参数)
            conn.setDoOutput(true);
            // 设置连接输入流为true
            conn.setDoInput(true);
            // 设置请求方式为post
            conn.setRequestMethod("POST");
            // post请求缓存设为false
            conn.setUseCaches(false);
            // 设置该HttpURLConnection实例是否自动执行重定向
            conn.setInstanceFollowRedirects(true);

            // 设置内容的类型,设置为经过urlEncoded编码过的from参数
            conn.setRequestProperty("Content-Type", HttpRequestHttpURLConnection.CONTENT_TYPE_FORM_URLENCODED);
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible;MSIE 6.0; Windows NT 5.1;SV1)");

            // 建立连接
            // (请求未开始,直到connection.getInputStream()方法调用时才发起,以上各个参数设置需在此方法之前进行)
            conn.connect();

            // 创建输入输出流,用于往连接里面输出携带的参数,(输出内容为?后面的内容)
            out = new DataOutputStream(conn.getOutputStream());
            // 向对象输出流写出数据，这些数据将存到内存缓冲区中
            out.writeBytes(parm != null ? parm : "");
            // 刷新对象输出流，将任何字节都写入潜在的流中
            out.flush();
            
            //输出响应信息
            ResponseHeadersInfo(conn, realUrl);

            // 连接发起请求,处理服务器响应 (从连接获取到输入流并包装为bufferedReader)
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
            String line;
            // 用来存储响应数据
            StringBuilder result = new StringBuilder();
            // 循环读取流
            while ((line = in.readLine()) != null) {
                result .append(line).append(System.getProperty("line.separator"));
            }
            return result.toString();

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                //关闭流
                if (out != null) {
                    out.close();
                }
              //关闭流
                if (in != null) {
                    in.close();
                }
                // 销毁连接
                if (conn != null) {
                    conn.disconnect();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return null;
    }
    
    public static void main(String[] args) {
        String result = post("http://vehicle.test.qingmiaojituan.com/api/user/info", "token=Vk1fMjAxODAzMTMxNDE0NDVfNDQ5MjU4N18zNDYyNTE%3D");
        System.out.println("
" + result);
    }
}