Java TCP FIN，但无流内eof

Question

我一直在使用org.apache.commons.net。telnet连接到控制流并向摄像机发送命令。我发送一个数据流请求并打开一个新线程，该线程扫描来自摄像机传感器的图像，并将数据作为原始字节发送给我。我使用的是标准java。io流入和流出以读取。我正在向文件中写入的扩展流……只是原始字节。然而，我在读取套接字发送的数据时陷入了一个无限循环。Ainstream.read（）

我已经在Wireshark中确认，所有内容都在传递给我的程序，并发送了一个FIN，但出于某种原因，JAVA没有拾取FIN并给我-1。文件的外流仍然打开，我从来没有从传感器那里得到“完整”的图像扫描。（我一直在手动杀死流并读取图像。最终目标是将此图像放入标签中，并将其用于动态偶尔的相机曝光更新。）

是否有某种方法可以检测FIN消息并告诉循环在流内读取（）之外终止？

其他信息：Win 7（企业版），Netbeans IDE

Answer 1

匿名用户

>

你真的认为你的流读代码很特别，所以你不能发布它？我对此表示怀疑。

<代码>。available（）不是对流结束的测试。它只返回您可以安全读取的字节数，而不会被阻止等待传入数据。

图像数据结束后，你从流中得到了什么？

这是InputStream使用的示例，我100%确定它是有效的并且正确处理eof-s、异常和流关闭等：

 static final int BUFFER_SIZE = 1024 * 32;

 public static ByteBuffer buffer(InputStream stream) throws IOException {
     // try (<resourse>) to properly handle 'stream.close()`
     try (BufferedInputStream reader = new BufferedInputStream(stream)) {
         byte[] buffer = new byte[BUFFER_SIZE];
         ByteBuffer result = ByteBuffer.allocate(BUFFER_SIZE);

         int totalReaded = 0, readed;
         while ((readed = reader.read(buffer)) >= 0) {
             if (readed > result.remaining()) {
                 // well, we've exceeded capacity of given buffer, make it grow
                 ByteBuffer t = result;
                 result = (ByteBuffer) ByteBuffer.allocate((int)((totalReaded + readed) * 1.3));
                 result.put(t.array(), 0, totalReaded);
             }

             totalReaded += readed;
             result.put(buffer, 0, readed);
         }

         return ByteBuffer.wrap(result.array(), 0, totalReaded);
     }
 }

Answer 2

Ainstream.read（）

当然可以。它丢弃了一个字节，而且它首先不是一个有效的测试。您的读取循环应该如下所示：

int ch;
while ((ch = instream.read()) != -1)
{
    // ... Cast ch to a byte and use it somehow ...
}

或这个：

int count;
byte[] buffer = new byte[8192];
while ((count = instream.read(buffer)) > 0)
{
    // ...
    // for example:
    out.write(buffer, 0, count);
}