Java NIO的工作方式

public class Server {
 
   public static void main(String args[]) throws IOException {
      //为了简单起见，所有的异常信息都往外抛
      int port = 8899;
      //定义一个ServerSocket监听在端口8899上
      ServerSocket server = new ServerSocket(port);
      while (true) {
         //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的
         Socket socket = server.accept();
         //每接收到一个Socket就建立一个新的线程来处理它(这里可以使用pool线程池)
         new Thread(new Task(socket)).start();
      }
   }
   
   /**
    * 用来处理Socket请求的
    */
   static class Task implements Runnable {
      private Socket socket;
      public Task(Socket socket) {
         this.socket = socket;
      }
      public void run() {
         try {
            handleSocket();
         } catch (Exception e) {
            e.printStackTrace();
         }
      }

      /**
       * 跟客户端Socket进行通信
      * @throws Exception
       */
      private void handleSocket() throws Exception {
         BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "GBK"));
         StringBuilder sb = new StringBuilder();
         String temp;
         int index;
         while ((temp=br.readLine()) != null) {
            System.out.println(temp);
            if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收
             sb.append(temp.substring(0, index));
                break;
            }
            sb.append(temp);
         }
         System.out.println("客户端: " + sb);
         //读完后写一句
       Writer writer = new OutputStreamWriter(socket.getOutputStream(), "UTF-8");
         writer.write("你好，客户端。");
         writer.write("eof\n");
         writer.flush();
         writer.close();
         br.close();
         socket.close();
      }
   }
}

public class Client {
 
   public static void main(String args[]) throws Exception {
      //为了简单起见，所有的异常都直接往外抛
     String host = "127.0.0.1";  //要连接的服务端IP地址
     int port = 8899;   //要连接的服务端对应的监听端口
     //与服务端建立连接
     Socket client = new Socket(host, port);
      //建立连接后就可以往服务端写数据了
     Writer writer = new OutputStreamWriter(client.getOutputStream(), "GBK");
      writer.write("你好，服务端。");
      writer.write("eof\n");
      writer.flush();
      //写完以后进行读操作
     BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream(), "UTF-8"));
      //设置超时间为10秒
     client.setSoTimeout(10*1000);
      StringBuffer sb = new StringBuffer();
      String temp;
      int index;
      try {
         while ((temp=br.readLine()) != null) {
            if ((index = temp.indexOf("eof")) != -1) {
                sb.append(temp.substring(0, index));
                break;
            }
            sb.append(temp);
         }
      } catch (SocketTimeoutException e) {
         System.out.println("数据读取超时。");
      }
      System.out.println("服务端: " + sb);
      writer.close();
      br.close();
      client.close();
   }
}

public void selector() throws IOException{
		ByteBuffer buffer = ByteBuffer.allocate(1024);
		Selector selector = Selector.open();
		ServerSocketChannel ssc = ServerSocketChannel.open();
		ssc.configureBlocking(false);//非阻塞
		ssc.socket().bind(new InetSocketAddress(8080));
		ssc.register(selector, SelectionKey.OP_ACCEPT);//注册监听事件
		while(true){
			Set selectedkeys = selector.selectedKeys();//取得所有key的集合
			Iterator it = selectedkeys.iterator();//set集合迭代出key
			while(it.hasNext()){//判断it的是否还有下一个，没有返回false
				SelectionKey key = (SelectionKey) it.next();
				if ((key.readyOps() & SelectionKey.OP_ACCEPT) == SelectionKey.OP_ACCEPT) { 
					ServerSocketChannel serverChanel = (ServerSocketChannel)key.channel();
					SocketChannel sc = serverChanel.accept();
					sc.configureBlocking( false ); 
					SelectionKey newKey = sc.register( selector,SelectionKey.OP_READ);
					it.remove();
				}else if((key.readyOps() & SelectionKey.OP_READ)== SelectionKey.OP_READ){ 
					SocketChannel sc = (SocketChannel)key.channel(); //通过学号知道是谁问的问题 
					int bytesEchoed = 0; 
					while(true){ 
						buffer.clear();
						int n = sc.read(buffer);
						if(n<=0){
							break;
						}
						buffer.flip();//反转缓冲区，这时操作系统就可以正确的读取字节发送出去
					}
					it.remove();
				}
			}
		}
	}

