Java InputStream.available() 读取后返回 > 0

Question

我正在构建一个聊天程序，其中主机通过套接字连接并使用 ObjectInput 和 ObjectOutput 流相互交谈。主机根据键盘输入构建一个字符串，并将其与整数数组一起发送给其他主机。

主机通过 readObject() 成功读取消息后，while(true) 循环继续，并且该主机在下一次调用 readObject() 时挂起。我只能推测这是因为 indata.available() 即使在读取了其中的内容之后也会返回 true，并且当它在发送其他内容之前尝试再次读取时，它会阻塞（等待）。

相关代码的sn-p如下。我做了一些研究，发现我无法刷新或清空输入流。我也无法关闭它 - 由于持续运行的聊天程序的性质，它需要保持打开状态才能继续阅读。

另外，我知道我正在检查 indata.available()，然后使用 inputs.readObject() 读取。我认为这是正确的做法，但如果我错了，请纠正我。

我不知道该怎么办！如果我没有将对象写入流，我需要 indata.available() 返回 0。

    private InputStream[] indata;                
    private ObjectInputStream[] inputs;          
    private ObjectOutputStream[] outputs;        
    private int[] stamps;   

    // Establish connections via sockets between 3 hosts, serverless                     

    while (true) {
        // Build a message
        for (all hosts that aren't myself) {
            if ( i != rank ) {
                outputs[i].writeObject( message );
                outputs[i].writeObject( stamps );
                outputs[i].flush( ); 
                outputs[i].reset( );
            }
        }

        // Read a message in from a host that sent one
        for (all hosts that aren't myself) {
            if (indata[j].available() > 0) {
                String message = (String)inputs[j].readObject();
                int[] senderStamps = (int[])inputs[j].readObject();
            }
        }
    }

一些附加信息，为了澄清：

我使用 available() 是因为讲师在他的代码中使用了它，我不允许更改它。此外，当只发送一个对象（字符串）时，对 available() 的调用按预期工作 - 发送端的唯一代码是“writeObject”和“flush”。添加代码以发送数组是我的工作，当我这样做时，我还必须添加代码以 reset() ObjectOutputStream（或者我遇到其他问题 - 发送、修改和发送数组时再次在发送之间不调用 reset()，则发送原始的、未修改的版本而不是新修改的版本）。

我不能只阻塞读取，因为读取阻塞的进程无法写入其他主机，即使主机没有可读取的内容，我也需要能够写入。

另外，我们不允许使用多个线程。

Answer 1

我知道发生了什么，但我不确定我明白为什么。

当我在发送后调用reset()，然后在接收端读取对象时，流中还剩下1个字节。这就是导致我陷入 if 子句然后再次阅读时阻塞的原因（因为真的没有要阅读的对象）。

我不得不调用reset，因为我正在发送一个持久对象（数组）。我注意到我只发送字符串时不必调用reset，字符串和数组之间的区别在于数组是类的数据成员，而每次循环都重新创建字符串跑了。

所以，我创建了一个我想要发送的数组的非持久副本，并发送了该副本。当我这样做时，我不必调用重置（仍然不明白为什么）。此外，从输入流中读取后，内部还剩下 0 个字节，因此它永远不会将程序置于 readObject 会阻塞的位置。

我想我有点理解为什么我在发送非持久对象时不必重置，但我不明白为什么 reset() 会导致数据留在相应的输入流中。

无论哪种方式，它现在都按预期工作。