詳解Java非阻塞I/O模型之NIO技術相關知識內容

//初始化一個網絡地址，并綁定7000端口號
InetSocketAddress inetSocketAddress = new InetSocketAddress(7000);
//ServerSocketChannel.open() 方法實例化一個ServerSocketChannel對象
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
//serverSocketChannel綁定初始化的網絡地址，并開始監(jiān)聽
serverSocketChannel.socket().bind(inetSocketAddress);
//將這個通道設置為非阻塞的
serverSocketChannel.configureBlocking(false);

//得到一個Selector對象
Selector selector = Selector.open();
//在channel上注冊selector，并且告訴這個選擇器初始應該監(jiān)聽的事件，
//SelectionKey.OP_ACCEPT 為監(jiān)聽鏈接進入的事件，初始化并不監(jiān)聽數(shù)據(jù)讀取的事件
//SelectionKey.OP_READ 事件讀取事件，需要在有鏈接進入時，配合鏈接一起注冊
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

//循環(huán)等待客戶端鏈接
while(true){
     //等待1秒，1秒內沒有鏈接事件發(fā)生，直接返回
     if(selector.select(1000)==0){
         System.out.println("服務器等待了1秒，無連接進入");
         continue;
      }
      //有事件發(fā)生，拿到集合
      //selector.selectedKeys() 關注事件的集合
      //通過這個可以反向獲取通道
      Set<SelectionKey> selectionKeys = selector.selectedKeys();

      //遍歷集合，使用迭代器
      Iterator<SelectionKey> keyIterator = selectionKeys.iterator();
      while(keyIterator.hasNext()){
           //獲取事件key
           SelectionKey key = keyIterator.next();
           //根據(jù)key對應的通道發(fā)生的事件做相應的處理
           if(key.isAcceptable()){
               //如果是ACCEPT事件，客戶端鏈接
               //傳統(tǒng)的accept()是阻塞的，但是在NIO中，當key.isAcceptable()方法返回true的時候，這個鏈接就已經存在了，所以accept()會立刻執(zhí)行
               SocketChannel socketChannel = serverSocketChannel.accept();
               socketChannel.configureBlocking(false);
               //將當前的socketChannel注冊的selector,關注事件為READ，同時給Channel關聯(lián)一個Buffer
               SelectionKey register = socketChannel.register(selector, SelectionKey.OP_READ, ByteBuffer.allocate(128));

           }else if(key.isReadable()){
               //發(fā)生了READ事件
               //通過key反向獲取Channel
               SocketChannel channel = (SocketChannel)key.channel();
               //獲取到該channel關聯(lián)的buffer
               ByteBuffer buffer =(ByteBuffer) key.attachment();
               channel.read(buffer);
               System.out.println("From 客戶端 ："+new String(buffer.array()));

           }

           //手動在集合中移除當前的SelectionKey否則可能會出現(xiàn)重復操作
           keyIterator.remove();

       }


}