ServerSocketChannel ssc= ServerSocketChannel.open();//新建NIO通道 
ssc.configureBlocking( false );//使通道为非阻塞 

ServerSocket ss = ssc.socket();//创建基于NIO通道的socket连接 
//新建socket通道的端口 
ss.bind(new InetSocketAddress("127.0.0.1",SERVERPORT)); 

//将NIO通道选绑定到择器,当然绑定后分配的主键为skey 
SelectionKey skey = ssc.register( selector, SelectionKey.OP_ACCEPT ); 

while(true){//除非学期结束，否则一直等待学生 
int num = selector.select();//获取通道内是否有选择器的关心事件, 意思是有多少学生报告(注：select()方法：选择一组键，其相应的通道以为I/O操作准备就绪。返回值可能为0) 
if(num<1){continue; } //当select()方法返回值>1，说明I/O操作还没准备就绪，将阻塞。小于1，往下继续执行。
Set selectedKeys = selector.selectedKeys();//获取通道内关心事件的集合 ，这里的集合就是老师和学生的编号集合，如果key是学生的，那就是老学生来问问题，如果key是老师的，那就是招生办的老师带着一个新生来注册 
Iterator it = selectedKeys.iterator(); 
while (it.hasNext()) {//遍历每个key （学生key和老师key） 
....... 
} 
..... 
} 

while (it.hasNext()) {//遍历每个事件 
try{ 
SelectionKey key = (SelectionKey)it.next(); //先得到这个学生的编号key 
//判断是新生报道还是老生问问题 
if ((key.readyOps() & SelectionKey.OP_ACCEPT) 
== SelectionKey.OP_ACCEPT) { 
//这是招生老师的Key说明是新生注册，先找到招生老师，再由招生老师找到新生，就可以给新生注册学号了 
ServerSocketChannel serverChanel = (ServerSocketChannel)key.channel(); //通过key把学校和老师找到了 
//从serverSocketChannel中创建出与客户端的连接socketChannel 有了老师才有学生，不可能我教计算机的，来一个想学李小龙的都让他报名 
SocketChannel sc = serverChanel.accept(); //学生报名成功 
sc.configureBlocking( false ); 
// 把新连接注册到选择器,新生被接收后给注册个新学号 
SelectionKey newKey = sc.register( selector, 
SelectionKey.OP_READ ); //注册学号成功，并分配学生的权限 
it.remove(); //新生注册任务完成了，呵呵 
System.out.println( "Got connection from "+sc ); 
}else 
//读客户端数据的事件,此时有客户端发数据过来,客户端事件 这是老学生来问问题了。 
if((key.readyOps() & SelectionKey.OP_READ)== SelectionKey.OP_READ){ 
// 读取数据 ，接受学生的问题 
SocketChannel sc = (SocketChannel)key.channel(); //通过学号知道是谁问的问题 

//下面接受问题 
int bytesEchoed = 0; 
while((bytesEchoed = sc.read(buffer))> 0){ 
System.out.println("bytesEchoed:"+bytesEchoed); 
} 
echoBuffer.flip(); 
System.out.println("limet:"+echoBuffer.limit()); 
byte [] content = new byte[echoBuffer.limit()]; 
echoBuffer.get(content); 
String result=new String(content); 
doPost(result,sc); //相应老师会去做回答的，细节自己去写吧 
echoBuffer.clear(); 
it.remove(); //任务完成，记得上面也是一样，要remove掉，否则下一次又来一次任务，就死循环了 
} 
}catch(Exception e){} 
} 
}