Java的InputStream可以超时读取吗？如何读取？

可以从具有超时的输入流中读取数据吗？

问题的中心是开发一种可以从输入流中读取数据的方法指定的超时时间。这样的方法 MaybeRead 的目标是，当在指定时间内有数据可用时，返回与 InputStream 中的 read() 方法相同的结果；如果没有可用数据，则返回 -2。挑战在于确保任何生成的线程在执行期间终止。

Java 输入流限制

在探索潜在的解决方案之前，必须先了解 Java 输入流的具体限制：

1. read() 可能是不可中断的，防止数据传输期间中断
2. 将 InputStream 包装在 Reader 或 InterruptibleChannel 中没有提供任何解决方案，因为它们仅依赖于 InputStream 方法。
3. available() 可以合法地返回 0，即使数据存在。
4. close() 可能会阻塞或无效。
5. 不存在终止其他方法的固有机制

对抗限制

利用 InputStream.available()

尽管文档声明可用() 可以返回 0，证据表明它提供了可用数据的准确估计。具体的InputStream子类策略性地覆盖available()以提供有意义的信息。

特定于平台的警告

Windows/Cygwin：仅在以下情况下提供输入按“返回”。否则，InputStream.available() 按预期返回 0。

简单解决方案（无阻塞）

byte[] inputData = new byte[1024];
int result = is.read(inputData, 0, is.available());  // Reads as much data as immediately available

综合解决方案（最大数据）获取）

public static int readInputStreamWithTimeout(InputStream is, byte[] b, int timeoutMillis)
     throws IOException  {
     int bufferOffset = 0;
     long maxTimeMillis = System.currentTimeMillis() + timeoutMillis;
     while (System.currentTimeMillis() < maxTimeMillis && bufferOffset < b.length) {
         int readLength = java.lang.Math.min(is.available(),b.length-bufferOffset);
         int readResult = is.read(b, bufferOffset, readLength);
         if (readResult == -1) break;
         bufferOffset += readResult;
     }
     return bufferOffset;
 }

用法：

byte[] inputData = new byte[1024];
int readCount = readInputStreamWithTimeout(System.in, inputData, 6000);  // 6 second timeout

以上是Java的InputStream可以超时读取吗？如何读取？的详细内容。更多信息请关注PHP中文网其他相关文章！