Merge remote-tracking branch 'origin/dev_New' into dev_New

liyong

7 小时以前 1cf91e355038837f30f2d727507b2229263d7de7

 src/main/java/com/ruoyi/common/utils/http/HttpUtils.java

@@ -9,6 +9,7 @@
import java.net.SocketTimeoutException;

import java.net.URL;

import java.net.URLConnection;

import java.nio.charset.StandardCharsets;

import java.security.cert.X509Certificate;

import javax.net.ssl.HostnameVerifier;

import javax.net.ssl.HttpsURLConnection;

@@ -20,6 +21,7 @@
import org.slf4j.LoggerFactory;

import com.ruoyi.common.constant.Constants;

import com.ruoyi.common.utils.StringUtils;

import org.springframework.http.MediaType;



/**

 * 通用http发送方法

@@ -73,7 +75,7 @@
            URLConnection connection = realUrl.openConnection();

            connection.setRequestProperty("accept", "*/*");

            connection.setRequestProperty("connection", "Keep-Alive");

            connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");

            connection.setRequestProperty("user-agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64)");

            connection.connect();

            in = new BufferedReader(new InputStreamReader(connection.getInputStream(), contentType));

            String line;

@@ -125,26 +127,38 @@
     */

    public static String sendPost(String url, String param)

    {

        return sendPost(url, param, MediaType.APPLICATION_FORM_URLENCODED_VALUE);

    }



    /**

     * 向指定 URL 发送POST方法的请求

     * 
     * @param url 发送请求的 URL

     * @param param 请求参数

     * @param contentType 内容类型

     * @return 所代表远程资源的响应结果

     */

    public static String sendPost(String url, String param, String contentType)

    {

        PrintWriter out = null;

        BufferedReader in = null;

        StringBuilder result = new StringBuilder();

        try

        {

            String urlNameString = url;

            log.info("sendPost - {}", urlNameString);

            URL realUrl = new URL(urlNameString);

            log.info("sendPost - {}", url);

            URL realUrl = new 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.setRequestProperty("user-agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64)");

            conn.setRequestProperty("Accept-Charset", "utf-8");

            conn.setRequestProperty("contentType", "utf-8");

            conn.setRequestProperty("Content-Type", contentType);

            conn.setDoOutput(true);

            conn.setDoInput(true);

            out = new PrintWriter(conn.getOutputStream());

            out.print(param);

            out.flush();

            in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "utf-8"));

            in = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8));

            String line;

            while ((line = in.readLine()) != null)

            {

@@ -191,6 +205,11 @@


    public static String sendSSLPost(String url, String param)

    {

        return sendSSLPost(url, param, MediaType.APPLICATION_FORM_URLENCODED_VALUE);

    }



    public static String sendSSLPost(String url, String param, String contentType)

    {

        StringBuilder result = new StringBuilder();

        String urlNameString = url + "?" + param;

        try

@@ -202,9 +221,9 @@
            HttpsURLConnection conn = (HttpsURLConnection) console.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.setRequestProperty("user-agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64)");

            conn.setRequestProperty("Accept-Charset", "utf-8");

            conn.setRequestProperty("contentType", "utf-8");

            conn.setRequestProperty("Content-Type", contentType);

            conn.setDoOutput(true);

            conn.setDoInput(true);



@@ -218,7 +237,7 @@
            {

                if (ret != null && !"".equals(ret.trim()))

                {

                    result.append(new String(ret.getBytes("ISO-8859-1"), "utf-8"));

                    result.append(new String(ret.getBytes(StandardCharsets.ISO_8859_1), StandardCharsets.UTF_8));

                }

            }

            log.info("recv - {}", result);

@@ -271,4 +290,93 @@
            return true;

        }

    }



    /**

     * 向指定URL发送JSON格式的POST请求（推荐通用方法，默认UTF-8编码）

     * @param url 发送请求的URL

     * @param jsonParam JSON格式的请求参数（直接传入JSON字符串）

     * @return 远程资源的响应结果

     */

    public static String sendPostJson(String url, String jsonParam) {

        // 重载调用，默认使用UTF-8编码，Content-Type固定为application/json

        return sendPostJson(url, jsonParam, StandardCharsets.UTF_8.name(),null);

    }



    /**

     * 向指定URL发送JSON格式的POST请求（自定义编码，灵活适配特殊场景）

     * @param url 发送请求的URL

     * @param jsonParam JSON格式的请求参数（直接传入JSON字符串）

     * @param headerValue 请求头的值

     * @return 远程资源的响应结果

     */

    public static String sendPostJson(String url, String jsonParam, String headerValue) {

        // 重载调用，默认使用UTF-8编码，Content-Type固定为application/json

        return sendPostJson(url, jsonParam, StandardCharsets.UTF_8.name(),headerValue);

    }



    /**

     * 向指定URL发送JSON格式的POST请求（自定义编码，灵活适配特殊场景）

     * @param url 发送请求的URL

     * @param jsonParam JSON格式的请求参数（直接传入JSON字符串）

     * @param charset 编码类型（如UTF-8、GBK等，建议使用StandardCharsets常量）

     * @return 远程资源的响应结果

     */

    public static String sendPostJson(String url, String jsonParam, String charset,String headerValue) {

        PrintWriter out = null;

        BufferedReader in = null;

        StringBuilder result = new StringBuilder();

        try {

            log.info("sendPostJson - {}", url);

            URL realUrl = new URL(url);

            URLConnection conn = realUrl.openConnection();



            // 1. 设置请求头：固定Content-Type为application/json，适配JSON传参规范

            conn.setRequestProperty("accept", "*/*");

            conn.setRequestProperty("connection", "Keep-Alive");

            conn.setRequestProperty("user-agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64)");

            conn.setRequestProperty("Content-Type", MediaType.APPLICATION_JSON_VALUE); // 核心：JSON专属Content-Type

            conn.setRequestProperty("Accept-Charset", charset);

            // 1.1 设置请求头：可选，根据实际需要设置

            if(StringUtils.isNotEmpty(headerValue)){

                conn.setRequestProperty("Authorization", headerValue);

            }

            // 2. 开启输入输出流（POST请求必须）

            conn.setDoOutput(true);

            conn.setDoInput(true);



            // 3. 写入JSON参数（使用指定编码，避免中文乱码）

            out = new PrintWriter(conn.getOutputStream(), true);

            out.print(jsonParam);

            out.flush();



            // 4. 读取响应结果（与请求编码一致，保证解析正确）

            in = new BufferedReader(new InputStreamReader(conn.getInputStream(), charset));

            String line;

            while ((line = in.readLine()) != null) {

                result.append(line);

            }

            log.info("recv - {}", result);

        } catch (ConnectException e) {

            log.error("调用HttpUtils.sendPostJson ConnectException, url=" + url + ",jsonParam=" + jsonParam, e);

        } catch (SocketTimeoutException e) {

            log.error("调用HttpUtils.sendPostJson SocketTimeoutException, url=" + url + ",jsonParam=" + jsonParam, e);

        } catch (IOException e) {

            log.error("调用HttpUtils.sendPostJson IOException, url=" + url + ",jsonParam=" + jsonParam, e);

        } catch (Exception e) {

            log.error("调用HttpUtils.sendPostJson Exception, url=" + url + ",jsonParam=" + jsonParam, e);

        } finally {

            // 5. 关闭流资源（避免内存泄漏，与原代码finally逻辑保持一致）

            try {

                if (out != null) {

                    out.close();

                }

                if (in != null) {

                    in.close();

                }

            } catch (IOException ex) {

                log.error("调用流关闭异常 sendPostJson, url=" + url + ",jsonParam=" + jsonParam, ex);

            }

        }

        return result.toString();

    }

}