程序在创建 ObjectInputStream 对象时停止

Question

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

服务器：

@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();
        }
    }

客户端启动时运行，使用 ObjecInputStream 发送检查消息 "ping"，但上述方法中的代码在 System.out.println(1); 停止，我不知道为什么。之前在类似的code all 是运行。我做错了什么？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());

程序在创建 ObjectInputStream 对象时停止

The program stops when the ObjectInputStream object is created

java

sockets

objectoutputstream