Java IO 流（二）

时间 2019-11-29 标签 java

InputStream和OutputStream的对应关系以下：java

这里针对每个类，分别作一些实例和介绍：
一、InputStream、OutputSTream设计模式

InputStream\OutSTream是抽象类，定义了关于字节流操做的最基本的方法
InputStream: available() / read() / mark() /reset() / skip() /  / close()
OutputStream: close() / flush() / write()
对于InputStream  mark()标记当前流的位置，reset()返回到上次标记的流的位置，skip(int n)跳过n个字节markSupported()

二、ByteArrayInputStream、ByteArrayOutputStream数组

把Byte转换为InputStream

//构造方法，其余方法与InputStream相同
ByteArrayInputStream(byte[] buf)
ByteArrayInputStream(byte[] buf, int offset, int length)

ByteArrayInputStream bais = new ByteArrayInputStream(ArrayLetters);

/ 从字节流中读取5个字节
        for (int i=0; i<LEN; i++) {
            if (bais.available() >= 0) {
                int tmp = bais.read();
                System.out.printf("%d : 0x%s\n", i, Integer.toHexString(tmp));
            }
        }

ByteArrayOutputStream中是有一个能够随着输入增加的byte数组缓冲区的，能够用来方便的缓存数据：
主要的用到的方法是可用
经过toByteArray()获得内部的Byte数组，
经过toString将内部数据转为String
writeTo(OutputStream out) 将内部的byte数组写入到另一个输出流中
缓存

            BufferedInputStream bis=new BufferedInputStream(new FileInputStream(f));
            ByteArrayOutputStream byteArrayOutputStream=new          
            ByteArrayOutputStream();
            int c;
            while((c=bis.read())!=-1){
                byteArrayOutputStream.write(c);
            }
            System.out.println(byteArrayOutputStream);
            byte[] b=byteArrayOutputStream.toByteArray();
            System.out.println(new String(b));

三、FileInputStream和FileOutputStream
链接地址数据结构

FileInputStream 和FileOutputStream适用于操做于任何形式的文件（由于是以字节为向导），若是想要操做文本文件，采用FileInputReader和FileOutputWriter效率更高多线程

FileChannel getChannel() //用于在java nio中的Channel
FileDescriptor getFD() // 返回该文件的文件描述符同时文件输入\输出流均可以经过FD进行构造app

其余的方法与InputStream以及OutputStream的方法同样ide

FileDescriptor是文件描述符
就是用来描述一个文件的。
能够用来做为在多个流之间的桥梁（文件的输入输出流均可以经过FD构造，也都能生成FD对象）
FileDescriptor中有三个常量in、out、err,分别是标准输入、输出、错误的句柄

四、ObjectInputStream和ObjectOutputStream
主要用于对象的序列化操做函数

点击这个连接地址

 Person p=new Person("lz",19);
        Person p1=new Person("lz1",191);
        try {
            FileOutputStream fo=new FileOutputStream("D:/ww");
            ObjectOutputStream oo=new ObjectOutputStream(fo);
            oo.writeObject(p);
            oo.writeObject(p1);
            oo.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        try {
            FileInputStream fi = new FileInputStream("D:/ww");
            ObjectInputStream oi = new ObjectInputStream(fi);
            Person p3=(Person) oi.readObject();
            Person p4=(Person) oi.readObject();
            System.out.println(p3.getName());
            System.out.println(p4.getName());
        }
        catch (IOException e){
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }

五、PipedInputStream和PipedOutputStream

链接地址

用于在多线程之间的单向的管道的通讯，使用connect方法把两个管道给关联起来

class Sender implements Runnable{
    PipedOutputStream pos=new PipedOutputStream();
    public void connect(PipedInputStream pipedInputStream) throws IOException {
        pos.connect(pipedInputStream);
    }
    @Override
    public void run() {
       StringBuffer sb=new StringBuffer("The Meaasge is:");
        for (int i = 0; i < 100; i++) {
            sb.append(i);
            try {
                pos.write(sb.toString().getBytes());
                Thread.sleep(500);
            } catch (IOException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
class Receiver implements Runnable{
    PipedInputStream pis=new PipedInputStream();
    public void Receiver(PipedOutputStream ops) throws IOException {
        pis.connect(ops);
    }
    @Override
    public void run() {
        while (true){
            int num= 0;
            try {
                if((num = pis.available())>0) {
                    byte b[] = new byte[num];
                    pis.read(b);
                    System.out.println(new String(b));
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}
public class _PipedStream {
    public static void main(String[] args) {
        Sender s=new Sender();
        Receiver r=new Receiver();
        try {
            s.connect(r.pis); //将两个流链接起来
        } catch (IOException e) {
            e.printStackTrace();
        }
        Thread t1=new Thread(s);
        Thread t2=new Thread(r);
        t1.start();
        t2.start();
    }
}

六、BufferedInputStream与BufferedOutputStream

BufferedInputStream是带缓冲区的输入流，默认缓冲区大小是8M，可以减小访问磁盘的次数，提升文件读取性能；BufferedOutputStream是带缓冲区的输出流，可以提升文件的写入效率。BufferedInputStream与BufferedOutputStream分别是FilterInputStream类和FilterOutputStream类的子类，实现了装饰设计模式。
构造方法是传入InputStream和OutPutStream，能够指定缓冲区的大小，默认的缓冲区的大小是8M

七、DataInputStream和DataOutputStram

实现了对于各类基本数据结构的读写的方法，也是装饰类

八、PushbackInputStream

提供了回退流的机制，能够将已经读出来的byte放回去，或者将指定的内容放到流中

PushbackInputStream(InputStream inputStream)
PushbackInputStream(InputStream inputStream,int numBytes)
 第二种形式建立的流对象具备一个长度为numBytes的回推缓存，从而容许将多个字节回推到输入流中。
void unread(int b)
void unread(byte[] buffer)
void unread(byte[] buffer,int offset,int numBytes)
第一种形式回推b的低字节，这会使得后续的read()调用会把这个字节再次读取出来。第二种形式回推buffer中的字节。第三种形式回推buffer中从offset开始的numBytes个字节。
当回推缓存已满时，若是试图回推字节，就会抛出IOException异常。

想象流是一个队列，每次都是从队列头读出流数据，回退流就是往头上在写回数据，注意写回数据的长度不能大于“回推缓存”，这个回推缓存实在回退流的构造函数中定义的

九、Sequenceinputstream

将两个流合并，要合并多个流能够经过指定Enumeration<InputStream>来处理

十、PrintStream

PrintStream 是打印输出流，可以方便地打印各类数据值表示形式。
System.out就是一个PrintStream实例，使用方法相似，需注意方法append()，向流的尾部追加内容。默认状况PrintStream是自动flush的
print()和println()都是将其中参数转换成字符串以后，再写入到输入流。