java - 创建 ObjectInputStream 对象时程序停止

Question

这个问题已经有答案了:

new ObjectInputStream() blocks (2 个回答)

已关闭 4 年前。

我在服务器和客户端有两种方法:

服务器:

@Override
    public void start(Stage primaryStage) throws Exception {
        socket = new Socket("localhost", 9998);
        System.out.println("connected");
        input = new ObjectInputStream(socket.getInputStream());
        System.out.println("1");
        output = new ObjectOutputStream(socket.getOutputStream());

        output.writeObject(new Message(CONFIG, "ping"));

        FXMLLoader loader = new FXMLLoader(this.getClass().getResource("/window/fxmls/window.fxml"));
        loader.setController(this);
        AnchorPane anchorPane = loader.load();
        Scene scene = new Scene(anchorPane);
        primaryStage.setScene(scene);
        primaryStage.show();
    }

客户:

@Override
    public void run() {
        try {
            serverSocket = new ServerSocket(9998);
            while (true) {
                Socket socket = serverSocket.accept();
                System.out.println("connected");
                input = new ObjectInputStream(socket.getInputStream());
                System.out.println(1);
                output = new ObjectOutputStream(socket.getOutputStream());
                Message message = (Message) input.readObject();
                if (message.getHeader() == CONFIG && message.getMessage().equals("ping")) {
                    System.out.println(message.getMessage());
                }
            }
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

当客户端开始运行时，发送检查消息"ping “使用 ObjecInputStream，但上述方法中的代码在 System.out.println(1); 上停止，我不知道为什么。之前类似的代码都在运行。我做错了什么？input = new ObjectInputStream(socket.getInputStream()); 正在等待我没有做过的事情？

Answer 1

这里基本上陷入了僵局。如果您首先启动服务器，它将开始监听端口 9998 上的连接。然后当您启动客户端时，它将与服务器建立连接。服务器接受连接，并尝试创建一个ObjectInputStream。 ObjectInputStream 构造函数(和服务器线程)将阻塞，直到它可以从客户端读取流 header (客户端尚未发送)。因此，服务器不会创建 ObjectOutputStream(这会导致数据发送到客户端)。

同时，客户端尝试创建 ObjectInputStream 并将被阻止，因为服务器尚未发送任何数据。结果是 ObjectInputStream 构造函数中阻塞了两个线程。

解决方案非常简单 - 在服务器中，首先创建 ObjectOutputStream，然后创建 ObjectInputStream:

socket = new Socket("localhost", 9998);
output = new ObjectOutputStream(socket.getOutputStream());
input = new ObjectInputStream(socket.getInputStream());