如何在不讀取InputStream的情況下檢查InputStream是否爲空？

Question

我想知道InputStreamn是否爲空，但不使用方法read（）。有沒有辦法知道它是空的而不閱讀它？

Answer 1

我認爲您在尋找inputstream.available()。它沒有告訴你它是否爲空，但是它可以告訴你數據是否被讀取。

Answer 2

不，你不能。 InputStream旨在與遠程資源一起使用，因此直到實際讀取它時才能知道它是否在那裏。

但是，您也許可以使用java.io.PushbackInputStream，它允許您從流中讀取數據，看看是否存在某些內容，然後將它「推回」流中（這不是它真正起作用的方式，但這是事實它對客戶端代碼的行爲方式）。

Answer 3

您可以使用available()方法詢問流是否有任何可用的數據在您稱之爲的那一刻。但是，該功能不能保證適用於所有類型的輸入流。這意味着您不能使用available()來確定是否實際阻止對read()的呼叫。

Answer 4

如果InputStream你使用支持標記/復位的支持，你也可以嘗試讀取數據流的第一個字節，然後將其恢復到原來的位置：

input.mark(1); 
final int bytesRead = input.read(new byte[1]); 
input.reset(); 
if (bytesRead != -1) { 
    //stream not empty 
} else { 
    //stream empty 
} 

如果你不這樣做控制您正在使用什麼樣的InputStream，您可以使用markSupported()方法來檢查標記/重置是否可以在數據流上工作，否則返回available()方法或java.io.PushbackInputStream方法。

Answer 5

如何使用inputStreamReader.ready()找出？

import java.io.InputStreamReader; 

/// ... 

InputStreamReader reader = new InputStreamReader(inputStream); 
if (reader.ready()) { 
    // do something 
} 

// ... 

Answer 6

基於使用PushbackInputStream的建議，你會發現這裏的執行爲例：

/** 
* @author Lorber Sebastien <i>(lorber.sebastien@gmail.com)</i> 
*/ 
public class NonEmptyInputStream extends FilterInputStream { 

    /** 
    * Once this stream has been created, do not consume the original InputStream 
    * because there will be one missing byte... 
    * @param originalInputStream 
    * @throws IOException 
    * @throws EmptyInputStreamException 
    */ 
    public NonEmptyInputStream(InputStream originalInputStream) throws IOException, EmptyInputStreamException { 
    super(checkStreamIsNotEmpty(originalInputStream)); 
    } 


    /** 
    * Permits to check the InputStream is empty or not 
    * Please note that only the returned InputStream must be consummed. 
    * 
    * see: 
    * http://stackoverflow.com/questions/1524299/how-can-i-check-if-an-inputstream-is-empty-without-reading-from-it 
    * 
    * @param inputStream 
    * @return 
    */ 
    private static InputStream checkStreamIsNotEmpty(InputStream inputStream) throws IOException, EmptyInputStreamException { 
    Preconditions.checkArgument(inputStream != null,"The InputStream is mandatory"); 
    PushbackInputStream pushbackInputStream = new PushbackInputStream(inputStream); 
    int b; 
    b = pushbackInputStream.read(); 
    if (b == -1) { 
     throw new EmptyInputStreamException("No byte can be read from stream " + inputStream); 
    } 
    pushbackInputStream.unread(b); 
    return pushbackInputStream; 
    } 

    public static class EmptyInputStreamException extends RuntimeException { 
    public EmptyInputStreamException(String message) { 
     super(message); 
    } 
    } 

} 

這裏有一些經過測試：

@Test(expected = EmptyInputStreamException.class) 
    public void test_check_empty_input_stream_raises_exception_for_empty_stream() throws IOException { 
    InputStream emptyStream = new ByteArrayInputStream(new byte[0]); 
    new NonEmptyInputStream(emptyStream); 
    } 

    @Test 
    public void test_check_empty_input_stream_ok_for_non_empty_stream_and_returned_stream_can_be_consummed_fully() throws IOException { 
    String streamContent = "HELLooooô wörld"; 
    InputStream inputStream = IOUtils.toInputStream(streamContent, StandardCharsets.UTF_8); 
    inputStream = new NonEmptyInputStream(inputStream); 
    assertThat(IOUtils.toString(inputStream,StandardCharsets.UTF_8)).isEqualTo(streamContent); 
    } 

Answer 7

public void run() { 
    byte[] buffer = new byte[256]; 
    int bytes;      

    while (true) { 
     try { 
      bytes = mmInStream.read(buffer); 
      mHandler.obtainMessage(RECIEVE_MESSAGE, bytes, -1, buffer).sendToTarget(); 
     } catch (IOException e) { 
      break; 
     } 
    } 
}