java.io.EOFException从套接字读取时

Question

我以这种方式设置了服务器和客户端。我找不到EOFException的原因，因为它是随机发生的。每次客户端连接时，它都会引发以下异常，但我无法找出它的来源。它总是在读取客户端发送的内容之前发生。异常始终位于以下行：

ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());

以下是例外：

java.io.EOFException
at java.base/java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2860)
at java.base/java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:3355)
at java.base/java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:939)
at java.base/java.io.ObjectInputStream.<init>(ObjectInputStream.java:381)
at com.denesgarda.Socketeer.data.End$3.run(End.java:62)
at com.denesgarda.Socketeer.data.End$3.run(End.java:76)
at com.denesgarda.Socketeer.data.End$3.run(End.java:76)
at com.denesgarda.Socketeer.data.End.listen(End.java:83)
at Server.<init>(Server.java:10)
at SStart.main(SStart.java:5)

这是我的服务器代码：

if(listener == null) this.voidListener();
ServerSocket serverSocket = new ServerSocket(port);
End THIS = this;
TimerTask timerTask = new TimerTask() {
@Override
public void run() {
try {
Socket socket = serverSocket.accept();
socket.setSoTimeout(10000);
Connection connection = new Connection(THIS, new End((((InetSocketAddress) socket.getRemoteSocketAddress()).getAddress()).toString().replace("/","")), port, listener);
try {
ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());
Object o = objectInputStream.readObject();
if (o.equals("01101100 01101001 01110011 01110100 01100101 01101110 00100000 01110011 01110100 01100001 01110010 01110100")) {
listener.event(new ConnectionEvent(connection));
listener.event(new ConnectionSuccessfulEvent(connection));
}
else {
listener.event(new ReceivedEvent(connection, o));
}
socket.close();
}
catch(EOFException e) {
e.printStackTrace();
}
this.run();
}
catch(Exception e) {
e.printStackTrace();
}
}
};
timerTask.run();

这是我的客户端代码：

if(listener == null) this.voidListener();
Socket socket = new Socket(address, port);
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
try {
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
});
send("Message");

public void send(Object object) throws IOException {
Socket socket = new Socket(THAT.getAddress(), this.port);
OutputStream outputStream = socket.getOutputStream();
ObjectOutputStream objectOutputStream = new ObjectOutputStream(outputStream);
objectOutputStream.writeObject(object);
socket.close();
}

我尝试过什么

我之前曾多次尝试解决此问题。我尝试创建对象输出流。我已经切换了初始化对象输入流和对象输出流的顺序。这样服务器就不会在与客户端的死锁中冻结。我不知道是什么导致了此错误。

Answer 1

我想我知道这里发生了什么，但我不能确定，因为你的代码是零碎的，而且症状没有得到很好的描述。 (例如，例外不太可能真的是随机的。

首先有一个不争的事实。 连接的一端看到EOFException，因为另一端已关闭网络连接。 这就是该例外的含义。

在您的情况下，服务器在ObjectInputStream构造函数中出现异常，因为构造函数尝试读取客户端从不发送的对象流标头...在那个连接上。

现在，理论。 我想我知道为什么。 这是代码的相关部分(为简洁起见，剪掉了一些位)。

Socket socket = new Socket(address, port);
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
[...]
socket.close();
[...]
}
});
send("Message");

public void send(Object object) throws IOException {
Socket socket = new Socket(THAT.getAddress(), this.port);
[...]
}

请注意，有两个套接字！ 第一个被创建并传递给关闭钩子。 第二个是在send中创建和使用，然后关闭。

我认为问题是第一个套接字。 创建后，它会建立与服务器的连接。 服务器代码将accept它，然后尝试读取。 读取将阻止...因为客户端没有向该套接字写入任何内容。 然后客户端将调用打开并使用不同套接字的send。

最终，客户端应用程序退出。

当它退出时，关机挂钩关闭第一个套接字。 这会导致服务器端看到流的结束...并触发EOFException.

---

那么如何解决这个问题呢？

而是取决于"大局"。真正的客户端是向服务器发送一条消息，还是需要复用套接字来发送多条消息？

假设前者，解决方案很简单：

1. 摆脱创建套接字并将其传递给关闭钩子的代码。 正如你所写的，它没有任何有用的目的。

2. 重写send方法以将try 与资源一起使用;例如

   public void send(Object object) throws IOException {
   try (Socket socket = new Socket(THAT.getAddress(), this.port);
   OutputStream os = socket.getOutputStream();
   ObjectOutputStream oos = new ObjectOutputStream(os)) {
   oos.writeObject(object);
   }
   }
   

   请注意，上述内容将按正确的顺序自动关闭 3 个资源。