package cn.nio; 
 
import java.io.IOException; 
import java.net.InetSocketAddress; 
import java.nio.ByteBuffer; 
import java.nio.channels.SelectionKey; 
import java.nio.channels.Selector; 
import java.nio.channels.ServerSocketChannel; 
import java.nio.channels.SocketChannel; 
import java.util.Iterator; 
 
/** 
 * NIO服務(wù)端 
 * @author 小路 
 */ 
public class NIOServer { 
 //通道管理器 
 private Selector selector; 
 
 /** 
  * 獲得一個(gè)ServerSocket通道，并對(duì)該通道做一些初始化的工作 
  * @param port 綁定的端口號(hào) 
  * @throws IOException 
  */ 
 public void initServer(int port) throws IOException { 
  // 獲得一個(gè)ServerSocket通道 
  ServerSocketChannel serverChannel = ServerSocketChannel.open(); 
  // 設(shè)置通道為非阻塞 
  serverChannel.configureBlocking(false); 
  // 將該通道對(duì)應(yīng)的ServerSocket綁定到port端口 
  serverChannel.socket().bind(new InetSocketAddress(port)); 
  // 獲得一個(gè)通道管理器 
  this.selector = Selector.open(); 
  //將通道管理器和該通道綁定，并為該通道注冊(cè)SelectionKey.OP_ACCEPT事件,注冊(cè)該事件后， 
  //當(dāng)該事件到達(dá)時(shí)，selector.select()會(huì)返回，如果該事件沒(méi)到達(dá)selector.select()會(huì)一直阻塞。 
  serverChannel.register(selector, SelectionKey.OP_ACCEPT); 
 } 
 
 /** 
  * 采用輪詢的方式監(jiān)聽selector上是否有需要處理的事件，如果有，則進(jìn)行處理 
  * @throws IOException 
  */ 
 @SuppressWarnings("unchecked") 
 public void listen() throws IOException { 
  System.out.println("服務(wù)端啟動(dòng)成功！"); 
  // 輪詢?cè)L問(wèn)selector 
  while (true) { 
   //當(dāng)注冊(cè)的事件到達(dá)時(shí)，方法返回；否則,該方法會(huì)一直阻塞 
   selector.select(); 
   // 獲得selector中選中的項(xiàng)的迭代器，選中的項(xiàng)為注冊(cè)的事件 
   Iterator ite = this.selector.selectedKeys().iterator(); 
   while (ite.hasNext()) { 
    SelectionKey key = (SelectionKey) ite.next(); 
    // 刪除已選的key,以防重復(fù)處理 
    ite.remove(); 
    // 客戶端請(qǐng)求連接事件 
    if (key.isAcceptable()) { 
     ServerSocketChannel server = (ServerSocketChannel) key 
       .channel(); 
     // 獲得和客戶端連接的通道 
     SocketChannel channel = server.accept(); 
     // 設(shè)置成非阻塞 
     channel.configureBlocking(false); 
 
     //在這里可以給客戶端發(fā)送信息哦 
     channel.write(ByteBuffer.wrap(new String("向客戶端發(fā)送了一條信息").getBytes())); 
     //在和客戶端連接成功之后，為了可以接收到客戶端的信息，需要給通道設(shè)置讀的權(quán)限。 
     channel.register(this.selector, SelectionKey.OP_READ); 
      
     // 獲得了可讀的事件 
    } else if (key.isReadable()) { 
      read(key); 
    } 
 
   } 
 
  } 
 } 
 /** 
  * 處理讀取客戶端發(fā)來(lái)的信息 的事件 
  * @param key 
  * @throws IOException 
  */ 
 public void read(SelectionKey key) throws IOException{ 
  // 服務(wù)器可讀取消息:得到事件發(fā)生的Socket通道 
  SocketChannel channel = (SocketChannel) key.channel(); 
  // 創(chuàng)建讀取的緩沖區(qū) 
  ByteBuffer buffer = ByteBuffer.allocate(10); 
  channel.read(buffer); 
  byte[] data = buffer.array(); 
  String msg = new String(data).trim(); 
  System.out.println("服務(wù)端收到信息："+msg); 
  ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes()); 
  channel.write(outBuffer);// 將消息回送給客戶端 
 } 
  
 /** 
  * 啟動(dòng)服務(wù)端測(cè)試 
  * @throws IOException 
  */ 
 public static void main(String[] args) throws IOException { 
  NIOServer server = new NIOServer(); 
  server.initServer(8000); 
  server.listen(); 
 } 
 
} 
 
 

