parser发布到maven central方便开发者依赖, pom文件结构调整

2026-08-31 13:59:05 +00:00 · 2025-10-16 18:08:03 +08:00
parent eb06eb9f3d
commit c16bde6bb8
9 changed files with 642 additions and 101 deletions
@@ -0,0 +1,128 @@
+package cn.qaiu.util;
+
+import io.vertx.core.buffer.Buffer;
+import io.vertx.core.http.HttpHeaders;
+import io.vertx.ext.web.client.HttpResponse;
+import io.vertx.core.json.JsonObject;
+//import org.brotli.dec.BrotliInputStream;
+import org.brotli.dec.BrotliInputStream;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.*;
+import java.nio.charset.StandardCharsets;
+import java.util.zip.GZIPInputStream;
+import java.util.zip.Inflater;
+import java.util.zip.InflaterInputStream;
+
+public class HttpResponseHelper {
+    static Logger LOGGER = LoggerFactory.getLogger(HttpResponseHelper.class);
+
+    // -------------------- 公共方法 --------------------
+    public static String asText(HttpResponse<?> res) {
+        String encoding = res.getHeader(HttpHeaders.CONTENT_ENCODING.toString());
+        try {
+            Buffer body = toBuffer(res);
+            if (encoding == null || "identity".equalsIgnoreCase(encoding)) {
+                return body.toString(StandardCharsets.UTF_8);
+            }
+            return decompress(body, encoding);
+        } catch (Exception e) {
+            LOGGER.error("asText: {}", e.getMessage(), e);
+            return null;
+        }
+    }
+
+    public static JsonObject asJson(HttpResponse<?> res) {
+        try {
+            String text = asText(res);
+            if (text != null) {
+                return new JsonObject(text);
+            } else  {
+                LOGGER.error("asJson: asText响应数据为空");
+                return JsonObject.of();
+            }
+        } catch (Exception e) {
+            LOGGER.error("asJson: {}", e.getMessage(), e);
+            return JsonObject.of();
+        }
+    }
+
+    // -------------------- Buffer 转换 --------------------
+    private static Buffer toBuffer(HttpResponse<?> res) {
+        return res.body() instanceof Buffer ? (Buffer) res.body() : Buffer.buffer(res.bodyAsString());
+    }
+
+    // -------------------- 通用解压分发 --------------------
+    private static String decompress(Buffer compressed, String encoding) throws IOException {
+        return switch (encoding.toLowerCase()) {
+            case "gzip" -> decompressGzip(compressed);
+            case "deflate" -> decompressDeflate(compressed);
+            case "br" -> decompressBrotli(compressed);
+            //case "zstd" -> decompressZstd(compressed);
+            default -> throw new UnsupportedOperationException("不支持的 Content-Encoding: " + encoding);
+        };
+    }
+
+    // -------------------- gzip --------------------
+    private static String decompressGzip(Buffer compressed) throws IOException {
+        try (ByteArrayInputStream bais = new ByteArrayInputStream(compressed.getBytes());
+             GZIPInputStream gzis = new GZIPInputStream(bais);
+             InputStreamReader isr = new InputStreamReader(gzis, StandardCharsets.UTF_8);
+             StringWriter writer = new StringWriter()) {
+
+            char[] buffer = new char[4096];
+            int n;
+            while ((n = isr.read(buffer)) != -1) {
+                writer.write(buffer, 0, n);
+            }
+            return writer.toString();
+        }
+    }
+
+    // -------------------- deflate --------------------
+    private static String decompressDeflate(Buffer compressed) throws IOException {
+        byte[] bytes = compressed.getBytes();
+        try {
+            return inflate(bytes, false); // zlib 包裹
+        } catch (IOException e) {
+            return inflate(bytes, true); // 裸 deflate
+        }
+    }
+
+    private static String inflate(byte[] data, boolean nowrap) throws IOException {
+        try (ByteArrayInputStream bais = new ByteArrayInputStream(data);
+             InflaterInputStream iis = new InflaterInputStream(bais, new Inflater(nowrap));
+             InputStreamReader isr = new InputStreamReader(iis, StandardCharsets.UTF_8);
+             StringWriter writer = new StringWriter()) {
+
+            char[] buffer = new char[4096];
+            int n;
+            while ((n = isr.read(buffer)) != -1) {
+                writer.write(buffer, 0, n);
+            }
+            return writer.toString();
+        }
+    }
+
+    // -------------------- Brotli --------------------
+    private static String decompressBrotli(Buffer compressed) throws IOException {
+        try (ByteArrayInputStream bais = new ByteArrayInputStream(compressed.getBytes());
+             BrotliInputStream bis = new BrotliInputStream(bais);
+             InputStreamReader isr = new InputStreamReader(bis, StandardCharsets.UTF_8);
+             StringWriter writer = new StringWriter()) {
+
+            char[] buffer = new char[4096];
+            int n;
+            while ((n = isr.read(buffer)) != -1) {
+                writer.write(buffer, 0, n);
+            }
+            return writer.toString();
+        }
+    }
+
+    // -------------------- Zstandard --------------------
+    private static String decompressZstd(Buffer compressed) {
+       throw new UnsupportedOperationException("Zstandard");
+    }
+}