Java IO与NIO技术体系分析

2017-08-01  本文已影响0人  东升的思考

java.io包中最为核心的一个概念是流(Stream),面向流的编程。流分为两种输入流和输出流,Java中的io流不可能既是输入流,又是输出流。同时,IntputStream和OutputStream都是抽象类, Java中是单继承方式,所以也就不可能出现同时是输入和输出的流。

java.nio中拥有3个核心的概念:Selector、Channel与Buffer。在java.nio中,我们是面向块(block)或者缓冲区(buffer)编程的。buffer本身其实就是一块内存,底层实现上实际是个数组,数据的读、写都是通过buffer来实现的。

如下图所示进行理解,有一个Thread线程,这个线程对应一个Selector,Selector下面有三个Channel,每个Channel下对应着一个Buffer。 一个线程可以在三个Channel通道上来回的切换,通过事件来判断某一时刻在哪一个Channel上执行,因此,事件也是个很重要的概念。

image.png

将数据从Channel读到buffer中,数据已进入内存中,程序中切换写模式到读模式后(通过flip方法实现的),从buffer中将数据读取出来。绝对不会出现直接向Channel写入数据的情况,或者直接从Channel读取数据的情况。
Channel指的是可以向其中写入数据或者从中读取数据的对象,我们可以将nio中的Channel近似理解为io中的Stream。

除了数组之外,Buffer还提供了对数据的结构化访问方式,并且可以追踪到数据的读、写过程。
Java中的7种原生数据类型(不包括boolean类型的buffer)都有各自的对应的Buffer类型,比如IntBuffer、LongBuffer、ByteBuffer以及CharBuffer等等。

与Stream不同的是,Channel是双向的,一个流只可能是IntputStream或者OutputStream,Channel打开后则可以进行读、写或者读写。

由于Channel是双向的,因此,它能更好的反映出底层操作系统的真实情况。
比如说在linux系统中,底层操作系统的通道就是双向的。

好了,上面是一些理论,下面是3个实际的例子进一步结合理论加深理解。

1)随机生成10个数字,然后写入IntBuffer中,最终再从IntBuffer读取并输出。

public class NioTest1 {
    public static void main(String[] args) {
        IntBuffer intbuffer = IntBuffer.allocate(10);

        for (int i =0 ;i < intbuffer.capacity(); i++) {
            int randomNum = new java.security.SecureRandom().nextInt(20);
            intbuffer.put(randomNum);
        }

        intbuffer.flip();  // 切换为读模式

        while (intbuffer.hasRemaining()) {
            System.out.println(intbuffer.get());
        }
    }
}

2)从文件读取内容到Buffer中,然后从Buffer中读取数据输出。

public class NioTest2 {

    public static void main(String[] args) throws Exception {
       try( FileInputStream in = new FileInputStream("niotext2.txt");) {
           FileChannel fileChannel = in.getChannel();

           ByteBuffer byteBuffer = ByteBuffer.allocate(512);
           fileChannel.read(byteBuffer); // 写入byteBuffer

           byteBuffer.flip(); // 切换为读模式

           StringBuffer str = new StringBuffer();
           while (byteBuffer.hasRemaining()) {
               byte b = byteBuffer.get();
               str.append((char)b);
           }
           System.out.println(str.toString());
       }
    }
}

3)将字符数据写入ByteBuffer中,在从ByteBuffer读取写入到文件中。

public class NioTest3 {

    public static void main(String[] args) throws Exception {
        try (FileOutputStream fileOutputStream = new FileOutputStream("niotest3.txt");) {
            FileChannel fileChannel = fileOutputStream.getChannel();

            ByteBuffer byteBuffer = ByteBuffer.allocate(512);

            String str = "hello world, welcom!";
            for (int i =0; i< str.length(); i++) {
                char c = str.charAt(i);
                byteBuffer.put((byte) c);
            }

            byteBuffer.flip(); // 切换为写模式

            fileChannel.write(byteBuffer);
        }
    }
}
上一篇下一篇

猜你喜欢

热点阅读