bio aio nio

Posted haozi_ncepu

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了bio aio nio相关的知识，希望对你有一定的参考价值。

转载请注明出处：http://blog.csdn.net/anxpp/article/details/51512200，谢谢！

    本文会从传统的BIO到NIO再到AIO自浅至深介绍，并附上完整的代码讲解。

    下面代码中会使用这样一个例子：客户端发送一段算式的字符串到服务器，服务器计算后返回结果到客户端。

    代码的所有说明，都直接作为注释，嵌入到代码中，看代码时就能更容易理解，代码中会用到一个计算结果的工具类，见文章代码部分。

    相关的基础知识文章推荐：

    Linux 网络 I/O 模型简介（图文）

    Java 并发（多线程）    

1、BIO编程

    1.1、传统的BIO编程

    网络编程的基本模型是C/S模型，即两个进程间的通信。

    服务端提供IP和监听端口，客户端通过连接操作想服务端监听的地址发起连接请求，通过三次握手连接，如果连接成功建立，双方就可以通过套接字进行通信。

    传统的同步阻塞模型开发中，ServerSocket负责绑定IP地址，启动监听端口；Socket负责发起连接操作。连接成功后，双方通过输入和输出流进行同步阻塞式通信。 

    简单的描述一下BIO的服务端通信模型：采用BIO通信模型的服务端，通常由一个独立的Acceptor线程负责监听客户端的连接，它接收到客户端连接请求之后为每个客户端创建一个新的线程进行链路处理没处理完成后，通过输出流返回应答给客户端，线程销毁。即典型的一请求一应答通宵模型。

    传统BIO通信模型图：

    

    该模型最大的问题就是缺乏弹性伸缩能力，当客户端并发访问量增加后，服务端的线程个数和客户端并发访问数呈1:1的正比关系，Java中的线程也是比较宝贵的系统资源，线程数量快速膨胀后，系统的性能将急剧下降，随着访问量的继续增大，系统最终就死-掉-了。

    同步阻塞式I/O创建的Server源码：

[java]  view plain  copy  print ?
  1. package com.anxpp.io.calculator.bio;  
  2. import java.io.IOException;  
  3. import java.net.ServerSocket;  
  4. import java.net.Socket;  
  5. /** 
  6.  * BIO服务端源码 
  7.  * @author yangtao__anxpp.com 
  8.  * @version 1.0 
  9.  */  
  10. public final class ServerNormal   
  11.     //默认的端口号  
  12.     private static int DEFAULT_PORT = 12345;  
  13.     //单例的ServerSocket  
  14.     private static ServerSocket server;  
  15.     //根据传入参数设置监听端口，如果没有参数调用以下方法并使用默认值  
  16.     public static void start() throws IOException  
  17.         //使用默认值  
  18.         start(DEFAULT_PORT);  
  19.       
  20.     //这个方法不会被大量并发访问，不太需要考虑效率，直接进行方法同步就行了  
  21.     public synchronized static void start(int port) throws IOException  
  22.         if(server != null) return;  
  23.         try  
  24.             //通过构造函数创建ServerSocket  
  25.             //如果端口合法且空闲，服务端就监听成功  
  26.             server = new ServerSocket(port);  
  27.             System.out.println("服务器已启动，端口号：" + port);  
  28.             //通过无线循环监听客户端连接  
  29.             //如果没有客户端接入，将阻塞在accept操作上。  
  30.             while(true)  
  31.                 Socket socket = server.accept();  
  32.                 //当有新的客户端接入时，会执行下面的代码  
  33.                 //然后创建一个新的线程处理这条Socket链路  
  34.                 new Thread(new ServerHandler(socket)).start();  
  35.               
  36.         finally  
  37.             //一些必要的清理工作  
  38.             if(server != null)  
  39.                 System.out.println("服务器已关闭。");  
  40.                 server.close();  
  41.                 server = null;  
  42.               
  43.           
  44.       
  45.   

    客户端消息处理线程ServerHandler源码：

[java]  view plain  copy  print ?
  1. package com.anxpp.io.calculator.bio;  
  2. import java.io.BufferedReader;  
  3. import java.io.IOException;  
  4. import java.io.InputStreamReader;  
  5. import java.io.PrintWriter;  
  6. import java.net.Socket;  
  7.   
  8. import com.anxpp.io.utils.Calculator;  
  9. /** 
  10.  * 客户端线程 
  11.  * @author yangtao__anxpp.com 
  12.  * 用于处理一个客户端的Socket链路 
  13.  */  
  14. public class ServerHandler implements Runnable  
  15.     private Socket socket;  
  16.     public ServerHandler(Socket socket)   
  17.         this.socket = socket;  
  18.       
  19.     @Override  
  20.     public void run()   
  21.         BufferedReader in = null;  
  22.         PrintWriter out = null;  
  23.         try  
  24.             in = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
  25.             out = new PrintWriter(socket.getOutputStream(),true);  
  26.             String expression;  
  27.             String result;  
  28.             while(true)  
  29.                 //通过BufferedReader读取一行  
  30.                 //如果已经读到输入流尾部，返回null,退出循环  
  31.                 //如果得到非空值，就尝试计算结果并返回  
  32.                 if((expression = in.readLine())==nullNIO,AIO,BIO

    Java的BIO,NIO和AIO的区别于演进

    Netty学习（源码分析）

    Netty学习（源码分析）

    关于BIO,NIO,AIO的理解

    详解 同步异步阻塞非阻塞 与 BIO NIO AIO区别多路复用