From 3ef873647802730134d0ff09035a4bea750b2cd5 Mon Sep 17 00:00:00 2001 From: xiang Date: Sun, 3 Aug 2025 17:44:07 +0800 Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E5=B7=A5=E5=85=B7=E7=B1=BB?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xiang/xservice/basic/utils/CurlUtils.java | 75 +++++++++++++++++++ .../xiang/xservice/basic/utils/HttpUtils.java | 25 ++++--- 2 files changed, 89 insertions(+), 11 deletions(-) create mode 100644 xservice-common/src/main/java/com/xiang/xservice/basic/utils/CurlUtils.java diff --git a/xservice-common/src/main/java/com/xiang/xservice/basic/utils/CurlUtils.java b/xservice-common/src/main/java/com/xiang/xservice/basic/utils/CurlUtils.java new file mode 100644 index 0000000..aee8bf6 --- /dev/null +++ b/xservice-common/src/main/java/com/xiang/xservice/basic/utils/CurlUtils.java @@ -0,0 +1,75 @@ +package com.xiang.xservice.basic.utils; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.nio.charset.StandardCharsets; +import java.util.HashMap; +import java.util.Map; + +public class CurlUtils { + + public static String doCurl(String url, Map headers, String requestBody, String requestMethod) throws IOException, InterruptedException { + String curlCommand = buildCurlCommand(url, headers, requestBody, requestMethod); + ProcessBuilder pb = new ProcessBuilder("cmd", "/c", curlCommand); + System.out.println(curlCommand); + pb.redirectErrorStream(true); + Process process = pb.start(); + // 打印输出 + try (BufferedReader reader = new BufferedReader( + new InputStreamReader(process.getInputStream(), StandardCharsets.UTF_8))) { + String line; + while ((line = reader.readLine()) != null) { + System.out.println(line); + } + } catch (IOException e) { + throw new RuntimeException(e); + } + + int exitCode = process.waitFor(); + System.out.println("Curl 执行完成，退出码: " + exitCode); + return exitCode + ""; + } + + private static String buildCurlCommand(String url, Map headers, String requestBody, String requestMethod) { + StringBuilder curl = new StringBuilder(); + curl.append("curl -X "); + curl.append(requestMethod).append(" "); + curl.append("'").append(url).append("' "); + + // 添加 headers + for (Map.Entry entry : headers.entrySet()) { + curl.append("-H ") + .append("'") + .append(entry.getKey()).append(": ").append(entry.getValue()) + .append("' "); + } + + // 添加 body（需处理引号转义） + if (requestBody != null && !requestBody.isEmpty()) { + requestBody = requestBody.replace("'", "'\"'\"'"); // 处理单引号冲突 + curl.append("--data ") + .append("'").append(requestBody).append("'"); + } + + return curl.toString(); + } + + public static void main(String[] args) throws IOException, InterruptedException { + Map headers = new HashMap(); + headers.put("Host", "api.livelab.com.cn"); + headers.put("Connection", "keep-alive"); + headers.put("Content-Length", "316"); + headers.put("platform-type", "%E7%BA%B7%E7%8E%A9%E5%B2%9B%E5%BE%AE%E4%BF%A1%E5%B0%8F%E7%A8%8B%E5%BA%8F"); + headers.put("content-type", "application/json"); + headers.put("x-fwd-anonymousId", "ocXac5C25MY5O3UM_EfL0oTgm7Jw"); + headers.put("platform-version", "3.12.0"); + headers.put("Authorization", "Bearer eyJhbGciOiJIUzUxMiJ9.eyJjdCI6MTc1MjYzODAwNTUxNywic3ViIjoiTDIxMTQzMjU2NDEiLCJhdWQiOiJMSVZFTEFCIiwiaXNzIjoiVElDS0VUIiwibWlkIjoxNzU4ODA4NTcxMzgzNjcxNTUzLCJ0eXBlIjoiYXBwbGV0IiwiaWF0IjoxNzUyNjM4MDA1LCJkaWQiOiI2RTRDMDQ5RS00RkFBLTQ0NDMtQjI3NC1DNjRBMjZEMUFGNTkiLCJrZXkiOiJMSVZFTEFCIn0.iw1u3LyCYlxYCI1gMwTeuJlPdv-rQKCVlO2ySF_UrJ-Bearer eyJhbGciOiJIUzUxMiJ9.eyJjdCI6MTc1Mzg4NTc5MDg3MSwic3ViIjoiTDIxMTQzMjU2NDEiLCJhdWQiOiJMSVZFTEFCIiwiaXNzIjoiVElDS0VUIiwibWlkIjoxNzU4ODA4NTcxMzgzNjcxNTUzLCJ0eXBlIjoiYXBwbGV0IiwiaWF0IjoxNzUzODg1NzkwLCJkaWQiOiI2RTRDMDQ5RS00RkFBLTQ0NDMtQjI3NC1DNjRBMjZEMUFGNTkiLCJrZXkiOiJMSVZFTEFCIn0.kZU8hyK1_ubuRnE8QpqzYydFER6Zi43uV-T8rbACS21f-YXote4-bURPDzq3K3H-GLdApyO-pPlZSQYXivOd1g"); + headers.put("Accept-Encoding", "gzip,compress,br,deflate"); + headers.put("User-Agent", "Mozilla/5.0 (iPhone; CPU iPhone OS 18_5 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 MicroMessenger/8.0.61(0x18003d30) NetType/4G Language/zh_CN"); + headers.put("Referer", "https://servicewechat.com/wx5a8f481d967649eb/114/page-frame.html"); + String json = "{\"audienceCount\":4,\"blackBox\":\"0\",\"combineTicketVos\":null,\"contactName\":\"朱吉祥\",\"contactPhone\":\"15858717571\",\"deliveryType\":1,\"frequentIds\":[50438548,35320661,50436621,50442739],\"ordinaryTicketVos\":null,\"payment\":3520.00,\"performId\":2395,\"privilegeCodeList\":[],\"projectId\":\"8763381795\",\"seatPlanIds\":[12091],\"totalPrice\":3520.00}"; + String post = CurlUtils.doCurl("https://api.livelab.com.cn/order/app/center/v3/create", headers, json, "POST"); + System.out.println(post); + } +} diff --git a/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java b/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java index 3ce7c3a..947d6cd 100644 --- a/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java +++ b/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java @@ -28,8 +28,8 @@ import java.util.concurrent.TimeUnit; public class HttpUtils { private static final int socketTimeOut = 5000; - private static final int connectTimeout = 5000; - private static final int connectionRequestTimeout = 5000; + private static final int connectTimeout = 10000; + private static final int connectionRequestTimeout = 3000; private static final int defaultMaxPerRoute = 20; private static final int maxTotal = 100; @@ -118,21 +118,24 @@ public class HttpUtils { CloseableHttpResponse response = null; String result = ""; try { - StringBuilder requestUrl = new StringBuilder(url); + String request = ""; if (MapUtils.isNotEmpty(param)) { - requestUrl.append("?"); - param.forEach((k, v) -> requestUrl.append(k).append("=").append(v).append("&")); - // 去掉最后一个 & - requestUrl.setLength(requestUrl.length() - 1); + StringBuilder req = new StringBuilder("?"); + for (Map.Entry entry : param.entrySet()) { + req.append(entry.getKey()).append("=").append(entry.getValue()).append("&"); + } + request = req.substring(0, req.length() - 1); } - HttpGet httpGet = new HttpGet(requestUrl.toString()); + HttpGet httpGet = new HttpGet(url + request); httpGet.addHeader("Content-Type", "application/json"); + httpGet.setHeader("User-Agent", "Mozilla/5.0 (iPhone; CPU iPhone OS 18_5 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Mobile/15E148 MicroMessenger/8.0.61(0x18003d2e) NetType/WIFI Language/zh_CN"); if (MapUtils.isNotEmpty(header)) { - header.forEach(httpGet::setHeader); + for (Map.Entry entry : header.entrySet()) { + httpGet.setHeader(entry.getKey(), entry.getValue()); + } } - - log.info("doGet请求：请求地址：{}", requestUrl); + log.info("doGet请求：请求地址：{}", url + request); response = httpClient.execute(httpGet); result = EntityUtils.toString(response.getEntity(), "utf-8"); } catch (Exception e) {