outputstream转inputstream

来源:趣味经验馆 2.24W

outputstream怎么转换成inputstream有三种方法。

方法一:使用字节数组缓存数据,输入代码:

ByteArrayOutputStream out = new ByteArrayOutputStream();

class1.putDataOnOutputStream(out);

class2.processDataFromInputStream(

new ByteArrayInputStream(out.toByteArray())

);

outputstream转inputstream

方法二:使用管道

第一种方法的问题是你必须有足够的内存缓存所有数据。你可以使用文件系统缓存更多数据,但无论如何可处理数据的大小还是受到限制。

解决方法是创建一个线程产生数据到PipedOutputStream。当前线程可从中读取数据。

输入代码:

PipedInputStream in = new PipedInputStream();

PipedOUtputStream out = new PipedOutputStream(in);

new Thread(

new Runnable(){

public void run(){

class1.putDataOnOutputStream(out);

}

}

).start();

class2.processDataFromInputStream(in);|||

outputstream转inputstream 第2张

方法三:使用循环缓存区

方法二中的两个管道流,实际上管理着一个隐藏的循环缓存区。使用一个显式的循环缓存区更易于理解。CircularBuffers 有如下优点

一个CircularBuffers类而不是两个管道类。

较于缓存所有数据和额外线程的方法更容易使用。

你可以更改缓存大小而不必受限于管道缓存区1K的固定缓存大小。

多线程情形:

CircularByteBuffer cbb = new CircularByteBuffer();

new Thread(

new Runnable(){

public void run(){

class1.putDataOnOutputStream(cbb.getOutputStream());

}

}

).start();

class2.processDataFromInputStream(cbb.getInputStream());

单线程情形

// buffer all data in a circular buffer of infinite size

CircularByteBuffer cbb = new CircularByteBuffer(CircularByteBuffer.INFINITE_SIZE);

class1.putDataOnOutputStream(cbb.getOutputStream());

class2.processDataFromInputStream(cbb.getInputStream());

热门标签