HttpClient和HttpServer之间通信的Java问题

问题描述

这是我在这里的第一个问题，所以我很抱歉，如果不是所有需要的信息都在这篇文章中。

java.net.http.HttpClient和HttpServer之间的通信出现问题。 我将请求从带有HttpClient的应用程序发送到带有Httpserver的应用程序，稍后再读取，根据消息中的信息发送邮件，然后通过HttpClient向应用程序发送响应，如果一切正常，或者如果出现问题，则失败。

前几次（通常是随机的，有时是2个，有时是24个）通常由Server正确发送并正确处理，这导致httpClient收到响应“成功”，但是突然间Server收到了带有正确头但没有正文的请求，即使它在请求中始终是同一条消息，从而导致“失败”响应。

我的HttpClient：

    private Boolean sendMail(String requestBody) throws IOException,InterruptedException {
    HttpClient client = HttpClient.newBuilder()
            .version(HttpClient.Version.HTTP_1_1)
            .cookieHandler(CookieHandler.getDefault())
            .build();

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


    //creating response body handler
    HttpResponse.BodyHandler<String> bodyHandler = HttpResponse.BodyHandlers.ofString();


    HttpResponse<String> response = client
            .send(request,bodyHandler);

    String requestOutcome = response.body();
    System.out.println(requestOutcome);

我的HttpServer：

   HttpServer server = HttpServer.create(new InetSocketAddress(port),0);
  ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);

  server.createContext("/mial",new  ServerHttpHandler(this.dbHandler,this.mailHandler));
  server.setExecutor(threadPoolExecutor);

  //Start HttpServer
  server.start();

我的自定义ServerHttpHandler：

 public void handle(HttpExchange httpExchange) throws IOException {
    String requestParamValue=null;
    if("GET".equals(httpExchange.getRequestMethod())) {
        requestParamValue = handleGetRequest(httpExchange);
    }else if("POST".equals(httpExchange.getRequestMethod())) {
        requestParamValue = handlePostRequest(httpExchange);
    }
    handleResponse(httpExchange,requestParamValue);
}
private String handleGetRequest(HttpExchange httpExchange) {
    return httpExchange.
            getRequestURI()
            .toString()
            .split("\\?")[1]
            .split("=")[1];
}

private String handlePostRequest(HttpExchange httpExchange){
    // get request
    Headers reqHeaders = httpExchange.getRequestHeaders();
    reqHeaders.forEach((key,value) -> System.out.println(key + ": " + value));

    String message = null;
    try (InputStream in = httpExchange.getRequestBody()) {
        BufferedReader br = new BufferedReader(new InputStreamReader(in));
        StringBuilder msgbuilder = new StringBuilder();
        while (br.ready()) {
            msgbuilder.append((char) br.read());
        }
        message = msgbuilder.toString();
        System.out.println("Message: " + message);
        br.close();

    } catch (IOException e) {
        e.printstacktrace();
    }
    return message;
}

private void handleResponse(HttpExchange httpExchange,String requestParamValue) throws IOException {
    boolean success = this.convertMsgAndSendMail(requestParamValue);

    String htmlResponse = "failure";
    if(success) {
        htmlResponse = "success";
    }

    httpExchange.sendResponseHeaders(200,htmlResponse.length());
    OutputStream outputStream = httpExchange.getResponseBody();

    outputStream.write(htmlResponse.getBytes());
    outputStream.flush();
    outputStream.close();
}

错误的请求：

Connection: [Upgrade,HTTP1_1-Settings]
Http2-settings: [AAEAAEAAAAIAAAABAAMAAABkAAQBAAAAAAUAAEAA]
Host: [localhost:587]
Upgrade: [h2c]
User-agent: [Java-http-client/11.0.6]
Content-type: [application/json]
Content-length: [180]
Message:

因此标题每次都是相同的，但是这次我没有收到任何消息。而且，由于该消息后来被转换为JSON，所以我得到的唯一错误是该消息不是以“ {”开头，因此它不是Json兼容的。

我在StackOverflow和其他站点上搜索了此问题的解决方案，但没有找到任何有用的技巧来解决此问题。你有什么主意吗？

解决方法

这里有几个错误：

1. 在将字节转换为字符时（反之），您实际上应该始终指定一个字符集；这不是您的主要问题所在，但您应该考虑一下。
2. 您的while循环错误。

您有：

while (br.ready()) {
   msgbuilder.append((char) br.read());
}

它的作用是，如果没有立即可用的字符，它将停止读取；您想要的是在没有更多要阅读的字符时停止阅读。这应该是这样的：

int c;
while ((c = br.read()) > -1) {
    msgbuilder.append((char) c);
}