我正在编写一个 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 秒我收到错误。目前,我正在使用自定义异常处理此问题,但正在研究更好的解决方案。感谢大家的帮助!
最佳答案
ready()
不是消息结束的有效测试。它只是告诉你是否有数据可以不阻塞地读取。 TCP 不是面向消息的协议(protocol),它是字节流协议(protocol)。如果你想要消息,你必须自己实现它们,例如作为行、长度-值元组、类型-长度-值元组、序列化对象、XML 文档……
ready()
(或 available()
)的正确使用很少,这不是其中之一。
关于java - BufferedReader 不一致地卡在我套接字的输入流上,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18370384/