Java 创建新的 ObjectInputStream 块

debugging sockets java inputstream

2022-09-02 02:09:19

我正在尝试使用从套接字中检索到的输入流创建新的 ObjectInputStream。这是我的代码：

这是我的 MessageGetterSender 类的构造函数。该程序无法到达检查点 4。

public MessageGetterSender(Socket socket) {

    System.out.println("MessageGetterSender: Checkpoint 1");

    this.socket = socket;

    // Get input and output streams
    try {
        System.out.println("MessageGetterSender: Checkpoint 2");

        InputStream is = socket.getInputStream();

        System.out.println("MessageGetterSender: Checkpoint 3");

        this.in = new ObjectInputStream(is);

        System.out.println("MessageGetterSender: Checkpoint 4");

    } catch (IOException ioe) {
        System.out.println("Could not get ObjectInputStream on socket: " + socket.getLocalPort());
    }

    try {
        this.out = new ObjectOutputStream(socket.getOutputStream());
    } catch (IOException ioe) {
        System.out.println("Could not get ObjectOutputStream on socket: " + socket.getLocalPort());
    }

    System.out.println("MessageGetterSender: Checkpoint 5");
}

我正在从一个类中实例化一个新的 MessageGetterSender 对象，在该类中，我连接到服务器以获取套接字。这是相关代码。它是 InstantMessageClass 的构造函数，InstantMessageClass 是实例化 MessageGetterSender 对象的类：

public InstantMessageClient(String username) {

try {
    socket = new Socket("localhost", 5555);
} catch (IOException ioe) {
    System.out.println("Error: Could not connect to socket on port: " + serverPort);
}

messageGetterSender = new MessageGetterSender(socket);

...

由于代码不会执行到检查点 4，但它确实到达了检查点 3，我非常确定 ObjectInputStream 的实例化是罪魁祸首。我不知道为什么。有什么想法吗？感谢您的帮助。

答案 1

只是为了扩展FatGuy对其他发现这一点的Google员工的答案;解决这个“先有鸡还是先有蛋”的问题，是让每一方先打开输出流，冲洗输出流，然后打开输入流。

ObjectOutputStream out = new ObjectOutputStream(socket.getOutputStream());
out.flush();
ObjectInputStream in = new ObjectInputStream(socket.getInputStream());

答案 2

在构造函数中构造时，类会尝试读取连接另一端的关联已写入的标头。在读取该标头之前，它不会返回。因此，如果您看到构造函数“挂起”，这是因为套接字的另一端尚未使用，或者尚未刷新数据。ObjectInputStreamObjectOutputStreamObjectOutputStream