liyong
7 小时以前 1cf91e355038837f30f2d727507b2229263d7de7
src/main/java/com/ruoyi/common/utils/http/HttpUtils.java
@@ -290,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();
    }
}