能够保持活动的HTTP服务器
我正在尝试用Java创建一个能够提供保持连接的http服务器。 我正在使用com.sun.net.httpserver.HttpServer类。
import java.io.IOException; import java.io.OutputStream; import java.net.InetSocketAddress; import com.sun.net.httpserver.Headers; import com.sun.net.httpserver.HttpExchange; import com.sun.net.httpserver.HttpHandler; import com.sun.net.httpserver.HttpServer; public class httpHandler implements HttpHandler { private String resp = ""; private OutputStream os = null; public void handle(HttpExchange t) throws IOException { System.out.println("Handling message..."); java.io.InputStream is = t.getRequestBody(); System.out.println("Got request body. Reading request body..."); byte[] b = new byte[500]; is.read(b); System.out.println("This is the request: " + new String(b)); String response = resp; Headers header = t.getResponseHeaders(); header.add("Connection", "Keep-Alive"); header.add("Keep-Alive", "timeout=14 max=100"); header.add("Content-Type", "application/soap+xml"); t.sendResponseHeaders(200, response.length()); if(os == null) { os = t.getResponseBody(); } os.write(response.getBytes()); System.out.println("Done with exchange. Closing connection"); os.close(); } public static void main(String[] args) { HttpServer server = null; try { server = HttpServer.create(new InetSocketAddress(8080), 5); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } server.createContext("/", new httpHandler()); server.setExecutor(null); // creates a default executor System.out.println("Starting server..."); server.start(); } } 客户端不会关闭连接。 服务器似乎在交换发生后直接关闭它。 我尝试删除os.close行，但服务器不会回复第二个请求。 但它也没有关闭它。 我有一种感觉它涉及在服务器对象的主代码中做一些事情，但我不知道是什么。 谷歌也没有出现太多变化。
这里有人有任何想法吗？ 任何帮助将非常感激。
看起来问题是你没有从请求中排出所有数据。 你应该继续做is.read()直到它返回-1，然后关闭它。
由于您没有消耗请求，因此仍有字节。 服务器不能简单地“跳转”到下一个请求; 它不像磁盘，更像是磁带。 在服务器可以到达下一个请求之前，服务器必须从当前请求中读取（并丢弃）所有数据。
没有限制，这可以用来攻击服务器; 所以服务器只会尝试排出一个限制，默认为64K。 您可能正在收到大于64K的请求。
通常，处理程序应首先读取整个请求。 否则它如何知道如何提供请求？
更严重的是，如果请求没有首先耗尽，则可能发生死锁。 客户端通常很简单：它们写入请求，然后读取响应。 如果服务器在读取所有请求之前写入响应，则客户端仍可以写入请求。 两人都在互相写信，但两人都没有读书。 如果缓冲区已满，那么我们处于死锁状态，两者都在写入时被阻止。 注意write（）没有超时！
为什么只有在前一个为null时才获得ResponseBody OutputStream？
if(os == null) { os = t.getResponseBody(); }
可能每次都更好地获取OutputStream，因为您无法确定前一个是否与当前Request的相同。
尝试调用t.close() ，服务器将回复
它是发送keep-alive标头的客户端 。 如果这样做，HttpServer不会关闭连接。 你不需要做任何事情。