使用 Apache HttpClient 的持久性？

Question

我的目标是连接到服务器然后保持连接。服务器只要有数据就会不断向我推送一些数据。我写了以下内容，但它仅在第一次时有效。第二次开始，它给我一个异常，说 get.getResponseBodyAsStream() 为 null。我认为 Apache 的 HTTPClient 默认情况下会保持连接处于活动状态，所以我的理解是我需要在某个地方进行阻塞调用。有人可以帮我吗？

        GetMethod get = new GetMethod(url);
        String nextLine;
        String responseBody = "";
        BufferedReader input;

        try {
            httpClient.executeMethod(get);
            while(true) {
                try {
                    input = new BufferedReader(new InputStreamReader(get.getResponseBodyAsStream()));

                    while ((nextLine = input.readLine()) != null)
                        responseBody += nextLine;
                    System.out.println(responseBody);
                } catch (IOException ex) {
                    ex.printStackTrace();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

实际上，在一天结束时，我试图获得与服务器的持久连接（稍后我将处理可能的错误），以便我可以继续从服务器接收更新。任何关于这方面的指示都会很棒。

Answer 1

我没有详细查看或测试代码，但我认为反复向读者开放响应可能是一个坏主意。首先，我会将 input = 行移到循环之外。

Answer 2

在我看来，HttpClient 库适用于客户端拉取情况。我推荐你看看comet，它支持服务器推送

Answer 3

你不能这样做。当您阅读了响应的“正文”后，就是这样。要获取更多信息，客户端必须发送新请求。这就是 HTTP 协议的工作方式。

如果您想在单个 HTTP 响应中传输多个数据块，那么您将需要自己进行分块和取消分块。您可以使用多种方法，具体取决于数据的性质。例如：

• 如果数据是 XML 或 JSON，则发送 XML 文档/JSON 对象流，并让接收者将流分离为文档/对象，然后再将其发送到解析器。
• 发明您自己的轻量级“打包”，在每个块之前添加开始标记和字节计数。

另一种选择是使用多个 GET 请求，但尝试进行配置，以便底层 TCP/IP 连接在请求之间保持打开状态；请参阅 HTTP 持久连接。

编辑

实际上，我只需要发送一个 GET 请求并继续等待来自服务器的状态消息。

HTTP 状态代码在 HTTP 响应消息的第一行中传输。每个 HTTP 响应只能有一个，而且（显然）每个 HTTP 请求也只能有一个响应。因此，使用正常的 HTTP 状态代码和请求/回复消息，您想要做的事情是不可能的。

请查看我上面建议的替代方案。可以调整项目符号替代方案，以允许您在每个数据块中包含某种状态。最后一个（发送多个请求）已经解决了问题。

编辑2

更具体地说，保持连接活动似乎是透明完成的

这是正确的。

...所以我需要的是一种在存在一些可以使用的数据时收到通知的方法。

假设您不准备发送多个 GET 请求（这显然是最简单的解决方案！！！），那么您的代码可能如下所示：

 while (true) {
     String header = input.readLine();  // format "status:linecount"
     if (header == null) {
         break;
     }
     String[] parts = header.split(":");
     String status = parts[0];
     StringBuilder sb = new StringBuilder();
     int lineCount = Integer.parseInt(parts[1]);
     for (int i = 0; i < lineCount; i++) {
         String line = input.readLine();
         if (line == null) {
             throw new Exception("Ooops!");
         }
         sb.append(line).append('\n');
     }
     System.out.println("Got status = " + status + " body = " + body);
  }

但是如果您仅发送状态代码或者每个数据块的其余部分可以被删除-角到同一条线上，您可以进一步简化它。

如果您尝试实现这一点，以便主线程不必等待（阻塞）从输入流读取数据，那么要么使用 NIO，要么使用单独的线程从输入流读取数据。