如何使用HttpClinet实现RPC返回对象类型

在使用 Java 的 HttpClient 实现 RPC 调用时，返回的对象类型通常取决于服务器响应的数据格式（比如 JSON）。为了将服务器的响应转换为具体的 Java 对象，我们需要以下步骤：

1. 发送 RPC 请求（POST 或 GET）。
2. 获取服务器返回的响应（通常是 JSON 字符串）。
3. 将响应反序列化为 Java 对象。

下面我以 POST 请求为例，展示如何使用 HttpClient 实现 RPC 并返回自定义对象类型。假设服务器返回的是 JSON 数据，我们使用 Jackson 或 Gson 库来处理反序列化。

---

1. 准备工作

确保项目中引入以下依赖（以 Maven 为例）：

<!-- HttpClient -->
<dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.14</version>
</dependency>
<!-- Jackson 用于 JSON 序列化/反序列化 -->
<dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.15.2</version>
</dependency>

---

2. 定义返回对象类型

假设 RPC 服务返回一个用户信息对象，格式如下：

{"id": 1,"name": "张三","age": 25
}

对应的 Java 类：

public class User {private int id;private String name;private int age;// 无参构造（Jackson 要求）public User() {}// Getter 和 Setterpublic int getId() { return id; }public void setId(int id) { this.id = id; }public String getName() { return name; }public void setName(String name) { this.name = name; }public int getAge() { return age; }public void setAge(int age) { this.age = age; }@Overridepublic String toString() {return "User{id=" + id + ", name='" + name + "', age=" + age + "}";}
}

---

3. 实现 RPC 调用并返回对象

以下是一个完整的示例代码，通过 POST 请求调用 RPC 服务，并将响应转换为 User 对象。

示例代码

import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;import java.io.IOException;public class RpcWithObjectReturn {public static void main(String[] args) {// 调用 RPC 方法并获取返回对象User user = callRpcService();System.out.println("返回的对象: " + user);}public static User callRpcService() {String url = "http://example.com/api/rpc";String jsonRequest = "{\"method\":\"getUser\",\"params\":{\"userId\":1},\"id\":1}";try {// 创建 HttpClient 实例CloseableHttpClient httpClient = HttpClients.createDefault();// 创建 POST 请求HttpPost httpPost = new HttpPost(url);httpPost.setHeader("Content-Type", "application/json");httpPost.setHeader("Accept", "application/json");// 设置请求体StringEntity entity = new StringEntity(jsonRequest, "UTF-8");httpPost.setEntity(entity);// 执行请求try (CloseableHttpResponse response = httpClient.execute(httpPost)) {int statusCode = response.getStatusLine().getStatusCode();if (statusCode == 200) {// 获取响应内容String responseBody = EntityUtils.toString(response.getEntity(), "UTF-8");// 使用 Jackson 将 JSON 反序列化为 User 对象ObjectMapper mapper = new ObjectMapper();return mapper.readValue(responseBody, User.class);} else {System.out.println("请求失败，状态码: " + statusCode);return null;}} finally {httpClient.close();}} catch (IOException e) {e.printStackTrace();return null;}}
}

---

4. 代码说明

• 请求：发送一个 JSON 请求，调用 getUser 方法，参数是 userId。
• 响应处理：
  • 使用 EntityUtils.toString 获取响应体的 JSON 字符串。
  • 使用 ObjectMapper.readValue 将 JSON 字符串反序列化为 User 对象。
• 返回类型：方法直接返回 User 对象，调用者可以直接使用。
• 异常处理：简单返回 null，实际应用中建议抛出自定义异常或返回 Optional。

---

5. 如果响应中包含 RPC 包装结构

有些 RPC 服务返回的不是直接的对象，而是包含结果的包装结构，例如：

{"jsonrpc": "2.0","result": {"id": 1,"name": "张三","age": 25},"id": 1
}

需要定义一个包装类来解析响应：

包装类

public class RpcResponse<T> {private String jsonrpc;private T result;private int id;public String getJsonrpc() { return jsonrpc; }public void setJsonrpc(String jsonrpc) { this.jsonrpc = jsonrpc; }public T getResult() { return result; }public void setResult(T result) { this.result = result; }public int getId() { return id; }public void setId(int id) { this.id = id; }@Overridepublic String toString() {return "RpcResponse{jsonrpc='" + jsonrpc + "', result=" + result + ", id=" + id + "}";}
}

修改调用代码

import com.fasterxml.jackson.core.type.TypeReference;public class RpcWithWrappedObject {public static User callRpcService() {String url = "http://example.com/api/rpc";String jsonRequest = "{\"method\":\"getUser\",\"params\":{\"userId\":1},\"id\":1}";try {CloseableHttpClient httpClient = HttpClients.createDefault();HttpPost httpPost = new HttpPost(url);httpPost.setHeader("Content-Type", "application/json");httpPost.setHeader("Accept", "application/json");StringEntity entity = new StringEntity(jsonRequest, "UTF-8");httpPost.setEntity(entity);try (CloseableHttpResponse response = httpClient.execute(httpPost)) {if (response.getStatusLine().getStatusCode() == 200) {String responseBody = EntityUtils.toString(response.getEntity(), "UTF-8");ObjectMapper mapper = new ObjectMapper();// 解析包装响应RpcResponse<User> rpcResponse = mapper.readValue(responseBody, new TypeReference<RpcResponse<User>>() {});return rpcResponse.getResult(); // 返回具体的 User 对象}} finally {httpClient.close();}} catch (IOException e) {e.printStackTrace();}return null;}public static void main(String[] args) {User user = callRpcService();System.out.println("返回的对象: " + user);}
}

---

6. 注意事项

1. 依赖 Jackson：确保正确配置 Jackson，若不喜欢 Jackson，也可以用 Gson 或其他 JSON 库。
2. 泛型支持：如果需要动态返回不同类型，可以将方法改为泛型：

   public static <T> T callRpcService(String jsonRequest, Class<T> clazz) {// 类似上述逻辑，返回 clazz 类型的对象
   }
   

3. 错误处理：实际应用中，检查响应中的错误字段（如 "error"），并处理异常情况。
4. 性能优化：ObjectMapper 是线程安全的，可以作为静态变量复用。

---

7. 测试

• 将 url 替换为真实 RPC 服务地址。
• 调整 jsonRequest 和返回对象类型（如 User）以匹配你的服务。

如果你有具体的返回格式或遇到问题，告诉我，我可以进一步帮你调整代码！有什么想深入了解的部分吗？