java - 通用套接字代理服务器也可以有效地与保持 Activity 连接一起工作(Java)

Question

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

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

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

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

这没有按预期工作的原因是:

每次从套接字写入和读取一个字节的速度很慢。所以我需要使用 BufferedInputStream/BufferedOutputStream 或任何具有相同功能的东西。当我使用 BufferedOutputStream 时，所有内容都只是缓冲，并且仅在我通过刷新或关闭告诉其写入时(或缓冲区填满时，这不是有趣的情况)才写入。

现在变得有趣了。几乎每个 HTTP 客户端在发送整个请求后实际上并不会关闭连接/流(保持 Activity 连接)。所以我实际上不知道什么时候我可以在不读取传输内容的情况下刷新输出流，确定它是否是HTTP，如果是，则解析它的 header ，选择内容长度 header 并通过读取仅限正文的指定字节数。

• 第一个问题:我是否正确，或者我是否遗漏了某些内容，并且有一个简单的方法可以克服这个问题？

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

• 第三个问题:如果我将自己限制为仅 HTTP 传输，是否有任何方法可以更简单地完成此操作？只是接受 HTTP 请求并将其重定向到其他地方(并返回响应)？

这里的目的是在 Java 1.5 中做到这一点(这是一个软限制，但会非常好)并保持响应延迟的增加尽可能低(10 毫秒还可以，50 毫秒很糟糕，100 毫秒是 Not Acceptable )。我将不胜感激任何帮助。

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

Answer 1

First question: Am I right, or am I missing something and there is an easy way to overcome this?

我认为您做出的一些假设并不正确。我已经做了很多流读/写，但从未遇到过您所描述的问题。 Java、W3 等背后的整个想法不需要了解接口(interface)实现如何工作的细节。我同意在某些特殊情况下，界面的行为不遵循隐含的(在某些情况下是字面的)契约(Contract)，但通常最好假设客户端遵循“规则”。

就像任何服务器一样，您应该知道什么协议(protocol)通过哪个端口传入。选择一个端口(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();