`
shihuan830619
  • 浏览: 582803 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

将输出流OutputStream转化为输入流InputStream的方法

    博客分类:
  • J2SE
阅读更多
将输出流OutputStream转化为输入流InputStream的方法
一:
package test.io;   
import java.io.ByteArrayInputStream;   
import java.io.ByteArrayOutputStream;   
import java.io.IOException;   
/** 
* 用于把OutputStream 转化为 InputStream。 
* 适合于数据量不大,且内存足够全部容纳这些数据的情况。 
* 
*/  
public class Test1 {   
/** 
* @param args 
* @throws IOException 
*/  
public static void main(String[] args) throws IOException {
ByteArrayOutputStream out = new ByteArrayOutputStream();
byte[] bs = new byte[] { 1, 2, 3, 4, 5 };  
out.write(bs); 

ByteArrayInputStream in = new ByteArrayInputStream(out.toByteArray()) 
byte[] bs = new byte[1024];   
int len = in.read(bs);   
for (int i = 0; i < len; i++) {   
System.out.println(bs[i]);   
}   
}
} 

二:
package test.io;   
import java.io.IOException;   
import java.io.PipedInputStream;   
import java.io.PipedOutputStream;   
/** 
* 用于把OutputStream 转化为 InputStream。 适合于数据量大的情况,一个类专门负责产生数据,另一个类负责读取数据。 
*/  
public class Test2 {   
/** 
* @param args 
* @throws IOException 
*/  
public static void main(String[] args) throws IOException {   
// 使用Piped 的输入输出流
PipedInputStream in = new PipedInputStream();
final PipedOutputStream out = new PipedOutputStream(in);
// 启动线程,让数据产生者单独运行
new Thread(new Runnable() {
public void run() {
try {
byte[] bs = new byte[2];
for (int i = 0; i <= 100; i++) {
bs[0] = (byte) i;
bs[1] = (byte) (i + 1);
// 测试写入字节数组
out.write(bs);
out.flush();
// 等待0.1秒
Thread.sleep(100);
}
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
// 数据使用者处理数据
// 也可以使用线程来进行并行处理
byte[] bs = new byte[1024];
int len;
// 读取数据,并进行处理
try {
while ((len = in.read(bs)) != -1) {
for (int i = 0; i < len; i++) {
System.out.println(bs[i]);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

下面是关于 PipedOutputStream 的API介绍
传送输出流可以连接到传送输入流,以创建通信管道。传送输出流是管道的发送端。通常,数据由某个线程写入 PipedOutputStream 对象,并由其他线程从连接的 PipedInputStream 读取。不建议对这两个对象尝试使用单个线程,因为这样可能会死锁该线程。

下面是关于 PipedInputStream的API介绍
传送输入流应该连接到传送输出流;传送输入流会提供要写入传送输出流的所有数据字节。通常,数据由某个线程从 PipedInputStream 对象读取,并由其他线程将其写入到相应的 PipedOutputStream。不建议对这两个对象尝试使用单个线程,因为这样可能会死锁该线程。传送输入流包含一个缓冲区,可在缓冲区限定的范围内将读操作和写操作分离开。

三:
package test.io;
import java.io.IOException;   
import java.io.InputStream;   
import java.io.OutputStream;   
import com.Ostermiller.util.CircularByteBuffer;   
/** 
* 用于把OutputStream 转化为 InputStream。 
* <p> 
* 使用CircilarBuffer 辅助类 <br> 
* 下载地址为 <A href="http://ostermiller.org/utils/download.html 
http://ostermiller.org/utils/download.html<br> 
* 介绍地址为 http://ostermiller.org/utils/CircularBuffer.html 
* </p>
*/  
public class Test3 {   
/** 
* @param args 
* @throws IOException 
*/  
public static void main(String[] args) throws IOException {   
// 使用CircularByteBuffer  
final CircularByteBuffer cbb = new CircularByteBuffer();   
// 启动线程,让数据产生者单独运行  
new Thread(new Runnable() {   
public void run() {   
try {   
OutputStreamClass3.putDataOnOutputStream(cbb.getOutputStream());   
} catch (IOException e) {   
e.printStackTrace();   
}   
}   
}).start();   
// 数据使用者处理数据  
// 也可以使用线程来进行并行处理  
InputStreamClass3.processDataFromInputStream(cbb.getInputStream());   
}   
}   
class OutputStreamClass3 {   
public static void putDataOnOutputStream(OutputStream out) throws IOException {   
byte[] bs = new byte[2];   
for (int i = 0; i <= 100; i++) {   
bs[0] = (byte) i;   
bs[1] = (byte) (i + 1);   
// 测试写入字节数组  
out.write(bs);   
out.flush();   
try {   
// 等待0.1秒  
Thread.sleep(100);   
} catch (InterruptedException e) {   
e.printStackTrace();   
}   
}   
}   
}   
class InputStreamClass3 {   
public static void processDataFromInputStream(InputStream in) {   
byte[] bs = new byte[1024];   
int len;   
// 读取数据,并进行处理  
try {   
while ((len = in.read(bs)) != -1) {   
for (int i = 0; i < len; i++) {   
System.out.println(bs[i]);   
}   
}   
} catch (IOException e) {   
e.printStackTrace();   
}   
}   
}  

此方法使用了一个类处理,代码更简洁,可以很方便的在缓冲处理全部数据的小数据量情况和多线程处理大数据量的不同情况切换

package test.io;   
import java.io.IOException;   
import java.io.InputStream;   
import java.io.OutputStream;   
import com.Ostermiller.util.CircularByteBuffer;   
/** 
* 用于把OutputStream 转化为 InputStream。 
* <p> 
* 使用CircilarBuffer 辅助类 <br> 
* 下载地址为 <A href="http://ostermiller.org/utils/download.html 
* http://ostermiller.org/utils/download.html<br> 
* 介绍地址为 http://ostermiller.org/utils/CircularBuffer.html 
* </p>
*/  
public class Test4 {   
/** 
* @param args 
* @throws IOException 
*/  
public static void main(String[] args) throws IOException {   
// 缓冲所有数据的例子,不使用多线程  
CircularByteBuffer cbb = new CircularByteBuffer(CircularByteBuffer.INFINITE_SIZE);   
OutputStreamClass4.putDataOnOutputStream(cbb.getOutputStream());   
InputStreamClass4.processDataFromInputStream(cbb.getInputStream());   
}   
}   
class OutputStreamClass4 {   
public static void putDataOnOutputStream(OutputStream out) throws IOException {   
byte[] bs = new byte[] { 1, 2, 3, 4, 5 };   
out.write(bs);   
}   
}   
class InputStreamClass4 {   
public static void processDataFromInputStream(InputStream in) throws IOException {   
byte[] bs = new byte[1024];   
int len = in.read(bs);   
for (int i = 0; i < len; i++) {   
System.out.println(bs[i]);   
}   
}   
}
分享到:
评论

相关推荐

    Java基础核心+InputStream输入流+OutputStream输出流

    InputStream代表字节输入流,而OutputStream则表示字节输出流。在Java中,文件操作通常涉及到数据的读取和写入,这两个类及其子类就提供了这样的功能。 InputStream主要用于读取数据,常见的子类有FileInputStream...

    InputStream与OutputStream及File间互转

    一种常见的方法是先将`OutputStream`的数据写入内存中的`ByteArrayOutputStream`,然后再将其转换为`InputStream`: ```java ByteArrayOutputStream baos = new ByteArrayOutputStream(); OutputStream out = ...

    IO流文档InputStream / OutputStream

    IO流是一种基本的数据交换方式,在Java中,IO流是通过输入流(InputStream)和输出流(OutputStream)来实现的。输入流用于读取数据,而输出流用于写入数据。 InputStream是所有输入流的抽象超类,它提供了基本的...

    一个输入流写到多个输出流

    在IT行业中,输入流(InputStream)和输出流(OutputStream)是Java.IO库中的核心概念,它们用于处理数据的读取和写入。标题提到的"一个输入流写到多个输出流"是一个常见的需求,特别是在并发编程和数据传输场景中。...

    输入流和输出流

    输入流和输出流 流是程序和外界进行数据交换的通道 分为输入流(InputStream)和输出流(OutputStream)。程序通过输入流从数据源读取数据,通过输出流向目的地写数据。

    java 输入输出流

    2. **字符流**:字符流处理Unicode字符数据,分为字符输入流(Reader)和字符输出流(Writer)。Reader的基类是`java.io.Reader`,Writer的基类是`java.io.Writer`。比如,`FileReader`用于读取字符文件,`...

    Java学习资料-输入输出流

    字节流分为输入流(InputStream)和输出流(OutputStream)。InputStream是所有字节输入流的基类,而OutputStream是所有字节输出流的基类。 - **字符流**:专为处理文本数据设计,基于Unicode编码,每个字符为两个...

    通过jsoup,输入流InputStream爬取图片PaQuPic.rar,有意者入

    6. **处理输入流和输出流**:在处理`InputStream`和`OutputStream`时,确保它们都被正确关闭,避免资源泄漏。这里使用了Java 7的try-with-resources语句,它会在块结束时自动关闭资源。 7. **处理PaQuPic.rar**:...

    java输入输出流.ppt

    - InputStream是所有字节输入流的基类,例如: - ByteArrayInputStream:从字节数组中读取数据。 - FileInputStream:从文件中读取字节数据。 - FilterInputStream和BufferedInputStream:提供缓冲和过滤功能,...

    JAVA输入流和输出流

    在Java编程语言中,输入流(InputStream)和输出流(OutputStream)是I/O操作的核心概念,它们构成了Java I/O框架的基础。输入流用于从数据源读取数据,而输出流则用于向目的地写入数据。这两类流为处理各种类型的...

    java输入输出流的简单例子

    Java的输入输出流分为字节流和字符流两大类,每类又分别有输入流和输出流四种类型,即InputStream、OutputStream、Reader和Writer。下面我们将深入探讨这些概念,并通过一个简单的例子来说明其使用方法。 字节流...

    java中的各种输入流与输出流

    以上就是Java中输入流与输出流的基本概念、分类及使用方法,它们是进行数据读写操作的核心工具。在实际编程中,根据不同的需求选择合适的流类型,并合理利用缓冲、转换和多线程技术,能够有效地提高程序的性能和可...

    java的输入输出流

    InputStream类是所有字节输入流的基类,提供了诸如read()和skip()等基本方法。例如,FileInputStream类是用于从文件读取字节的输入流,可以通过文件路径、File对象或FileDescriptor对象进行初始化。而...

    文件上传/下载使用输入输出流操作文件

    分别是所有输入流和输出流的基类,它们定义了基本的读写操作,如`read()`和`write()`方法。 - **FileInputStream** 和 **FileOutputStream**: 是与文件交互的输入流和输出流,可以直接读写文件。 - **...

    java中的标准输入输出流

    为了能够更高效地处理标准输入流,通常需要将其包装为更高层次的流。例如,可以使用`InputStreamReader`将`System.in`转换为`Reader`类型,然后再进一步包装为`BufferedReader`,以便于逐行读取输入数据。 ```java ...

    java输入输出流,电子课件

    Java中,所有的输入流都继承自InputStream或Reader,所有输出流都继承自OutputStream或Writer。例如, FileInputStream 和 FileOutputStream 分别用于读写文件的字节流,而 FileReader 和 FileWriter 则用于读写文件...

    java输入输出流与文件处理

    以输入流为例,首先需要创建一个与数据源相关的流对象,接着通过调用该对象的读取方法读取数据,最后调用`close()`方法关闭流以释放资源。字节流适用于处理二进制数据,而字符流更擅长处理文本数据,两者的区别在于...

    Java_输入输出流及文件读写详解

    输入流用于从数据源(如文件、网络连接)读取数据,输出流则用于将数据写入目标(如文件、网络连接)。Java中,这两个概念被进一步细分为字节流和字符流。 1. 字节流: - 字节输入流(Byte Input Stream)的基类是...

    Java中几个文件输入流和文件输出流的研究.pdf

    1. 构造方法:public BufferedInputStream(InputStream in):创建一个缓冲输入流,wrap autour d'un 输入流 in。 2. 构造方法:public BufferedOutputStream(OutputStream out):创建一个缓冲输出流,wrap autour d'...

Global site tag (gtag.js) - Google Analytics