[零基础学JAVA]Java SE应用部分-29.Java IO操作（03）-阿里云开发者社区

[零基础学JAVA]Java SE应用部分-29.Java IO操作（03）

2017-12-09 1256

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介：

上季内容回顾：

字节流：InputStream、OutputStream
字符流：Reader、Writer

上季练习题：

既然是文件的拷贝，肯定要使用字节流，所以建立一个字节的输入流再建立一个字节的输出流，边读边写。

看下效果：

IO操作就是研究五个类一个接口
· File类
· OutputStream、InputStream
· Reader、Writer
· 对象序列化

管道流

了解：管道流是管两个线程间通讯使的。

public void connect(PipedOutputStream src) throws IOException

把输出与输入连接在一起。

import java.io.*;
//设置两个线程，一个发送另一个接收
class Send implements Runnable{
         private PipedOutputStream out = null;
         //在构造方法中实例化此对象
         public Send(){
                 this.out = new PipedOutputStream();
        }
         public void run(){
                 //启动线程，启动线程时直接发送
                String str = "Hello World~~~";
                 try{
                         this.out.write(str.getBytes());
                } catch (Exception e){}
        }
         //必须把管道输出流返回去
         public PipedOutputStream getOut(){
                 return this.out;
        }
}
class Receive implements Runnable{
         private PipedInputStream input = null;
         public Receive(){
                 this.input = new PipedInputStream();
        }
         public void run(){
                 //启动线程，接收内容
                 byte b[] = new byte[1024];
                 int len = 0;
                 try{
                        len = this.input.read(b);
                         this.input.close();
                        System.out.println( new String(b,0,len));
                } catch (Exception e){}
        }
         public PipedInputStream getInput(){
                 return this.input;
        }
}
public class IODemo01{
         public static void main(String args[]){
                Send s = new Send();
                Receive r = new Receive();
                 //要把输出连接到输入上去哈~
                 try{
                        r.getInput().connect(s.getOut());
                } catch (Exception e){}
                 new Thread(s).start();
                 new Thread(r).start();
        }
}

看下效果：