From ef7b9af9b78a5da4c23b95a517adad6fd6aa2f69 Mon Sep 17 00:00:00 2001 From: Timi Date: Mon, 16 Mar 2026 16:34:46 +0800 Subject: [PATCH 1/2] add bodyEntity --- .gitignore | 4 + pom.xml | 7 +- src/main/java/com/imyeyu/network/ArgMap.java | 174 +++++++++++++++--- .../com/imyeyu/network/CommonRequest.java | 6 + .../java/com/imyeyu/network/FileRequest.java | 15 +- .../java/com/imyeyu/network/GsonRequest.java | 7 + .../imyeyu/network/ProgressiveRequest.java | 12 ++ .../java/com/imyeyu/network/TimiRequest.java | 7 + .../com/imyeyu/network/test/ArgMapTest.java | 9 + 9 files changed, 215 insertions(+), 26 deletions(-) diff --git a/.gitignore b/.gitignore index 5ff6309..f3fc6e1 100644 --- a/.gitignore +++ b/.gitignore @@ -1,3 +1,7 @@ +AGENTS.md +CLAUDE.md +.claude + target/ !.mvn/wrapper/maven-wrapper.jar !**/src/main/**/target/ diff --git a/pom.xml b/pom.xml index 483a2d1..80157a7 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ com.imyeyu.network timi-network - 0.0.4 + 0.0.5 jar @@ -94,6 +94,11 @@ timi-io 0.0.2 + + org.apache.commons + commons-collections4 + 4.4 + org.apache.httpcomponents.client5 httpclient5-fluent diff --git a/src/main/java/com/imyeyu/network/ArgMap.java b/src/main/java/com/imyeyu/network/ArgMap.java index bbb8631..26dc051 100644 --- a/src/main/java/com/imyeyu/network/ArgMap.java +++ b/src/main/java/com/imyeyu/network/ArgMap.java @@ -1,40 +1,143 @@ package com.imyeyu.network; import com.imyeyu.utils.Encoder; +import org.apache.hc.client5.http.entity.mime.MultipartEntityBuilder; import org.apache.hc.client5.http.fluent.Form; +import org.apache.hc.core5.http.ContentType; +import org.apache.hc.core5.http.HttpEntity; import org.apache.hc.core5.http.NameValuePair; -import java.util.HashMap; +import java.io.File; +import java.io.InputStream; +import java.util.AbstractMap; +import java.util.ArrayList; +import java.util.Collections; import java.util.List; import java.util.Map; +import java.util.function.BiConsumer; /** - * HashMap 构建 {@link org.apache.hc.client5.http.fluent.Form} 参数列表 + * 请求参数列表。 + *

+ * 该实现允许同名 key 重复出现，适用于 query 参数和表单参数场景。 * * @author 夜雨 * @since 2025-06-26 15:41 */ -public class ArgMap extends HashMap { +public class ArgMap { + private final List> entries = new ArrayList<>(); + + /** + * 追加一个参数。 + * + * @param key 参数名 + * @param value 参数值 + * @return 当前对象 + */ + public ArgMap put(K key, V value) { + entries.add(new AbstractMap.SimpleImmutableEntry<>(key, value)); + return this; + } + + /** + * 按插入顺序遍历全部参数。 + * + * @param consumer 处理逻辑 + */ + public void forEach(BiConsumer consumer) { + entries.forEach(entry -> consumer.accept(entry.getKey(), entry.getValue())); + } + + /** + * 返回参数数量。 + * + * @return 参数数量 + */ + public int size() { + return entries.size(); + } + + /** + * 判断参数列表是否为空。 + * + * @return 是否为空 + */ + public boolean isEmpty() { + return entries.isEmpty(); + } + + /** + * 清空全部参数。 + */ + public void clear() { + entries.clear(); + } + + /** + * 返回只读参数视图。 + * + * @return 参数条目列表 + */ + public List> entries() { + return Collections.unmodifiableList(entries); + } + + /** + * 转换为 multipart 实体。 + * + * @return multipart 请求体 + */ + public HttpEntity toEntity() { + MultipartEntityBuilder builder = MultipartEntityBuilder.create(); + forEach((k, v) -> { + String key = k.toString(); + switch (v) { + case File file -> builder.addBinaryBody(key, file); + case byte[] bytes -> builder.addBinaryBody(key, bytes); + case InputStream stream -> builder.addBinaryBody(key, stream, ContentType.APPLICATION_OCTET_STREAM, key); + default -> builder.addTextBody(key, v.toString()); + } + }); + return builder.build(); + } + + /** + * 转换为表单参数列表。 + * + * @return 表单参数列表 + */ public List toNameValuePair() { Form form = Form.form(); - for (Map.Entry item : entrySet()) { - form.add(item.getKey().toString(), item.getValue().toString()); - } + forEach((k, v) -> form.add(k.toString(), v.toString())); return form.build(); } + /** + * 转换为 query string。 + * + * @return query string + */ public String toURL() { - StringBuilder sb = new StringBuilder(); - for (Map.Entry item : entrySet()) { - sb.append(item.getKey().toString()).append('=').append(Encoder.urlArg(item.getValue().toString())); - sb.append('&'); + if (isEmpty()) { + return ""; } + StringBuilder sb = new StringBuilder(); + forEach((k, v) -> sb.append(k.toString()).append('=').append(Encoder.urlArg(v.toString())).append('&')); sb.deleteCharAt(sb.length() - 1); return sb.toString(); } + /** + * 将参数拼接到指定 URL。 + * + * @param url 原始 URL + * @return 拼接后的 URL + */ public String toURL(String url) { + if (isEmpty()) { + return url; + } StringBuilder sb = new StringBuilder(url); if (url.contains("?")) { if (!url.endsWith("?") && !url.endsWith("&")) { @@ -42,29 +145,52 @@ public class ArgMap extends HashMap { } sb.append(toURL()); return sb.toString(); - } else { - return url + "?" + toURL(); } + return url + "?" + toURL(); } + /** + * 使用一组参数创建对象。 + * + * @param key 参数名 + * @param value 参数值 + * @param key 类型 + * @param value 类型 + * @return 参数对象 + */ public static ArgMap of(K key, V value) { - ArgMap map = new ArgMap<>(); - map.put(key, value); - return map; + return new ArgMap().put(key, value); } + /** + * 使用两组参数创建对象。 + * + * @param key1 参数名 1 + * @param value1 参数值 1 + * @param key2 参数名 2 + * @param value2 参数值 2 + * @param key 类型 + * @param value 类型 + * @return 参数对象 + */ public static ArgMap of(K key1, V value1, K key2, V value2) { - ArgMap map = new ArgMap<>(); - map.put(key1, value1); - map.put(key2, value2); - return map; + return new ArgMap().put(key1, value1).put(key2, value2); } + /** + * 使用三组参数创建对象。 + * + * @param key1 参数名 1 + * @param value1 参数值 1 + * @param key2 参数名 2 + * @param value2 参数值 2 + * @param key3 参数名 3 + * @param value3 参数值 3 + * @param key 类型 + * @param value 类型 + * @return 参数对象 + */ public static ArgMap of(K key1, V value1, K key2, V value2, K key3, V value3) { - ArgMap map = new ArgMap<>(); - map.put(key1, value1); - map.put(key2, value2); - map.put(key3, value3); - return map; + return new ArgMap().put(key1, value1).put(key2, value2).put(key3, value3); } } diff --git a/src/main/java/com/imyeyu/network/CommonRequest.java b/src/main/java/com/imyeyu/network/CommonRequest.java index 58b64a6..bfb9531 100644 --- a/src/main/java/com/imyeyu/network/CommonRequest.java +++ b/src/main/java/com/imyeyu/network/CommonRequest.java @@ -3,6 +3,7 @@ package com.imyeyu.network; import lombok.AccessLevel; import lombok.AllArgsConstructor; import org.apache.hc.client5.http.fluent.Request; +import org.apache.hc.core5.http.HttpEntity; import org.apache.hc.core5.util.Timeout; import java.io.IOException; @@ -49,6 +50,11 @@ public class CommonRequest { return this; } + public CommonRequest bodyEntity(HttpEntity entity) { + request.body(entity); + return this; + } + public String asString() throws IOException { return request.execute().returnContent().asString(); } diff --git a/src/main/java/com/imyeyu/network/FileRequest.java b/src/main/java/com/imyeyu/network/FileRequest.java index a75dd2d..d237676 100644 --- a/src/main/java/com/imyeyu/network/FileRequest.java +++ b/src/main/java/com/imyeyu/network/FileRequest.java @@ -3,6 +3,7 @@ package com.imyeyu.network; import com.imyeyu.io.IO; import org.apache.hc.client5.http.fluent.Request; import org.apache.hc.core5.http.Header; +import org.apache.hc.core5.http.HttpEntity; import org.apache.hc.core5.http.HttpResponse; import org.apache.hc.core5.http.ProtocolException; @@ -16,7 +17,7 @@ import java.nio.file.Path; * @author 夜雨 * @since 2025-06-26 13:03 */ -public class FileRequest extends CommonRequest { +public class FileRequest extends GsonRequest { protected FileRequest(Request request) { super(request); @@ -58,6 +59,18 @@ public class FileRequest extends CommonRequest { return this; } + @Override + public FileRequest body(Object object) { + super.body(object); + return this; + } + + @Override + public FileRequest bodyEntity(HttpEntity entity) { + super.bodyEntity(entity); + return this; + } + public void toFile(String path, String fileName) throws IOException, NoPermissionException { toFile(new File(IO.fitPath(path) + fileName)); } diff --git a/src/main/java/com/imyeyu/network/GsonRequest.java b/src/main/java/com/imyeyu/network/GsonRequest.java index 7bcdee6..935e8f0 100644 --- a/src/main/java/com/imyeyu/network/GsonRequest.java +++ b/src/main/java/com/imyeyu/network/GsonRequest.java @@ -8,6 +8,7 @@ import com.google.gson.reflect.TypeToken; import com.imyeyu.java.TimiJava; import org.apache.hc.client5.http.fluent.Request; import org.apache.hc.core5.http.ContentType; +import org.apache.hc.core5.http.HttpEntity; import java.io.IOException; @@ -75,6 +76,12 @@ public class GsonRequest extends CommonRequest { return this; } + @Override + public GsonRequest bodyEntity(HttpEntity entity) { + super.bodyEntity(entity); + return this; + } + public T resultAs(Class clazz) throws IOException { return getGson().fromJson(super.asString(), clazz); } diff --git a/src/main/java/com/imyeyu/network/ProgressiveRequest.java b/src/main/java/com/imyeyu/network/ProgressiveRequest.java index cd24c3f..539669b 100644 --- a/src/main/java/com/imyeyu/network/ProgressiveRequest.java +++ b/src/main/java/com/imyeyu/network/ProgressiveRequest.java @@ -66,6 +66,18 @@ public class ProgressiveRequest extends FileRequest { return this; } + @Override + public ProgressiveRequest body(Object object) { + super.body(object); + return this; + } + + @Override + public ProgressiveRequest bodyEntity(HttpEntity entity) { + super.bodyEntity(entity); + return this; + } + @Override public void toFile(Path outputPath) throws IOException, NoPermissionException { processResponse(request.execute(), IO.getOutputStream(outputPath.toFile())); diff --git a/src/main/java/com/imyeyu/network/TimiRequest.java b/src/main/java/com/imyeyu/network/TimiRequest.java index 43a4a25..c05d6f3 100644 --- a/src/main/java/com/imyeyu/network/TimiRequest.java +++ b/src/main/java/com/imyeyu/network/TimiRequest.java @@ -3,6 +3,7 @@ package com.imyeyu.network; import com.google.gson.reflect.TypeToken; import com.imyeyu.java.bean.timi.TimiResponse; import org.apache.hc.client5.http.fluent.Request; +import org.apache.hc.core5.http.HttpEntity; import java.io.IOException; @@ -58,6 +59,12 @@ public class TimiRequest extends GsonRequest { return this; } + @Override + public TimiRequest bodyEntity(HttpEntity entity) { + super.bodyEntity(entity); + return this; + } + @Override public String asString() throws IOException { return resultAs(String.class); diff --git a/src/test/java/com/imyeyu/network/test/ArgMapTest.java b/src/test/java/com/imyeyu/network/test/ArgMapTest.java index 6ff5bbe..c62d6ad 100644 --- a/src/test/java/com/imyeyu/network/test/ArgMapTest.java +++ b/src/test/java/com/imyeyu/network/test/ArgMapTest.java @@ -24,4 +24,13 @@ public class ArgMapTest { String url = ArgMap.of("newKey", "newValue").toURL("http://localhost/test" + uri); assert url.equals("http://localhost/test/detail?id=123&key=value&newKey=newValue"); } + + @Test + public void duplicateKeyTest() { + ArgMap argMap = new ArgMap<>(); + argMap.put("id", "1"); + argMap.put("id", "2"); + assert argMap.toURL().equals("id=1&id=2"); + assert argMap.toURL("/detail").equals("/detail?id=1&id=2"); + } } -- 2.49.1 From ada0f96e57f4d19514190f261aec0a075d5008bb Mon Sep 17 00:00:00 2001 From: Timi Date: Mon, 16 Mar 2026 17:13:10 +0800 Subject: [PATCH 2/2] v0.0.5 --- pom.xml | 11 +- .../java/com/imyeyu/network/FileRequest.java | 2 +- .../java/com/imyeyu/network/GsonRequest.java | 100 --------- .../com/imyeyu/network/JacksonRequest.java | 204 ++++++++++++++++++ .../java/com/imyeyu/network/TimiRequest.java | 76 ++++++- 5 files changed, 278 insertions(+), 115 deletions(-) delete mode 100644 src/main/java/com/imyeyu/network/GsonRequest.java create mode 100644 src/main/java/com/imyeyu/network/JacksonRequest.java diff --git a/pom.xml b/pom.xml index 80157a7..0bc3d87 100644 --- a/pom.xml +++ b/pom.xml @@ -94,20 +94,15 @@ timi-io 0.0.2 - - org.apache.commons - commons-collections4 - 4.4 - org.apache.httpcomponents.client5 httpclient5-fluent 5.6 - com.google.code.gson - gson - 2.13.2 + tools.jackson.core + jackson-databind + 3.1.0 org.projectlombok diff --git a/src/main/java/com/imyeyu/network/FileRequest.java b/src/main/java/com/imyeyu/network/FileRequest.java index d237676..43acc83 100644 --- a/src/main/java/com/imyeyu/network/FileRequest.java +++ b/src/main/java/com/imyeyu/network/FileRequest.java @@ -17,7 +17,7 @@ import java.nio.file.Path; * @author 夜雨 * @since 2025-06-26 13:03 */ -public class FileRequest extends GsonRequest { +public class FileRequest extends JacksonRequest { protected FileRequest(Request request) { super(request); diff --git a/src/main/java/com/imyeyu/network/GsonRequest.java b/src/main/java/com/imyeyu/network/GsonRequest.java deleted file mode 100644 index 935e8f0..0000000 --- a/src/main/java/com/imyeyu/network/GsonRequest.java +++ /dev/null @@ -1,100 +0,0 @@ -package com.imyeyu.network; - -import com.google.gson.Gson; -import com.google.gson.JsonArray; -import com.google.gson.JsonObject; -import com.google.gson.JsonParser; -import com.google.gson.reflect.TypeToken; -import com.imyeyu.java.TimiJava; -import org.apache.hc.client5.http.fluent.Request; -import org.apache.hc.core5.http.ContentType; -import org.apache.hc.core5.http.HttpEntity; - -import java.io.IOException; - -/** - * @author 夜雨 - * @since 2025-07-15 14:27 - */ -public class GsonRequest extends CommonRequest { - - private static final Gson GSON = new Gson(); - - private Gson gson = null; - - protected GsonRequest(Request request) { - super(request); - } - - protected Gson getGson() { - return TimiJava.firstNotNull(gson, GSON); - } - - public static GsonRequest wrap(Request request) { - return new GsonRequest(request); - } - - public static GsonRequest get(String url) { - return new GsonRequest(Request.get(url)); - } - - public static GsonRequest post(String url) { - return new GsonRequest(Request.post(url)); - } - - public GsonRequest gson(Gson gson) { - this.gson = gson; - return this; - } - - @Override - public GsonRequest timeout(long ms) { - super.timeout(ms); - return this; - } - - @Override - public GsonRequest header(String key, String value) { - request.addHeader(key, value); - return this; - } - - @Override - public GsonRequest token(String token) { - request.addHeader("Token", token); - return this; - } - - @Override - public GsonRequest language(String langHeader) { - request.addHeader("Accept-Language", langHeader); - return this; - } - - public GsonRequest body(Object object) { - request.bodyString(getGson().toJson(object), ContentType.APPLICATION_JSON); - return this; - } - - @Override - public GsonRequest bodyEntity(HttpEntity entity) { - super.bodyEntity(entity); - return this; - } - - public T resultAs(Class clazz) throws IOException { - return getGson().fromJson(super.asString(), clazz); - } - - public T resultAs(TypeToken typeToken) throws IOException { - return getGson().fromJson(super.asString(), typeToken); - } - - public JsonObject asJsonObject() throws IOException { - return JsonParser.parseString(super.asString()).getAsJsonObject(); - } - - public JsonArray asJsonArray() throws IOException { - return JsonParser.parseString(super.asString()).getAsJsonArray(); - } -} diff --git a/src/main/java/com/imyeyu/network/JacksonRequest.java b/src/main/java/com/imyeyu/network/JacksonRequest.java new file mode 100644 index 0000000..4126f8a --- /dev/null +++ b/src/main/java/com/imyeyu/network/JacksonRequest.java @@ -0,0 +1,204 @@ +package com.imyeyu.network; + +import org.apache.hc.client5.http.fluent.Request; +import org.apache.hc.core5.http.ContentType; +import org.apache.hc.core5.http.HttpEntity; +import tools.jackson.core.JacksonException; +import tools.jackson.core.type.TypeReference; +import tools.jackson.databind.JsonNode; +import tools.jackson.databind.ObjectMapper; +import tools.jackson.databind.node.ArrayNode; +import tools.jackson.databind.node.ObjectNode; + +import java.io.IOException; +import java.lang.reflect.Type; + +/** + * 基于 Jackson 的请求封装。 + * + * @author 夜雨 + * @since 2025-07-15 14:27 + */ +public class JacksonRequest extends CommonRequest { + + private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper(); + + private ObjectMapper objectMapper = null; + + protected JacksonRequest(Request request) { + super(request); + } + + /** + * 获取当前请求使用的对象映射器。 + * + * @return 对象映射器 + */ + protected ObjectMapper getObjectMapper() { + if (objectMapper != null) { + return objectMapper; + } + return OBJECT_MAPPER; + } + + /** + * 包装现有请求对象。 + * + * @param request 请求对象 + * @return Jackson 请求 + */ + public static JacksonRequest wrap(Request request) { + return new JacksonRequest(request); + } + + /** + * 创建 GET 请求。 + * + * @param url 请求地址 + * @return Jackson 请求 + */ + public static JacksonRequest get(String url) { + return new JacksonRequest(Request.get(url)); + } + + /** + * 创建 POST 请求。 + * + * @param url 请求地址 + * @return Jackson 请求 + */ + public static JacksonRequest post(String url) { + return new JacksonRequest(Request.post(url)); + } + + /** + * 指定对象映射器。 + * + * @param objectMapper 对象映射器 + * @return 当前请求 + */ + public JacksonRequest objectMapper(ObjectMapper objectMapper) { + this.objectMapper = objectMapper; + return this; + } + + @Override + public JacksonRequest timeout(long ms) { + super.timeout(ms); + return this; + } + + @Override + public JacksonRequest header(String key, String value) { + request.addHeader(key, value); + return this; + } + + @Override + public JacksonRequest token(String token) { + request.addHeader("Token", token); + return this; + } + + @Override + public JacksonRequest language(String langHeader) { + request.addHeader("Accept-Language", langHeader); + return this; + } + + /** + * 设置 JSON 请求体。 + * + * @param object 要序列化的对象 + * @return 当前请求 + * @throws IllegalArgumentException JSON 序列化失败时抛出 + */ + public JacksonRequest body(Object object) { + try { + request.bodyString(getObjectMapper().writeValueAsString(object), ContentType.APPLICATION_JSON); + return this; + } catch (JacksonException e) { + throw new IllegalArgumentException("Jackson serialize request body failed", e); + } + } + + @Override + public JacksonRequest bodyEntity(HttpEntity entity) { + super.bodyEntity(entity); + return this; + } + + /** + * 将响应体解析为指定类型。 + * + * @param clazz 目标类型 + * @param 结果类型 + * @return 解析结果 + * @throws IOException 读取或解析失败 + */ + public T resultAs(Class clazz) throws IOException { + return getObjectMapper().readValue(super.asString(), clazz); + } + + /** + * 将响应体解析为指定泛型类型。 + * + * @param typeReference 目标类型引用 + * @param 结果类型 + * @return 解析结果 + * @throws IOException 读取或解析失败 + */ + public T resultAs(TypeReference typeReference) throws IOException { + return getObjectMapper().readValue(super.asString(), typeReference); + } + + /** + * 将响应体解析为指定反射类型。 + * + * @param type 目标类型 + * @param 结果类型 + * @return 解析结果 + * @throws IOException 读取或解析失败 + */ + public T resultAs(Type type) throws IOException { + return getObjectMapper().readValue(super.asString(), getObjectMapper().constructType(type)); + } + + /** + * 将响应体解析为 JSON 节点。 + * + * @return JSON 节点 + * @throws IOException 读取或解析失败 + */ + public JsonNode asJsonNode() throws IOException { + return getObjectMapper().readTree(super.asString()); + } + + /** + * 将响应体解析为 JSON 对象。 + * + * @return JSON 对象节点 + * @throws IOException 读取或解析失败 + */ + public ObjectNode asJsonObject() throws IOException { + JsonNode jsonNode = asJsonNode(); + if (jsonNode instanceof ObjectNode objectNode) { + return objectNode; + } + throw new IOException("Response body is not a JSON object"); + } + + /** + * 将响应体解析为 JSON 数组。 + * + * @return JSON 数组节点 + * @throws IOException 读取或解析失败 + */ + public ArrayNode asJsonArray() throws IOException { + JsonNode jsonNode = asJsonNode(); + if (jsonNode instanceof ArrayNode arrayNode) { + return arrayNode; + } + throw new IOException("Response body is not a JSON array"); + } +} diff --git a/src/main/java/com/imyeyu/network/TimiRequest.java b/src/main/java/com/imyeyu/network/TimiRequest.java index c05d6f3..986604f 100644 --- a/src/main/java/com/imyeyu/network/TimiRequest.java +++ b/src/main/java/com/imyeyu/network/TimiRequest.java @@ -1,17 +1,19 @@ package com.imyeyu.network; -import com.google.gson.reflect.TypeToken; import com.imyeyu.java.bean.timi.TimiResponse; import org.apache.hc.client5.http.fluent.Request; import org.apache.hc.core5.http.HttpEntity; +import tools.jackson.core.type.TypeReference; +import tools.jackson.databind.JavaType; import java.io.IOException; +import java.lang.reflect.Type; /** * @author 夜雨 * @since 2025-07-15 14:34 */ -public class TimiRequest extends GsonRequest { +public class TimiRequest extends JacksonRequest { protected TimiRequest(Request request) { super(request); @@ -75,16 +77,48 @@ public class TimiRequest extends GsonRequest { return Double.parseDouble(asString()); } + /** + * 读取 Timi 响应中的数据字段。 + * + * @param clazz 数据类型 + * @param 数据泛型 + * @return 数据内容 + * @throws IOException 读取或解析失败 + */ public T resultAs(Class clazz) throws IOException { - TimiResponse resp = getGson().fromJson(asJsonObject(), TypeToken.getParameterized(TimiResponse.class, clazz).getType()); + TimiResponse resp = getObjectMapper().treeToValue(asJsonObject(), timiResponseType(clazz)); if (resp.isFail()) { throw resp.toException(); } return resp.getData(); } - public T resultAs(TypeToken typeToken) throws IOException { - TimiResponse resp = getGson().fromJson(asJsonObject(), TypeToken.getParameterized(TimiResponse.class, typeToken.getType()).getType()); + /** + * 读取 Timi 响应中的泛型数据字段。 + * + * @param typeReference 数据类型引用 + * @param 数据泛型 + * @return 数据内容 + * @throws IOException 读取或解析失败 + */ + public T resultAs(TypeReference typeReference) throws IOException { + TimiResponse resp = getObjectMapper().treeToValue(asJsonObject(), timiResponseType(typeReference)); + if (resp.isFail()) { + throw resp.toException(); + } + return resp.getData(); + } + + /** + * 读取 Timi 响应中的泛型数据字段。 + * + * @param type 数据类型 + * @param 数据泛型 + * @return 数据内容 + * @throws IOException 读取或解析失败 + */ + public T resultAs(Type type) throws IOException { + TimiResponse resp = getObjectMapper().treeToValue(asJsonObject(), timiResponseType(type)); if (resp.isFail()) { throw resp.toException(); } @@ -93,9 +127,39 @@ public class TimiRequest extends GsonRequest { @Override public void execute() throws IOException { - TimiResponse resp = getGson().fromJson(asJsonObject(), TypeToken.getParameterized(TimiResponse.class, Object.class).getType()); + TimiResponse resp = getObjectMapper().treeToValue(asJsonObject(), timiResponseType(Object.class)); if (resp.isFail()) { throw resp.toException(); } } + + /** + * 构造带泛型的 Timi 响应类型。 + * + * @param clazz 数据类型 + * @return Jackson 类型 + */ + protected JavaType timiResponseType(Class clazz) { + return getObjectMapper().getTypeFactory().constructParametricType(TimiResponse.class, clazz); + } + + /** + * 构造带泛型的 Timi 响应类型。 + * + * @param typeReference 数据类型引用 + * @return Jackson 类型 + */ + protected JavaType timiResponseType(TypeReference typeReference) { + return getObjectMapper().getTypeFactory().constructParametricType(TimiResponse.class, getObjectMapper().constructType(typeReference)); + } + + /** + * 构造带泛型的 Timi 响应类型。 + * + * @param type 数据类型 + * @return Jackson 类型 + */ + protected JavaType timiResponseType(Type type) { + return getObjectMapper().getTypeFactory().constructParametricType(TimiResponse.class, getObjectMapper().constructType(type)); + } } -- 2.49.1