Java技巧使用管道数据流传送数据
2008-05-01 06:01
302 查看
Java I/O系统是建立在数据流概念之上的,在UNIX操作系统中有一个类似的概念很流行,那就是管道,它具有将一个程序的输出当作另一个程序的输入的能力。
Java为这种管道概念提供了PipedInputStream和PipedOutputStream类。将这两者结合在一起,它们允许一个Java组件输出数据到输出流,而另一个组件将这个输出流当作输入流来读取。
举个例子可以说明,比如一个用来记录应用程序日志信息的组件和一个用来显示流数据动态报表的组件。通过给日志记录组件提供PipedOutputStream,给报表组件提供相应的PipedInputStream,这两个组件就不用知道对方的情况而可以相互通信。
最简单的情况下,代码段如下所示:
importJava.io.*;
public class Foo {
static public void main(String[] args) throwsIOException {
PipedOutputStream pout = newPipedOutputStream();
PipedInputStream= new PipedInputStream(pout);
for(int i=0; i < 100; i++) {
pout.write((byte)i );
}
pout.close();
int j=0;
while( (j = pin.read()) != -1)
{
System.err.println(j);
}
pin.close();
}
}
上面的代码中,一定要记得调用close()以关闭输出流"pout",否则第二轮循环永远也不会结束。
这个粗泛的例子并不是正常的可用的代码。随着第一轮循环数量越来越大,PipedOutputStream中的缓冲将会用尽,从而出现问题,比如它在等待某些程序从流里面删除数据时会导致线程死锁。
这就是为什么管道流的Javadoc中声明了PipedInputStream和PipedOutputStream必须用在多线程环境里面的原因。
Java为这种管道概念提供了PipedInputStream和PipedOutputStream类。将这两者结合在一起,它们允许一个Java组件输出数据到输出流,而另一个组件将这个输出流当作输入流来读取。
举个例子可以说明,比如一个用来记录应用程序日志信息的组件和一个用来显示流数据动态报表的组件。通过给日志记录组件提供PipedOutputStream,给报表组件提供相应的PipedInputStream,这两个组件就不用知道对方的情况而可以相互通信。
最简单的情况下,代码段如下所示:
importJava.io.*;
public class Foo {
static public void main(String[] args) throwsIOException {
PipedOutputStream pout = newPipedOutputStream();
PipedInputStream= new PipedInputStream(pout);
for(int i=0; i < 100; i++) {
pout.write((byte)i );
}
pout.close();
int j=0;
while( (j = pin.read()) != -1)
{
System.err.println(j);
}
pin.close();
}
}
上面的代码中,一定要记得调用close()以关闭输出流"pout",否则第二轮循环永远也不会结束。
这个粗泛的例子并不是正常的可用的代码。随着第一轮循环数量越来越大,PipedOutputStream中的缓冲将会用尽,从而出现问题,比如它在等待某些程序从流里面删除数据时会导致线程死锁。
这就是为什么管道流的Javadoc中声明了PipedInputStream和PipedOutputStream必须用在多线程环境里面的原因。
相关文章推荐
- 使用管道数据流传送数据
- 讲解在java环境下使用jQuery进行JSON数据传送的交互过程
- 加强eclipse的使用技巧。可变参数。基本数据类型自动装箱和拆箱。枚举。反射。数组反射的应用。ArrayList和HashSet。JavaBean
- Java核心数据结构(List,Map,Set)使用技巧与优化
- 在Struts中使用JavaBean和List(多行数据)类型属性-JSP教程,Java技巧及代码
- 使用SpringMVC进行数据的传送,数据来自mysql数据库 (1)没有使用hibernate
- 日历控件Calendar使用技巧--根据数据库数据控制日期背景显示颜色
- JAVA中使用JSON进行数据传递
- [原]从管道传送数据到ffmpeg进行视频编码
- Java 使用udp协议发送数据
- Java使用JDBC连接mysql数据库并封装数据
- OpenJDK源码研究笔记(五)-缓存Integer等类型的频繁使用的数据和对象,大幅度提升性能(一道经典的Java笔试题)
- JAVA MyBatis使用技巧收集
- Java基础-结合框架6 使用集合的技巧
- java使用多线程进行分页数据采集
- MongoDB最简单的入门教程之三 使用Java代码往MongoDB里插入数据
- (果粉必备)iCloud备份和恢复数据使用技巧
- Java中使用无符号基本数据类型
- Java的Struts2框架配合Ext JS处理JSON数据的使用示例