0

我正在尝试在 Java 中创建一个通用的 TCP 套接字代理服务器 - 在服务器套接字上被接受的任何连接都是双向连接到创建到预期目标的另一个套接字。

我用谷歌搜索了很多，没有一篇文章、教程或我发现的任何其他建议可以解决我遇到的基本问题。首先是代码的主干：

is = socket1.getInputStream();
os = socket2.getOutputStream();

int read = 0;
while ((read = is.read()) != -1) {
    os.write(read);
}

这不能按预期工作的原因是：

一次一个字节地从套接字写入和读取是很慢的。所以我需要使用 BufferedInputStream/BufferedOutputStream 或任何类似的东西。当我使用 BufferedOutputStream 时，所有内容都只是被缓冲，并且只有在我通过刷新或关闭告诉它被写入（或者当缓冲区填满时，这不是有趣的情况）时才被写入。

现在它变得有趣了。几乎每个 HTTP 客户端在发送整个请求（保持活动连接）后实际上并没有关闭连接/流。所以我实际上不知道什么时候可以在不读取传输内容的情况下刷新输出流，确定它是否是 HTTP，如果是，解析它的标头，选择 Content Length 标头，然后只读取指定数量的字节身体。

  • 第一个问题：我是对的，还是我错过了什么，有一种简单的方法可以克服这个问题？

  • 第二个问题：如果我是对的，是否有任何工具可以帮助我进行解析？自己解析 HTTP 通信听起来是个非常糟糕的主意。但我不需要 HttpServer 或 HttpClient - 它们提供的太多了，我只需要很少，而且有时需要（并非所有传输都是 HTTP）。

  • 第三个问题：如果我将自己限制为仅使用 HTTP 传输，有什么方法可以更简单地做到这一点？只是接受 HTTP 请求并将它们重定向到其他地方（并返回响应）？

这里的目的是在 Java 1.5 中执行此操作（这是一个软限制，但会非常好）并尽可能降低响应延迟的增加（10 ms 可以，50 ms 很烂，100 ms 是不可接受的）。我将不胜感激任何帮助。

澄清：也许我不够清楚，假设是第一个反应。这里的问题是read() 方法在一个 HTTP 请求后不会返回 -1，因为连接对另一个请求保持打开......所以循环不会在那个单个请求之后结束，read() 调用挂起阻塞并等待另一个输入。此外，如果我不调用flush()，缓冲流将无法工作，但我不知道何时调用它——不知道如何在不解析传输内容的情况下识别HTTP请求的结束。

4

1 回答 1

1

第一个问题：我是对的，还是我错过了什么，有一种简单的方法可以克服这个问题？

我认为您正在做出一些不正确的假设。我做了很多流读/写，从来没有遇到过你描述的问题。Java、W3 等背后的整个想法不需要了解接口实现如何工作的细节。我同意当接口的行为不遵循隐含的（在某些情况下是字面的）合同时存在极端情况，但通常最好假设客户端遵循“规则”。

就像任何服务器一样，您应该知道通过哪个端口传输的协议。选择一个端口（80？）并知道进入该端口的任何流量都是 HTTP 流量。同样适用于 FTP、SFTP 等。

对于您关于流缓慢和缓冲的观点，您是否尝试过使用字节数组并指定缓冲区大小？

private final static int BUFFERSIZE = 1024 << 10;  // 1 MB
...
// .. in some method
BufferedInputStream in = new BufferedInputStream(inSocket.getInputStream(), BUFFERSIZE);
BufferedOutputStream out = new BufferedOutputStream(outSocket.getOutputStream(),BUFFERSIZE);
byte[] bytes = new byte[BUFFERSIZE];
int bytesRead;
while((bytesRead = in.read(bytes)) != -1){
       out.write(bytes,0,bytesRead);
}
// omitting try catch finally logic
in.close(); 
out.close();
于 2013-11-06T13:24:27.430 回答