OP030-two/src/com/mes/util/HttpUtils.java

package com.mes.util;

import com.mes.ui.MesClient;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URISyntaxException;
import java.net.URL;

public class HttpUtils {
	/**
	 * HTTP请求，正确报文解析，并保存数据到生产记录数据
	 * @return 
	 * @throws URISyntaxException
	 */
    //http post请求
    public static String sendRequest(String urlParam) {
        urlParam = appendSid(urlParam);
		String requestType = "POST";
        //根据接收内容返回数据结果
    	String ret = "";
    	System.out.println(urlParam);
        HttpURLConnection con = null;
        BufferedReader buffer = null;
        StringBuffer resultBuffer = null;
        try {
            URL url = new URL(urlParam);
            //得到连接对象
            con = (HttpURLConnection) url.openConnection();
            //设置请求类型
            con.setRequestMethod(requestType);
            //设置请求需要返回的数据类型和字符集类型
            con.setRequestProperty("Content-Type", "application/json;charset=GBK");  
            //允许写出
            con.setDoOutput(true);
            //允许读入
            con.setDoInput(true);
            //不使用缓存
            con.setUseCaches(false);
            //得到响应码
            int responseCode = con.getResponseCode();
            System.out.println("responseCode="+responseCode);
            if(responseCode == HttpURLConnection.HTTP_OK){
                //得到响应流
                InputStream inputStream = con.getInputStream();
                //将响应流转换成字符串
                resultBuffer = new StringBuffer();
                String line;
                buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
                while ((line = buffer.readLine()) != null) {
                    resultBuffer.append(line);
                }
                System.out.println(resultBuffer.toString());
                ret = resultBuffer.toString();
            }else {
            	//ret = String.valueOf(responseCode);
            	ret = "false";
            }
            con.disconnect();
        }catch(Exception e) {
        	//ret = false;
        	//System.out.println("e.toString()="+e.toString());
        	//return e.toString();
            //e.printStackTrace();
        	ret = "false";
        }
        return ret;
    }


    public static String sendPostRequest(String urlParam, String params) {
        urlParam = appendSid(urlParam);
        String requestType = "POST";
        //根据接收内容返回数据结果
        String ret = "";
        System.out.println(urlParam);
        HttpURLConnection con = null;
        BufferedReader buffer = null;
        StringBuffer resultBuffer = null;
        try {
            URL url = new URL(urlParam);
            //得到连接对象
            con = (HttpURLConnection) url.openConnection();
            //设置请求类型
            con.setRequestMethod(requestType);
            //设置请求需要返回的数据类型和字符集类型
            con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=GBK");
            //允许写出
            con.setDoOutput(true);
            //允许读入
            con.setDoInput(true);
            //不使用缓存
            con.setUseCaches(false);

            // 获取URLConnection对象对应的输出流
            OutputStreamWriter out = new OutputStreamWriter( con.getOutputStream(),"UTF-8");// utf-8编码
            // 发送请求参数
            out.write(params);

            //得到响应码
            int responseCode = con.getResponseCode();
            System.out.println("responseCode="+responseCode);
            if(responseCode == HttpURLConnection.HTTP_OK){
                //得到响应流
                InputStream inputStream = con.getInputStream();
                //将响应流转换成字符串
                resultBuffer = new StringBuffer();
                String line;
                buffer = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
                while ((line = buffer.readLine()) != null) {
                    resultBuffer.append(line);
                }
                System.out.println(resultBuffer.toString());
                ret = resultBuffer.toString();
            }else {
                //ret = String.valueOf(responseCode);
                ret = "false";
            }
            con.disconnect();
        }catch(Exception e) {
            //ret = false;
            //System.out.println("e.toString()="+e.toString());
            //return e.toString();
            //e.printStackTrace();
            ret = "false";
        }
        return ret;
    }

    public static String sendPostRequestJson(String apiUrl, String jsonData) throws IOException {
        apiUrl = appendSid(apiUrl);
        URL url = new URL(apiUrl);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setRequestMethod("POST");
        conn.setRequestProperty("Content-Type", "application/json");
        conn.setDoOutput(true);

        // 发送请求数据
        try (OutputStream os = conn.getOutputStream()) {
            byte[] input = jsonData.getBytes("utf-8");
            os.write(input, 0, input.length);
        }

        // 获取响应数据
        StringBuilder response = new StringBuilder();
        int responseCode = conn.getResponseCode();
//        System.out.println("Sending POST request to URL: " + apiUrl);
//        System.out.println("Post parameters: " + jsonData);
//        System.out.println("Response Code: " + responseCode);

        try (BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"))) {
            String responseLine;
            while ((responseLine = br.readLine()) != null) {
                response.append(responseLine.trim());
            }
        }

        conn.disconnect();
        return response.toString();
    }

    public static String sendGetRequestWithHeader(String apiUrl, String headerKey, String headerValue) throws IOException {
        URL url = new URL(apiUrl);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setRequestMethod("GET");
        conn.setRequestProperty(headerKey, headerValue);
        conn.setDoInput(true);
        conn.setUseCaches(false);

        int responseCode = conn.getResponseCode();
        InputStream inputStream = responseCode >= 200 && responseCode < 300
                ? conn.getInputStream()
                : conn.getErrorStream();
        if (inputStream == null) {
            conn.disconnect();
            return "false";
        }

        StringBuilder response = new StringBuilder();
        try (BufferedReader br = new BufferedReader(new InputStreamReader(inputStream, "utf-8"))) {
            String responseLine;
            while ((responseLine = br.readLine()) != null) {
                response.append(responseLine.trim());
            }
        }

        conn.disconnect();
        if (responseCode < 200 || responseCode >= 300) {
            return "false";
        }
        return response.toString();
    }


	


    private static String appendSid(String url) {
        if (url == null || url.contains("__sid=") || url.contains("/login")) {
            return url;
        }
        try {
            String sid = MesClient.sessionid;
            if (sid == null || sid.length() == 0) {
                return url;
            }
            return url + (url.contains("?") ? "&" : "?") + "__sid=" + sid;
        } catch (Exception e) {
            return url;
        }
    }

}