使用ObjectInputStream/ObjectOutputStream的Java网络编程客户端阻塞问题求助

嘿，这个问题我之前踩过好几次坑！客户端创建ObjectInputStream时阻塞，本质是流的初始化顺序不匹配导致的，咱们一步步来解决：

问题根源 #

ObjectInputStream的构造函数会尝试读取一个由ObjectOutputStream写入的序列化头部（包含魔术数字和版本信息）。如果你的客户端先创建ObjectInputStream，但服务端还没创建ObjectOutputStream并写入这个头部，客户端就会一直卡在那里等数据，自然就阻塞了。

另外还要确认你的UserInfo类已经正确实现了Serializable接口，不然后续序列化会直接报错，这个是基础前提哦。

解决方案：统一流的创建顺序 #

不管是服务端还是客户端，都要先创建ObjectOutputStream，再创建ObjectInputStream。这样双方的流初始化时能完成头部的读写匹配，不会出现一方等待的情况。

修正后的服务端示例代码 #

public class Server {
    public static void main(String[] args) throws IOException, ClassNotFoundException {
        ServerSocket serverSocket = new ServerSocket(8888);
        Socket socket = serverSocket.accept();
        
        // 先创建ObjectOutputStream
        ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
        // 再创建ObjectInputStream
        ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
        
        // 后续的读写操作
        UserInfo receivedUser = (UserInfo) ois.readObject();
        System.out.println("收到用户信息：" + receivedUser);
        
        // 发送响应
        oos.writeObject("已收到信息");
        
        // 关闭资源
        ois.close();
        oos.close();
        socket.close();
        serverSocket.close();
    }
}

修正后的客户端示例代码 #

public class Client {
    static String key, temp, tester;
    static UserInfo ui = new UserInfo();

    public static void main(String[] args) throws UnknownHostException, IOException, ClassNotFoundException {
        Socket socket = new Socket("localhost", 8888);
        
        // 先创建ObjectOutputStream
        ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
        // 再创建ObjectInputStream
        ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
        
        // 发送UserInfo对象
        ui.setName("测试用户"); // 假设UserInfo有对应的setter方法
        oos.writeObject(ui);
        
        // 读取服务端响应
        String response = (String) ois.readObject();
        System.out.println("服务端响应：" + response);
        
        // 关闭资源
        ois.close();
        oos.close();
        socket.close();
    }
}

补充：UserInfo类的要求 #

一定要让UserInfo实现Serializable接口，否则无法序列化传输：

import java.io.Serializable;

public class UserInfo implements Serializable {
    // 建议显式声明序列化版本号，避免类结构变化后出现序列化异常
    private static final long serialVersionUID = 1L;
    private String name;
    // 可添加其他字段、getter/setter方法
}

额外注意事项 #

• 如果需要多次读写，记得写完后调用oos.flush()确保数据发送出去，避免数据在缓冲区堆积。
• 关闭流的时候尽量用try-with-resources语法，自动管理资源，避免内存泄漏：

try (Socket socket = new Socket("localhost", 8888);
     ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
     ObjectInputStream ois = new ObjectInputStream(socket.getInputStream())) {
    // 业务代码逻辑
} catch (IOException | ClassNotFoundException e) {
    e.printStackTrace();
}

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