使用管道流传输数据

import java.io.IOException;
import java.io.PipedOutputStream;

public class Sender extends Thread{ //发送信息（写）
//创建管道输出成员变量
    private PipedOutputStream out=new PipedOutputStream();
   
    public PipedOutputStream getOutputStream(){ //获得输出管道
        return out;
    }
    public void run(){
        String s=new String("Hello,receiver,how are you!");
        try{
            out.write(s.getBytes()); //write() 只能写字节
            out.close();
        }
        catch(IOException e){
        System.out.println(e.getMessage());
        }
    }
}



import java.io.IOException;
import java.io.PipedInputStream;

//接收信息（读）
public class Receiver extends Thread {
// 创建管道输入成员变量
private PipedInputStream in = new PipedInputStream();

public PipedInputStream getInputStream() { // 获得输入管道
return in;
}

public void run() {
String s = null;
byte[] buf = new byte[1024];
try {
int len = in.read(buf);
s = new String(buf, 0, len);
System.out
.println("the following message comes from sender:\n" + s);
in.close();
} catch (IOException e) {
System.out.println(e.getMessage());
}
}
}




import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class TestPipe {
public static void main(String args[]){
        try{
        Sender t1=new Sender();
            Receiver t2=new Receiver();
            PipedOutputStream out = t1.getOutputStream();
            PipedInputStream in = t2.getInputStream();
            out.connect(in); //连接两个管道
            //in.connect(out);
            t1.start();
            t2.start();
        }
        catch(IOException e){
        System.out.println(e.getMessage());
        }
    }
}