package com.mes.util; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.*; import java.net.HttpURLConnection; import java.net.URISyntaxException; import java.net.URL; import java.nio.charset.StandardCharsets; public class HttpUtils { public static final Logger log = LoggerFactory.getLogger(HttpUtils.class); /** * HTTP请求，正确报文解析，并保存数据到生产记录数据 * @return * @throws URISyntaxException */ //http post请求 public static String sendRequest(String urlParam) { String requestType = "POST"; //根据接收内容返回数据结果 String ret = ""; log.info("http请求路径: {}", 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(); if(responseCode == HttpURLConnection.HTTP_OK){ //得到响应流 InputStream inputStream = con.getInputStream(); //将响应流转换成字符串 resultBuffer = new StringBuffer(); String line; buffer = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8)); while ((line = buffer.readLine()) != null) { resultBuffer.append(line); } log.info("http响应结果: {}", resultBuffer); ret = resultBuffer.toString(); }else { //ret = String.valueOf(responseCode); ret = "false"; } con.disconnect(); }catch(Exception e) { ret = "false"; } return ret; } public static String sendPostRequest(String urlParam, String params) { String requestType = "POST"; //根据接收内容返回数据结果 String ret = ""; log.info("http请求路径: {}", 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(); 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); } log.info("http响应结果: {}", resultBuffer); ret = resultBuffer.toString(); }else { //ret = String.valueOf(responseCode); ret = "false"; } con.disconnect(); }catch(Exception e) { ret = "false"; } return ret; } public static String sendPostRequestJson(String apiUrl, String jsonData) throws IOException { 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(); } /** * 发送 JSON 格式的 POST 请求 * * @param urlString 目标 URL * @param jsonInput JSON 请求体 * @param timeoutMs 连接和读取超时时间（毫秒） * @return 响应内容（JSON 字符串），失败时返回 null */ public static String sendJsonPost(String urlString, String jsonInput, int timeoutMs) { HttpURLConnection conn = null; try { // 1. 创建连接 URL url = new URL(urlString); conn = (HttpURLConnection) url.openConnection(); // 2. 配置请求参数 conn.setRequestMethod("POST"); conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8"); conn.setRequestProperty("Accept", "application/json"); conn.setConnectTimeout(timeoutMs); conn.setReadTimeout(timeoutMs); conn.setDoOutput(true); // 允许写入请求体 // 3. 发送 JSON 数据 try (OutputStream os = conn.getOutputStream()) { byte[] input = jsonInput.getBytes(StandardCharsets.UTF_8); os.write(input, 0, input.length); } // 4. 处理响应 int status = conn.getResponseCode(); if (status >= 200 && status < 300) { // 读取成功响应流 try (InputStream is = conn.getInputStream(); BufferedReader br = new BufferedReader( new InputStreamReader(is, StandardCharsets.UTF_8))) { StringBuilder response = new StringBuilder(); String line; while ((line = br.readLine()) != null) { response.append(line); } return response.toString(); } } else { // 读取错误流（部分服务器将错误信息放在错误流中） try (InputStream es = conn.getErrorStream(); BufferedReader br = new BufferedReader( new InputStreamReader(es, StandardCharsets.UTF_8))) { StringBuilder errorResponse = new StringBuilder(); String line; while ((line = br.readLine()) != null) { errorResponse.append(line); } log.error("HTTP Error {}: {}", status, errorResponse.toString()); } return null; } } catch (Exception e) { log.error("http请求失败", e); return null; } finally { if (conn != null) { conn.disconnect(); // 关闭连接 } } } /** * 发送 JSON 格式的 POST 请求 * * @param urlString 目标 URL * @param jsonInput JSON 请求体 * @return 响应内容（JSON 字符串），失败时返回 null */ public static String sendJsonPost(String urlString, String jsonInput) { return sendJsonPost(urlString, jsonInput, 5000); } }