Java创建新的ObjectInputStream块

| 我正在尝试使用从Socket检索的InputStream创建新的ObjectInputStream。这是我的代码：这是我的MessageGetterSender类的构造函数。程序无法到达Checkpoint 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的实例化是罪魁祸首。我不知道为什么。有任何想法吗？谢谢您的帮助。

已邀请:

3 个回复

搁手

当构造一个ObjectInputStream时，该类将在构造函数中尝试读取连接另一端相关的ObjectOutputStream已写入的标头。在读取该标头之前，它不会返回。因此，如果看到的是构造函数“'hang \'”，那是因为套接字的另一侧要么未使用ѭ3flush，要么尚未刷新数据。

缔恃钨

只是为了扩展FatGuy对其他发现此问题的Google员工的回答；解决“鸡和鸡蛋问题”的方法是首先让双方打开输出流，冲洗输出流，然后再打开输入流。

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

芭隘的盘石

您还可以延迟ObjectInputStream的初始化，直到基础流中的数据可用为止。无论流初始化顺序如何，此方法都有效，并且如果通道的一端在无法更改的库代码中，则该方法特别有用。

要回复问题请先登录或注册

Java创建新的ObjectInputStream块

3 个回复

发起人

inputstream

debugging

sockets

java

问题状态

Java创建新的ObjectInputStream块

与内容相关的链接

3 个回复

发起人

inputstream

debugging

sockets

java

问题状态