Java Socket无法获取输入流，求排查错误原因

问题代码片段 #

while (true) {
  System.out.println("Waiting");
  ois = new ObjectInputStream(socket.getInputStream());
  System.out.println("Rcvd Stream");
  client listener.onDataReceived(ois.readObject());
}

程序输出 #

Waiting 

问题 #

程序卡在Waiting输出后阻塞，无法成功创建输入流。

错误原因及修正方案 #

1. 循环内重复创建ObjectInputStream
ObjectInputStream的构造函数会等待读取流开头的序列化魔术标记，这个标记需要由通信另一端的ObjectOutputStream提前写入。如果每次循环都新建ObjectInputStream，不仅会因等待标记一直阻塞，还会破坏流的读写状态——流的指针是连续的，重复创建会导致读取位置错乱。正确做法是只初始化一次输入流，放在循环外部。

2. 未处理异常
   代码未捕获IOException或ClassNotFoundException，一旦流操作出错会直接终止程序，无法排查具体问题。

3. 资源未妥善管理
   流和Socket资源没有在合适时机关闭，会导致资源泄漏。

修正后的示例代码 #

try {
    // 循环外初始化输入流，确保通信另一端已先创建ObjectOutputStream
    ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
    while (true) {
        System.out.println("Waiting");
        System.out.println("Rcvd Stream");
        try {
            Object receivedData = ois.readObject();
            client listener.onDataReceived(receivedData);
        } catch (ClassNotFoundException e) {
            System.err.println("反序列化对象失败: " + e.getMessage());
        } catch (IOException e) {
            System.err.println("流读取异常: " + e.getMessage());
            break; // 流断开时退出循环
        }
    }
    // 最后关闭资源
    ois.close();
    socket.close();
} catch (IOException e) {
    System.err.println("输入流初始化失败: " + e.getMessage());
}

额外注意点 #

通信两端的流创建顺序要对应：必须先创建ObjectOutputStream，再创建ObjectInputStream。因为ObjectOutputStream的构造函数会主动写入序列化头部数据，只有这个头部存在，ObjectInputStream才能成功完成初始化，不会一直阻塞。

内容的提问来源于stack exchange，提问作者Saaketh