简介
PipedInputStream和PipedOutputStream是一对输入输出，这里需要明白的是，PipedOutPutStream和PipedInputStream必须相连，而且，前者的读取必须要等待后者的写入后才能够执行
除此之外，这两者要结合线程来使用
案例
用一个读者和写者，来模拟两者的写入读出
public class Writer implements Runnable{
PipedOutputStream pos=null;
Writer(PipedOutputStream pos)
{
this.pos=pos;
}
public void write() {
}
@Override
public void run() {
System.out.println("我要停3秒");
try {
Thread.sleep(3000);
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
String msg="写一条信息进去";
try {
pos.write(msg.getBytes());
pos.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public class Reader implements Runnable{
PipedInputStream pis=null;
Reader(PipedInputStream pis)
{
this.pis=pis;
}
@Override
public void run() {
StringBuilder sb=new StringBuilder();
int len=0;
byte[] b=new byte[1024];
try {
while((len=pis.read(b))!=-1)
{
sb.append(new String(b,0,len));
}
System.out.println(sb.toString());
pis.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public class IOMain {
public static void main(String[] args) throws Exception{
PipedTest();
}
public static void PipedTest() throws Exception{
PipedInputStream pis=null;
PipedOutputStream pos=null;
pis=new PipedInputStream();
pos=new PipedOutputStream(pis);
Thread t1=new Thread(new Writer(pos));
Thread t2=new Thread(new Reader(pis));
t1.start();
t2.start();
//pis.close();
//pos.close();
}
public static void sop(Object o)
{
System.out.println(o);
}
}
总结
这里别忘记给两者相连接，这一对输入输出流并没有什么难点，只是说需要结合线程来使用
