奇怪的 Java 套接字行为（连接，但不发送）

Question

我有一个相当复杂的项目，可以归结为通过对象流进行通信的简单客户端/服务器。

对于两个连续连接，一切都完美无缺（我连接一次，工作，断开连接，然后再次连接，工作，然后断开连接）。客户端连接，执行其业务，然后关闭。服务器成功关闭对象输出流和套接字，没有 IO 错误。

当我第三次尝试连接时，连接似乎已通过（ServerSocket.accept() 方法已通过并成功创建了 ObjectOutputStream）。然而，没有数据被传递。 inputStream.readUnshared() 方法只是阻塞。

我采取了以下内存预防措施：

1. 当需要关闭套接字时，所有正在运行的线程都将停止，并且所有对象都将被清空。
2. 在每个 writeUnshared() 方法之后 调用时，ObjectOutputBuffer 是 冲洗并重置。

有没有人遇到过类似的问题，或者有没有人有什么建议？恐怕我的项目相当大，因此复制代码是有问题的。

该项目可归结为：

服务器主

ServerSocket serverSocket = new ServerSocket(port);

while (true) {
    new WorkThread(serverSocket.accept()).start();
}

工作线程（服务器）

public void run() {
    ObjectInputBuffer inputBuffer = new ObjectInputBuffer(new BufferedInputStream(socket.getInputStream()));

    while (running) {
         try {
              Object myObject = inputBuffer.readUnshared();

              // do work is not specified in this sample
              doWork(myObject);
         } catch (IOException e) {   
              running = false;
         }
    }

    try {
         inputBuffer.close();
         socket.close(); 
    } catch (Exception e) {
         System.out.println("Could not close.");
    }
}

客户端

public Client() {
    Object myObject;
    Socket mySocket = new Socket(address, port);

    try {
         ObjectOutputBuffer output = new ObjectOutputBuffer(new BufferedOutputStream(mySocket.getOutputStream()));

         output.reset();
         output.flush();
    } catch (Exception e) {
         System.out.println("Could not get an input.");
         mySocket.close();
         return;
    }

    // get object data is not specified in this sample. it simply returns a serializable object
    myObject = getObjectData();

    while (myObject != null) {
         try {
              output.writeUnshared(myObject);
              output.reset();
              output.flush();
         } catch (Exception e) {
              e.printStackTrace();
              break;
         } // catch
    } // while

    try {
         output.close();
         socket.close();
    } catch (Exception e) { 
         System.out.println("Could not close.");
    }
}

感谢所有可能提供帮助的人！

Answer 1

(1)什么是ObjectInputBuffer和ObjectOutputBuffer？您的意思是 ObjectInputStream &对象输出流？

(2) 如果是这样，在创建ObjectOutputStream后立即调用reset()只是浪费时间和带宽。

(3) 为什么在创建输出流的异常上打印“无法获取输入”？

(4) 当您遇到异常时，您应该始终打印它的消息 - 不要完全用您自己的消息替换它，那只是丢弃有用的信息。

(5) 您假设读取时any IOException 表示流结束。只有 EOFException 意味着这一点。应打印或记录任何其他 IOException。显然，您在这里遇到了其他一些异常并忽略了它。

(6) 为什么你总是发送同一个对象？

Answer 2

来自 readUnshared() 的 ObjectInputStream API：

从中读取“非共享”对象
对象输入流。这个方法是
与 readObject 相同，除了
它会阻止后续调用
readObject 和 readUnshared from
返回对的附加引用
通过获得的反序列化实例
这次通话。

这可能是问题所在吗？请改用 readObject()。