Java 17中java.net.http HttpClient sendAsync回调返回值异常求助

核心错误原因 #

你遇到的"unexpected return value"是因为**Consumer接口的accept方法是void返回类型**，你的lambda表达式里写了return responseBody;，这违反了Consumer的方法签名规则。

除此之外，代码还有两个潜在问题：

• 共享外部retVal对象存在线程安全风险，异步回调线程和主线程可能同时操作这个Map
• 强制类型转换responseMap.get("result")未做类型校验，容易抛出ClassCastException

修正步骤 #

1. 移除Consumer中的return语句：将回调逻辑改为直接处理结果，不需要返回值
2. 避免共享外部Map：在thenApply和exceptionally中分别创建新的LinkedHashMap，替代外部的retVal
3. 增加类型安全校验：对responseMap.get("result")的返回值做类型检查，避免强制转换异常

修正后的完整代码 #

HttpRequest request = HttpRequest.newBuilder(URI.create(url))
        .header("Content-Type", "application/json")
        .POST(HttpRequest.BodyPublishers.ofString(params))
        .build();

HttpClient.newHttpClient()
        .sendAsync(request, HttpResponse.BodyHandlers.ofString())
        .thenApply(response -> {
            LinkedHashMap<String, Object> resultMap = new LinkedHashMap<>();
            try {
                ObjectMapper mapper = new ObjectMapper();
                LinkedHashMap<String, Object> responseMap = mapper.readValue(response.body(), new TypeReference<>() {});
                
                // 类型安全校验
                Object resultObj = responseMap.get("result");
                if (resultObj instanceof ArrayList<?> resultList && !resultList.isEmpty()) {
                    Object firstItem = resultList.get(0);
                    if (firstItem instanceof LinkedHashMap<?, ?> itemMap) {
                        resultMap.put("status", itemMap.get("status"));
                        resultMap.put("message", itemMap.get("message"));
                    } else {
                        resultMap.put("status", "FAILED");
                        resultMap.put("message", "Result item is not a valid map");
                    }
                } else {
                    resultMap.put("status", "FAILED");
                    resultMap.put("message", "Result list is empty or invalid");
                }
            } catch (JsonProcessingException e) {
                resultMap.put("status", "FAILED");
                resultMap.put("message", e.getMessage());
                e.printStackTrace();
            }
            return resultMap;
        })
        .exceptionally(ex -> {
            LinkedHashMap<String, Object> errorMap = new LinkedHashMap<>();
            errorMap.put("status", "FAILED");
            errorMap.put("message", ex.getMessage());
            System.out.println("Exception occurred: " + ex.getMessage());
            return errorMap;
        })
        .thenAccept(callback);

// 修正后的回调函数：无返回值，直接处理结果
Consumer<LinkedHashMap<String, Object>> callback = responseBody -> {
    // 在这里处理结果，比如返回给调用方（根据你的业务逻辑实现）
    System.out.println("Received response: " + responseBody);
};

额外优化建议 #

如果需要将结果返回给调用方法，建议直接返回CompletableFuture<LinkedHashMap<String, Object>>，更符合异步编程的规范，示例如下：

public CompletableFuture<LinkedHashMap<String, Object>> callMessageService(String url, String params) {
    HttpRequest request = HttpRequest.newBuilder(URI.create(url))
            .header("Content-Type", "application/json")
            .POST(HttpRequest.BodyPublishers.ofString(params))
            .build();

    return HttpClient.newHttpClient()
            .sendAsync(request, HttpResponse.BodyHandlers.ofString())
            .thenApply(response -> {
                LinkedHashMap<String, Object> resultMap = new LinkedHashMap<>();
                // 复用上面的结果处理逻辑
                return resultMap;
            })
            .exceptionally(ex -> {
                LinkedHashMap<String, Object> errorMap = new LinkedHashMap<>();
                errorMap.put("status", "FAILED");
                errorMap.put("message", ex.getMessage());
                return errorMap;
            });
}

调用方可以通过whenComplete或thenAccept处理异步结果，完全避免主线程阻塞。

内容的提问来源于stack exchange，提问作者Sumon Bappi