我正在尝试读取刚刚关闭的套接字输入流的完整内容。但是,如果我只是尝试读取它正常工作,我会不断尝试同时写入该套接字的输出流。看起来写入其中“破坏”了套接字的输入流,并且无法读取剩余的内容。
以我为说明我的问题而制作的这个小例子为例:
@Test
public void socketTest() throws Throwable
{
new Thread(() -> {
try
{
ServerSocket serverSocket = new ServerSocket(5555);
while(true)
{
//keep listening
Socket socket = serverSocket.accept();
InputStream in = socket.getInputStream();
System.out.println(in.read());
Thread.sleep(2000);
try
{
socket.getOutputStream().write(3);
}
catch(Throwable ex)
{
System.out.println("Error writing");
ex.printStackTrace();
}
System.out.println(in.read());
in.close();
socket.close();
System.exit(0);
}
}
catch(Throwable ex)
{
System.out.println("Error reading");
ex.printStackTrace();
}
}).start();
Thread.sleep(100); //you might need this
Socket socket = new Socket("localhost", 5555);
OutputStream out = socket.getOutputStream();
out.write(1);
out.write(2);
out.close();
socket.close();
synchronized(this)
{
wait();
}
}
然而,2 从未被读取,而在流中写入 3 从未出错。我不在乎在流中写入是否会抛出,但我想阅读 2。有什么办法可以做到这一点?
我在 Windows 7 上使用 jdk1.8.0_91。即使在更新到 jdk1.8.0_181(现在是最新版本)之后,我也可以重现该问题。我还可以在另一台装有 Java 1.8.0_111 的 Windows 7 计算机上进行复制。
无法在 ArchLinux open-jdk1.8.0_172 上重现该错误,这是否意味着它是 Java 版本的错误?它似乎确实与 Windows 或至少 Oracle 的实现有关。
相关分类