Java中怎么將OutputStream 轉換成InputStream

Java中怎么將OutputStream 轉換成InputStream，相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。

一、使用byte array緩存轉換

ByteArrayOutputStream baos = new ByteArrayOutputStream();
ByteArrayInputStream swapStream = new ByteArrayInputStream(baos.toByteArray());

這種方式最為簡單，但是要求執行baos.toByteArray()這個方法之前，需要的數據已經完全寫入，即無法做到邊寫邊讀，另外其需要足夠的內存來一次性的容納這些數據。

二、使用Pipes

PipedInputStream in = new PipedInputStream();
PipedOutputStream out = new PipedOutputStream(in);
new Thread(
  new Runnable(){
    public void run(){
      class1.putDataOnOutputStream(out);
    }
  }
).start();
class2.processDataFromInputStream(in);

 顧名思義，pipe即為管道，這種方法支持流式的方式，一端寫一端讀，向PipedOutputStream寫入的數據可以從PipedInputStream讀出，很好的解決了方法一中的短處，是個人較為推薦的一種方式。

注意：

• PipedInputStream中存儲數據的數組大小默認為1024，且使用過程中不可擴充，當一次性寫入的數據超過這個數，則會有個AssertionError拋出。當然，我們可以在初始化PipedInputStream的時候進行設置。

• 上述代碼僅為pipe的一種使用的方式，其也可以初始化如下：

PipedOutputStream out = new PipedOutputStream();
PipedInputStream in = new PipedInputStream(out);

 兩種方式等價。

三、使用Circular Buffers

作為PipedInputStream和PipedOutputStream的一種替代方式，CircularBuffer有著更為簡單的數據結構和使用方法，但是其并不是JDK自帶的類需要額外引入。

<!-- https://mvnrepository.com/artifact/org.ostermiller/utils -->
<dependency>
    <groupId>org.ostermiller</groupId>
    <artifactId>utils</artifactId>
    <version>1.07.00</version>
</dependency>

CircularByteBuffer cbb = new CircularByteBuffer();
new Thread(
  new Runnable(){
    public void run(){
      class1.putDataOnOutputStream(cbb.getOutputStream());
    }
  }
).start();
class2.processDataFromInputStream(cbb.getInputStream());

 如上，CircularByteBuffer將InputStream和OutputStream作為其屬性，相對于方法二使用更為簡化，且更易理解。

注意：

• 方法二和方法三使用類似，但是其不建議再同一個線程中處理OutputStram和InputStream，以為容易造成死鎖的問題

• 方法二和方法三中，當數組滿的時候，需要等待消費，造成block，所以建議使用者初始化的時候根據使用情況來定義初始容量。 

看完上述內容，你們掌握Java中怎么將OutputStream 轉換成InputStream的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！