java - BufferedReader 不一致地卡在我套接字的输入流上

Question

我正在编写一个 Java HTTP 服务器。我认为整个服务器都在工作并且它正在使用线程。但是，我意识到将请求读入 BufferedReader 的那段代码无法始终如一地工作。

这是读取传入请求的代码:

private String receive(WebSocket webSocket) throws IOException {
  int chr;
  System.out.println("Receiving!");
  StringBuffer buffer = new StringBuffer();

  while ( (chr = webSocket.in().read() ) != -1) {
    buffer.append((char) chr);
    if ( !webSocket.in().ready())
      break;
  }
  return buffer.toString();
}

我的 Websocket 类只是包装 Socket 并提供输入和输出。我这样做是为了模拟套接字并测试我的服务器。

Websocket 类如下所示:

package http.server.socket;

import java.io.*;
import java.net.Socket;

public class SystemSocket implements WebSocket {
  private Socket theConnection;
  private BufferedReader in;
  private OutputStream out;

  public SystemSocket(Socket theConnection) throws IOException {
    this.theConnection = theConnection;
    in = new BufferedReader(new InputStreamReader(theConnection.getInputStream()));
    out = new BufferedOutputStream(theConnection.getOutputStream());
  }

  public BufferedReader in() throws IOException {
    return in;
  }

  public OutputStream out() throws IOException {
    return out;
  }

  public void close() throws IOException {
    in.close();
    out.close();
    theConnection.close();
  }
}

问题在于，用户在浏览器中输入每个 url 时，都会发出两个请求 - 一个用于请求的页面，一个用于 favicon。有时 - 似乎 - 没有收到网站图标请求并且线程挂起。

这是我打印到控制台的一些调试信息当一切正常时:

Receiving!
Receiving!
REQUEST STRING = GET /color_picker.html HT
[20130821 20:29:23] REQUEST: http://localhost:5000/color_picker.html
[20130821 20:29:23] PAGE RENDERED
REQUEST STRING = GET /favicon.ico HTTP/1.1
[20130821 20:29:23] REQUEST: http://localhost:5000/favicon.ico
[20130821 20:29:23] PAGE RENDERED

每当读取请求时，都会打印“正在接收”消息。因此，在这种情况下，“接收”消息被打印了两次，收到了两个请求并呈现了两件事。但是随后，同一页面(但在不同的时间)将执行此操作(大约 10 秒后):

Receiving!
Receiving!
REQUEST STRING = GET /color_picker.html HTTP/1.1
[20130821 20:41:25] REQUEST: http://localhost:5000/color_picker.html
[20130821 20:41:25] PAGE RENDERED
REQUEST STRING = 
Exception in thread "ServerThread" java.lang.ArrayIndexOutOfBoundsException: 1
  at http.request.Parser.setRequestLineData(Parser.java:42)
  at http.request.Parser.setRequestHash(Parser.java:27)
  at http.request.Parser.parse(Parser.java:13)
  at http.request.Request.get(Request.java:18)
  at http.server.ServerThread.run(ServerThread.java:39)

后面的所有错误都是因为请求字符串为空。但我无法弄清楚为什么 Request 字符串为空。我什至不知道如何调试。

有人能帮忙吗？？

同样重要的是要注意，如果第二个请求字符串没有立即出现，用户可以请求一个新的 url，这将导致第二个挂起的进程完成(因此第四个请求 url 将是挂起的) .所以，只有当用户停止请求时，在大约 10 秒后的最后一个请求中，我才会得到错误。有时我可以请求 20 个不同的页面，只有在我停止请求页面并等待几秒钟后，我才会看到错误。我认为这就是正在发生的事情？？

更新:

根据请求，这里是 setRequestLineData() 方法:

private void setRequestLineData() {
  requestHash = new HashMap<String, String>();

  if (requestLineParts.length == 3) {
    requestHash.put("httpMethod", requestLineParts[0]);
    requestHash.put("url", requestLineParts[1]);  //line 42
    requestHash.put("httpProtocol", requestLineParts[2]);
  }
  else {
    requestHash.put("httpMethod", requestLineParts[0]);
    requestHash.put("url", requestLineParts[1]);
    requestHash.put("queryString", requestLineParts[2]);
    requestHash.put("httpProtocol", requestLineParts[3]);
  }
}

更新:

我想我在导师的帮助下对这里发生的事情有了更多的了解。他的想法是，一旦收到一个请求，浏览器就立即启动另一个请求，以减少下一个请求的加载时间。这对我来说似乎是合理的，因为我可以一页接一页地加载页面，但是在请求最后一页后大约 10 秒我收到错误。目前，我正在使用自定义异常处理此问题，但正在研究更好的解决方案。感谢大家的帮助!

Answer 1

ready() 不是消息结束的有效测试。它只是告诉你是否有数据可以不阻塞地读取。 TCP 不是面向消息的协议(protocol)，它是字节流协议(protocol)。如果你想要消息，你必须自己实现它们，例如作为行、长度-值元组、类型-长度-值元组、序列化对象、XML 文档……

ready()(或 available())的正确使用很少，这不是其中之一。