多线程服务器中ObjectInputStream.readObject阻塞及客户端流初始化失败问题

看起来你遇到了Java Socket使用对象流时的经典阻塞问题——服务器卡在readObject()，客户端连对象流都初始化不了。我帮你梳理几个最可能的原因和对应的解决办法：

1. 流的初始化顺序完全搞反了！ #

这是这类问题的头号元凶。ObjectOutputStream的构造函数会自动发送一个流头信息给对端，而ObjectInputStream的构造函数会一直等待这个流头。如果两端的流创建顺序不匹配，就会互相死等，直接卡死。

正确的初始化顺序必须严格对应： #

• 客户端：必须先创建ObjectOutputStream（先把流头发给服务器），再创建ObjectInputStream（等待服务器的流头）

  Socket socket = new Socket("localhost", 8080);
  // 先开输出流，发送流头
  ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
  // 再开输入流，等待服务器响应的流头
  ObjectInputStream in = new ObjectInputStream(socket.getInputStream());
  

• 服务器：必须先创建ObjectInputStream（先读取客户端发来的流头），再创建ObjectOutputStream（发送自己的流头）

  ServerSocket serverSocket = new ServerSocket(8080);
  Socket clientSocket = serverSocket.accept();
  // 先开输入流，读取客户端的流头
  ObjectInputStream in = new ObjectInputStream(clientSocket.getInputStream());
  // 再开输出流，发送服务器的流头
  ObjectOutputStream out = new ObjectOutputStream(clientSocket.getOutputStream());
  

如果两端都先开输入流，或者都先开输出流，必然会卡死在流初始化这一步。

2. 传输的对象没实现Serializable接口 #

你要发送的Pedestrian、返回的Message，还有Message里的司机列表对应的Driver类，所有涉及序列化/反序列化的对象必须实现java.io.Serializable接口，否则会直接抛出序列化异常，导致流阻塞或初始化失败。

示例代码：

// 给Pedestrian类加Serializable接口
public class Pedestrian implements Serializable {
    // 最好显式声明序列化版本号，避免类结构变化导致反序列化失败
    private static final long serialVersionUID = 1L;
    
    // 如果有不需要序列化的成员，加transient修饰
    private transient Scanner nonSerializableField;
    // 其他成员和方法...
}

// Message和Driver类也要做同样的处理
public class Message implements Serializable {
    private static final long serialVersionUID = 1L;
    private List<Driver> driverList; // Driver必须也实现Serializable
    // ...
}

3. 流的操作没做flush，或者关闭逻辑有问题 #

• 写完对象后一定要调用out.flush()，确保数据真正发送到对端，不然服务器会一直等数据过来，卡在readObject()
• 要在try-with-resources或者finally块中正确关闭流和Socket，避免半开连接影响后续通信：

  // 服务器端示例：用try-with-resources自动关闭流
  try (ObjectInputStream in = new ObjectInputStream(clientSocket.getInputStream());
       ObjectOutputStream out = new ObjectOutputStream(clientSocket.getOutputStream())) {
      // 读取客户端发来的Pedestrian
      Pedestrian pedestrian = (Pedestrian) in.readObject();
      // 业务逻辑：获取司机列表
      List<Driver> drivers = getDriverList();
      // 封装成Message发送回去
      Message response = new Message(drivers);
      out.writeObject(response);
      out.flush(); // 强制发送数据
  } catch (IOException | ClassNotFoundException e) {
      e.printStackTrace();
  } finally {
      // 关闭Socket
      if (clientSocket != null) {
          try {
              clientSocket.close();
          } catch (IOException e) {
              e.printStackTrace();
          }
      }
  }
  

4. 调试小技巧 #

如果还是找不到问题，可以加日志定位卡点：

• 在客户端初始化流的每一步打印日志，比如System.out.println("ObjectOutputStream 创建完成")
• 在服务器端accept()后、创建流的前后都加打印，看是不是卡在new ObjectInputStream()这一步
• 可以用控制台输出确认对象是否真的被序列化发送，或者有没有异常被吞掉

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