摘要：是一個用來替代標(biāo)準(zhǔn)的新型數(shù)據(jù)傳遞方式，像現(xiàn)在分布式架構(gòu)中會經(jīng)常存在他的身影。這個方法會一直阻塞到某個注冊的通道有事件就緒。保持不變，仍然表示能從中讀取多少個元素等與通過調(diào)用方法，可以標(biāo)記中的一個特定。

Java NIO是一個用來替代標(biāo)準(zhǔn)Java IO API的新型數(shù)據(jù)傳遞方式，像現(xiàn)在分布式架構(gòu)中會經(jīng)常存在他的身影。其比傳統(tǒng)的IO更加高效，非阻塞，異步，雙向

Java NIO的主要構(gòu)成核心就是Buffer、Channel和Selector這三個

對于Channel我想要提醒的是，Channel中的數(shù)據(jù)總是要先讀到一個Buffer，或者總是要從一個Buffer中寫入

使用Selector，得向Selector注冊Channel，然后調(diào)用它的select()方法。這個方法會一直阻塞到某個注冊的通道有事件就緒。一旦這個方法返回，線程就可以處理這些事件

所有的 IO 在NIO 中都從一個Channel 開始。Channel 有點象流

FileChannel:從文件中讀寫數(shù)據(jù)

DatagramChannel:通過UDP讀寫網(wǎng)絡(luò)中的數(shù)據(jù)

SocketChannel:通過TCP讀寫網(wǎng)絡(luò)中的數(shù)據(jù)

ServerSocketChannel:監(jiān)聽新進(jìn)來的TCP連接，像Web服務(wù)器那樣。對每一個新進(jìn)來的連接都會創(chuàng)建一個SocketChannel

分散（scatter）從Channel中讀取是指在讀操作時將讀取的數(shù)據(jù)寫入多個buffer中。因此，Channel將從Channel中讀取的數(shù)據(jù)“分散（scatter）”到多個Buffer中

聚集（gather）寫入Channel是指在寫操作時將多個buffer的數(shù)據(jù)寫入同一個Channel，因此，Channel 將多個Buffer中的數(shù)據(jù)“聚集（gather）”后發(fā)送到Channel

通過這樣的方式可以方便數(shù)據(jù)的讀取，當(dāng)你想要獲取整個數(shù)據(jù)的一部分的時候，通過這種方式可以很快的獲取數(shù)據(jù)

ByteBuffer header = ByteBuffer.allocate(128);
ByteBuffer body   = ByteBuffer.allocate(1024);
ByteBuffer[] bufferArray = { header, body };
channel.read(bufferArray);

read()方法按照buffer在數(shù)組中的順序?qū)腸hannel中讀取的數(shù)據(jù)寫入到buffer，當(dāng)一個buffer被寫滿后，channel緊接著向另一個buffer中寫

實現(xiàn)兩個Channel之間相互連接，數(shù)據(jù)傳遞

    public static void trainforNio() {
        RandomAccessFile fromFile=null;
        RandomAccessFile toFile=null;
        try {

            fromFile = new RandomAccessFile("src/nio.txt", "rw");
            // channel獲取數(shù)據(jù)
            FileChannel fromChannel = fromFile.getChannel();
            toFile = new RandomAccessFile("src/toFile.txt", "rw");
            FileChannel toChannel = toFile.getChannel();
            System.out.println(toChannel.size());
              //position處開始向目標(biāo)文件寫入數(shù)據(jù),這里是toChannel
            long position = toChannel.size();
            long count = fromChannel.size();
            toChannel.transferFrom(fromChannel, position, count);
            System.out.println(toChannel.size());
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (fromFile != null) {
                    fromFile.close();
                }
                if (toFile != null) {
                    toFile.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

transferFrom、transferTo作用是一樣的，只是一個是tochannal調(diào)用，一個是fromchannnal調(diào)用

在實際的運用中可能存在源通道的剩余空間小于 count 個字節(jié)，則所傳輸?shù)淖止?jié)數(shù)要小于請求的字節(jié)數(shù)

在SoketChannel的實現(xiàn)中，SocketChannel只會傳輸此刻準(zhǔn)備好的數(shù)據(jù)（可能不足count字節(jié)）。因此，SocketChannel可能不會將請求的所有數(shù)據(jù)(count個字節(jié))全部傳輸?shù)紽ileChannel中

看官一定要仔細(xì)看我栗子中的注釋

Buffer是一個緩存區(qū)，其會將Channel中的數(shù)據(jù)存儲起來

ByteBuffer

CharBuffer

DoubleBuffer

FloatBuffer

IntBuffer

LongBuffer

ShortBuffer

MappedByteBuffer