package cn.nio; 
 
import java.io.IOException; 
import java.net.InetSocketAddress; 
import java.nio.ByteBuffer; 
import java.nio.channels.SelectionKey; 
import java.nio.channels.Selector; 
import java.nio.channels.SocketChannel; 
import java.util.Iterator; 
 
/** 
 * NIO客戶端 
 * @author 小路 
 */ 
public class NIOClient { 
 //通道管理器 
 private Selector selector; 
 
 /** 
  * 獲得一個(gè)Socket通道，并對(duì)該通道做一些初始化的工作 
  * @param ip 連接的服務(wù)器的ip 
  * @param port 連接的服務(wù)器的端口號(hào)   
  * @throws IOException 
  */ 
 public void initClient(String ip,int port) throws IOException { 
  // 獲得一個(gè)Socket通道 
  SocketChannel channel = SocketChannel.open(); 
  // 設(shè)置通道為非阻塞 
  channel.configureBlocking(false); 
  // 獲得一個(gè)通道管理器 
  this.selector = Selector.open(); 
   
  // 客戶端連接服務(wù)器,其實(shí)方法執(zhí)行并沒(méi)有實(shí)現(xiàn)連接，需要在listen（）方法中調(diào) 
  //用channel.finishConnect();才能完成連接 
  channel.connect(new InetSocketAddress(ip,port)); 
  //將通道管理器和該通道綁定，并為該通道注冊(cè)SelectionKey.OP_CONNECT事件。 
  channel.register(selector, SelectionKey.OP_CONNECT); 
 } 
 
 /** 
  * 采用輪詢的方式監(jiān)聽selector上是否有需要處理的事件，如果有，則進(jìn)行處理 
  * @throws IOException 
  */ 
 @SuppressWarnings("unchecked") 
 public void listen() throws IOException { 
  // 輪詢?cè)L問(wèn)selector 
  while (true) { 
   selector.select(); 
   // 獲得selector中選中的項(xiàng)的迭代器 
   Iterator ite = this.selector.selectedKeys().iterator(); 
   while (ite.hasNext()) { 
    SelectionKey key = (SelectionKey) ite.next(); 
    // 刪除已選的key,以防重復(fù)處理 
    ite.remove(); 
    // 連接事件發(fā)生 
    if (key.isConnectable()) { 
     SocketChannel channel = (SocketChannel) key 
       .channel(); 
     // 如果正在連接，則完成連接 
     if(channel.isConnectionPending()){ 
      channel.finishConnect(); 
       
     } 
     // 設(shè)置成非阻塞 
     channel.configureBlocking(false); 
 
     //在這里可以給服務(wù)端發(fā)送信息哦 
     channel.write(ByteBuffer.wrap(new String("向服務(wù)端發(fā)送了一條信息").getBytes())); 
     //在和服務(wù)端連接成功之后，為了可以接收到服務(wù)端的信息，需要給通道設(shè)置讀的權(quán)限。 
     channel.register(this.selector, SelectionKey.OP_READ); 
      
     // 獲得了可讀的事件 
    } else if (key.isReadable()) { 
      read(key); 
    } 
 
   } 
 
  } 
 } 
 /** 
  * 處理讀取服務(wù)端發(fā)來(lái)的信息 的事件 
  * @param key 
  * @throws IOException 
  */ 
 public void read(SelectionKey key) throws IOException{ 
  //和服務(wù)端的read方法一樣 
 } 
  
  
 /** 
  * 啟動(dòng)客戶端測(cè)試 
  * @throws IOException 
  */ 
 public static void main(String[] args) throws IOException { 
  NIOClient client = new NIOClient(); 
  client.initClient("localhost",8000); 
  client.listen(); 
 } 
 
}