pipestream1.java.bak

Java程序设计培训教程2

import java.io.*;
/**类PipeStream1使用管道输入流来获得有关信息*/
public class PipeStream1{
	public static void main(String args[]){
		try
		{
			PipedInputStream inObj = new PipedInputStream();
			PipeStream2 classObj = new PipeStream2();
			/*下面的语句将管道输入流和输出流连接起来*/
			inObj.connect(classObj.outObj);
			DataInputStream receiverObj = new DataInputStream(inObj);
			String readStr;
			classObj.writeS();
			readStr = receiverObj.readUTF();
			System.out.println(readStr);
			receiverObj.close();
			classObj.close();			
		}catch(IOException e){
			System.out.println("error:"+e);
			System.exit(0);
		}
	}
}
/**类PipeStream2使用管道输出流将有关信息写入输入流*/
class PipeStream2{
	PipedOutputStream outObj;
	DataOutputStream senderObj;
	/**构造方法生成管道输出流对象*/
	public PipeStream2()
	{
		outObj = new PipedOutputStream();
	}
	/**writeS()方法将一个字符串通过管道输出流发送*/
	public void writeS()
	{
		try
		{
			senderObj = new DataOutputStream(outObj);
			String writeStr = new String("Hi,glad to meet you!");
			senderObj.writeUTF(writeStr);
		}catch(IOException e){
			System.out.println("error:"+e);
		}
	}
	/**关闭管道输出流*/
	public void close()
	{
		try
		{
			senderObj.close();
		}catch(IOException e){
			System.exit(0);
		}
	}
}