摘要：是什么就不在此文展開，這篇主要來介紹下我們要怎樣通過來構建一個服務客戶端程序的。的通信完全依賴與，數據的寫入和讀取都是通過從中寫入讀取。和上的調用一樣的功能，監聽已經注冊在上面的文件描述符，監聽上的事件。

NIO是什么就不在此文展開，這篇主要來介紹下我們要怎樣通過java NIO來構建一個服務客戶端程序的。

NIO建立一個服務端和客戶端程序主要涉及的知識點有：

channel

selector

buffer

如果通過C/C++寫過通信程序的應該知道都是通過linux提供的系統調用來完成，java NIO的實現思想上沒有什么變化只是在實現方式上換了一種新的概念，并提供了更友好的開發模式供開發人員更加簡便快捷的來實現自己想要的功能。

channel：NIO的通信完全依賴與channel，數據的寫入和讀取都是通過channel從buffer中寫入/讀取。

selector：和linux上的select調用一樣的功能，監聽已經注冊在上面的socket文件描述符，java NIO監聽channel上的事件。主要有：OP_CONNECT（）、OP_ACCEPT、OP_READ、OP_WRITE。

buffer主要是從channel中讀出數據或者寫入數據到channel。

public class NioServer {

    public static void main(String[] args) {
        try {
            // 建立一個serversocketchannel,用于監聽是否有連接到來
            ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
            // 設置為非阻塞模式
            serverSocketChannel.configureBlocking(false);
            // 綁定監聽的地址
            serverSocketChannel.bind(new InetSocketAddress(8080));
            // 獲取一個selector
            Selector selector = Selector.open();
            // 將channel注冊到selector中,并且這個channel關心的是accept事件
            serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

            while(true) {
                int readySize = selector.select();
                if(readySize == 0) {
                    continue;
                }
                // 獲取有事件到來的selectKeys
                Set selectionKeys = selector.selectedKeys();
                // 處理到來的事件
                for(Iterator iter = selectionKeys.iterator(); iter.hasNext(); ) {
                    SelectionKey selectionKey = iter.next();
                    // 要將已經被處理的selectionKey刪除掉
                    iter.remove();
                    if(selectionKey.isAcceptable()) {
                        System.out.println("acceptable");
                        ServerSocketChannel listenChannel = (ServerSocketChannel) selectionKey.channel();
                        /* 獲取連接進來的channel */
                        SocketChannel socketChannel = listenChannel.accept();
                        socketChannel.configureBlocking(false);
                        socketChannel.write(ByteBuffer.wrap(new String("java NIO").getBytes()));
                        socketChannel.register(selector, SelectionKey.OP_READ);
                    } else if(selectionKey.isReadable()) {
                        SocketChannel socketChannel = (SocketChannel) selectionKey.channel();
                        ByteBuffer byteBuffer = ByteBuffer.allocate(100);
                        int readSize = socketChannel.read(byteBuffer);
                        /* 相應的channel連接斷開了將其關閉掉 */
                        if(readSize == -1) {
                            socketChannel.close();
                            selectionKey.cancel();
                            continue;
                        }
                        /* 將客戶端寫入的數據顯示出來 */
                        byte[] bytes = byteBuffer.array();
                        String message = new String(bytes).trim();
                        System.out.println(message);
                    }
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }

    }
}

public class NioClient {

    public static void main(String[] args) {
        SocketChannel socketChannel = null;
        try {
            socketChannel = SocketChannel.open();
            socketChannel.configureBlocking(false);
            // 發起連接請求
            socketChannel.connect(new InetSocketAddress("127.0.0.1", 8080));
            Selector selector = Selector.open();
            socketChannel.register(selector, SelectionKey.OP_CONNECT);
            while (true) {
                int readySize = selector.select();
                if(readySize == 0) {
                    continue;
                }
                Set selectionKeys =  selector.selectedKeys();
                for(SelectionKey selectionKey : selectionKeys) {
                    SocketChannel clientChannel = (SocketChannel)selectionKey.channel();
                    if(selectionKey.isConnectable()) {
                        /* 連接還沒建立完全,等待連接建立完成 */
                        if(clientChannel.isConnectionPending()) {
                            clientChannel.finishConnect();
                        }
                        clientChannel.register(selector, SelectionKey.OP_READ);
                    } else if (selectionKey.isReadable()) {
                        System.out.println("readable");
                        ByteBuffer byteBuffer = ByteBuffer.allocate(100);
                        System.out.println(clientChannel.read(byteBuffer));
                        byte[] bytes = byteBuffer.array();
                        String message = new String(bytes).trim();
                        System.out.println(message);
                    }
                    selectionKeys.remove(selectionKey);
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }

    }
}

NIO相關的概念可以點這里