在講解該主題之前，首先要明白讀模式和寫模式，無論是Channel還是Buffer都存在這兩種模式，要理解這兩種模式，第一步要明確主題是哪一個，是Channel還是Buffer。舉個栗子，主角是Channel，讀模式的含義就是從Buffer中獲取數(shù)據(jù)，寫模式就是將數(shù)據(jù)寫入Buffer，對于Buffer則是相反。搞清楚這一點，理解下面的就要相對清楚一點

capacity:作為一個內(nèi)存塊，其就代表了當(dāng)前Buffer能最多暫存多少數(shù)據(jù)量，存儲的數(shù)據(jù)類型則是根據(jù)上面的Buffer對象類型，一旦Buffer滿了，需要將其清空（通過讀數(shù)據(jù)或者清除數(shù)據(jù)）才能繼續(xù)寫數(shù)據(jù)往里寫數(shù)據(jù)

position:代表當(dāng)前數(shù)據(jù)讀或?qū)懱幱谀莻€位置。讀模式：被重置從0開始，最大值可能為capacity-1或者limit-1，寫模式：被重置從0開始，最大值為limit-1

limit:最多能往Buffer里寫多少數(shù)據(jù)，limit大小跟數(shù)據(jù)量大小和capacity有關(guān)，讀模式：數(shù)據(jù)量>capacity時，limit=capacity，數(shù)據(jù)量=capacity時，limit=capacity，數(shù)據(jù)量

import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

public class Method {
    public static void nio() {
        RandomAccessFile aFile = null;
        try {

            aFile = new RandomAccessFile("src/nio.txt", "rw");
            // channel獲取數(shù)據(jù)
            FileChannel fileChannel = aFile.getChannel();
            // 初始化Buffer，設(shè)定Buffer每次可以存儲數(shù)據(jù)量
            // 創(chuàng)建的Buffer是1024byte的，如果實際數(shù)據(jù)本身就小于1024，那么limit就是實際數(shù)據(jù)大小
            ByteBuffer buf = ByteBuffer.allocate(1024);
            // channel中的數(shù)據(jù)寫入Buffer
            int bytesRead = fileChannel.read(buf);
            System.out.println(bytesRead);

            while (bytesRead != -1) {
                // Buffer切換為讀取模式
                buf.flip();
                // 讀取數(shù)據(jù)
                while (buf.hasRemaining()) {
                    System.out.print((char) buf.get());
                }
                // 清空Buffer區(qū)
                buf.compact();
                // 繼續(xù)將數(shù)據(jù)寫入緩存區(qū)
                bytesRead = fileChannel.read(buf);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (aFile != null) {
                    aFile.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) {
        Method.nio();
    

寫入數(shù)據(jù)到Buffer(fileChannel.read(buf))

調(diào)用flip()方法(buf.flip())

從Buffer中讀取數(shù)據(jù)(buf.get())

調(diào)用clear()方法或者compact()方法(buf.compact())

Buffer方法

flip():將Buffer讀模式切換到寫模式，并且將position制為0

clear():清空整個緩沖區(qū)

compact():只會清除已經(jīng)讀過的數(shù)據(jù)。任何未讀的數(shù)據(jù)都被移到緩沖區(qū)的起始處，新寫入的數(shù)據(jù)將放到緩沖區(qū)未讀數(shù)據(jù)的后面

allocate(1024):初始化Buffer，設(shè)定的值就決定capacity值的大小

rewind():將position設(shè)回0，所以你可以重讀Buffer中的所有數(shù)據(jù)。limit保持不變，仍然表示能從Buffer中讀取多少個元素（byte、char等）

mark()與reset():通過調(diào)用Buffer.mark()方法，可以標(biāo)記Buffer中的一個特定position。之后可以通過調(diào)用Buffer.reset()方法恢復(fù)到這個position

equals():當(dāng)滿足下面三個條件時，兩個Buffer才是相等

有相同的類型（byte、char、int等）

Buffer中剩余的byte、char等的個數(shù)相等

Buffer中所有剩余的byte、char等都相同

只比較的是剩余的數(shù)據(jù)

compareTo():滿足下列條件，則認(rèn)為一個Buffer“小于”另一個Buffer

第一個不相等的元素小于另一個Buffer中對應(yīng)的元素

所有元素都相等，但第一個Buffer比另一個先耗盡(第一個Buffer的元素個數(shù)比另一個少)

Selector允許單線程處理多個 Channel。如果你的應(yīng)用打開了多個連接（通道），但每個連接的流量都很低，使用Selector就會很方便

關(guān)于selector的知識內(nèi)容比較多了，我打算在下一期進(jìn)行詳細(xì)說明

更多內(nèi)容可以關(guān)注微信公眾號，或者訪問AppZone網(wǎng)站