Asyncdb（三）：Java NIO

本文由 GodPan 发表在 ScalaCool 团队博客。

上篇说了最基础的五种IO模型，相信你们对IO相关的概念应该有了必定的了解，这篇文章主要讲讲基于多路复用IO的Java NIO。

背景

Java诞生至今，有好多种IO模型，从最先的Java IO到后来的Java NIO以及最新的Java AIO，每种IO模型都有它本身的特色，详情请看个人上篇文章Java IO初探，而其中的的Java NIO应用很是普遍，尤为是在高并发领域，好比咱们常见的Netty，Mina等框架，都是基于它实现的，相信你们都有所了解，下面让咱们来看看Java NIO的具体架构。

Java NIO架构

其实Java NIO模型相对来讲也仍是比较简单的，它的核心主要有三个，分别是：Selector、Channel和Buffer,咱们先来看看它们之间的关系：

它们之间的关系很清晰，一个线程对应着一个Selecter，一个Selecter对应着多个Channel，一个Channel对应着一个Buffer，固然这只是一般的作法，一个Channel也能够对应多个Selecter，一个Channel对应着多个Buffer。

Selecter

我的认为Selecter是Java NIO的最大特色，以前咱们说过，传统的Java IO在面对大量IO请求的时候有心无力，由于每一个维护每个IO请求都须要一个线程，这带来的问题就是，系统资源被极度消耗，吞吐量直线降低，引发系统相关问题，那么Java NIO是如何解决这个问题的呢？答案就是Selecter，简单来讲它对应着多路IO复用中的监管角色，它负责统一管理IO请求，监听相应的IO事件，并通知对应的线程进行处理，这种模式下就无需为每一个IO请求单独分配一个线程，另外也减小线程大量阻塞，资源利用率降低的状况，因此说Selecter是Java NIO的精髓，在Java中咱们能够这么写：

// 打开服务器套接字通道
ServerSocketChannel ssc = ServerSocketChannel.open();
// 服务器配置为非阻塞
ssc.configureBlocking(false);
// 进行服务的绑定
ssc.bind(new InetSocketAddress("localhost", 8001));

// 经过open()方法找到Selector
Selector selector = Selector.open();
// 注册到selector，等待链接
ssc.register(selector, SelectionKey.OP_ACCEPT);
...
复制代码

Channel

Channel本意是通道的意思，简单来讲，它在Java NIO中表现的就是一个数据通道，可是这个通道有一个特色，那就是它是双向的，也就是说，咱们能够从通道里接收数据，也能够向通道里写数据，不用像Java BIO那样，读数据和写数据须要不一样的数据通道，好比最多见的Inputstream和Outputstream，可是它们都是单向的，Channel做为一种全新的设计，它帮助系统以相对小的代价来保持IO请求数据传输的处理，可是它并不真正存放数据，它老是结合着缓存区（Buffer）一块儿使用，另外Channel主要有如下四种：

• FileChannel：读写文件时使用的通道
• DatagramChannel：传输UDP链接数据时的通道,与Java IO中的DatagramSocket对应
• SocketChannel：传输TCP链接数据时的通道，与Java IO中的Socket对应
• ServerSocketChannel: 监听套接词链接时的通道，与Java IO中的ServerSocket对应

固然其中最重要以及最经常使用的就是SocketChannel和ServerSocketChannel，也是Java NIO的精髓，ServerSocketChannel能够设置成非阻塞模式，而后结合Selecter就能够实现多路复用IO，使用一个线程管理多个Socket链接，具体使用能够参数上面的代码。

Buffer

顾名思义，Buffer的含义是缓冲区，它在Java NIO中的主要做用就是做为数据的缓冲区域，Buffer对应着某一个Channel，从Channel中读取数据或者向Channel中写数据，Buffer与数组很相似，可是它提供了更多的特性，方便咱们对Buffer中的数据进行操做，后面我也会主要分析它的三个属性capacity，position和limit，咱们先来看一下Buffer分配时的类别（这里不是指Buffer的具体数据类型）即Direct Buffer和Heap Buffer，那么为何要有这两种类别的Buffer呢？咱们先来看看它们的特性：

Direct Buffer：

• 直接分配在系统内存中；
• 不须要花费将数据库从内存拷贝到Java内存中的成本；
• 虽然Direct Buffer是直接分配中系统内存中的，但当它被重复利用时，只有真正须要数据的那一页数据会被装载到真是的内存中，其它的还存在在虚拟内存中，不会形成实际内存的资源浪费；
• 能够结合特定的机器码，一次能够有顺序的读取多字节单元；
• 由于直接分配在系统内存中，因此它不受Java GC管理，不会自动回收；
• 建立以及销毁的成本比较高；

Heap Buffer：

• 分配在Java Heap，受Java GC管理生命周期，不须要额外维护；
• 建立成本相对较低；

根据它们的特性，咱们能够大体总结出它们的适用场景：

若是这个Buffer能够重复利用，并且你也想多个字节操做，亦或者你对性能要求很高，能够选择使用Direct Buffer，但其编码相对来讲会比较复杂，须要注意的点也更多，反之则用Heap Buffer，Buffer的相应建立方法：

//建立Heap Buffer
ByteBuffer heapBuffer = ByteBuffer.allocate(1024);

//建立Direct Buffer
ByteBuffer directBuffer = ByteBuffer.allocateDirect(1024);
复制代码

下面咱们来看看它的三个属性：

• Capacity：顾名思义它的含义是容量，表明着Buffer的最大容量，与数组的Size很相似，初始化不可更改，除非你改变的Buffer的结构；
• Limit：顾名思义它的含义是界限，表明着Buffer的目前可以使用的最大限制，写模式下，通常Limit等于Capacity，读模式下须要你本身控制它的值结合position读取想要的数据；
• Position：顾名思义它的含义是位置，表明着Buffer目前操做的位置，通俗来讲，就是你下次对Buffer进行操做的起始位置；

接下来我会用一个图解的列子帮助你们理解,如今咱们假设有一个容量为10的Buffer，咱们先往里面写入必定字节的数据，而后再根据编码规则从其中读取咱们须要的数据：

1.初始Buffer：

ByteBuffer buffer = ByteBuffer.allocate(10);
复制代码

2.向Buffer中写入两个字节：

buffer.put("my".getBytes());
复制代码

3.再Buffer中写入四个字节：

buffer.put("blog".getBytes());
复制代码

4.如今咱们须要从Buffer中获取数据，首先咱们先将写模式转换为读模式：

buffer.flip();
复制代码

咱们来看看flip()方法到底作了什么事？

public final Buffer flip() {
    limit = position;
    position = 0;
    mark = -1;
    return this;
}
复制代码

从源码中能够看出，flip方法根据Buffer目前的相应属性来修改对应的属性，因此flip()方法以后，Buffer目前的状态：

5.接着咱们从Buffer中读取数据

从Buffer中读取数据有多种方式，好比get(),get(byte [])等，相关的具体方法使用能够参考Buffer的官方API文档，这里咱们用最简单的get()来获取数据:

byte a = buffer.get();
  byte b = buffer.get();
复制代码

此时Buffer的状态以下图所示：

咱们能够按照这种方式读取完咱们所需数据，最终调用clear()方法将Buffer置为初始状态。

总结

这篇文章主要讲解了Java NIO中重要的三个组成部分，在实际使用过程也是比较重要的，掌握它们之间的关系，可让你对Java NIO的整个架构更加熟悉，理解相对来讲也会更加深入，并分析了这种模式是如何与多路复用IO模型的映射，了解Java NIO在高并发场景下优点的缘由。