加入收藏 | 设为首页 | 会员中心 | 我要投稿 惠州站长网 (https://www.0752zz.com.cn/)- 办公协同、云通信、物联设备、操作系统、高性能计算!
当前位置: 首页 > 建站 > 正文

BIO和NIO了解多少呢?一起从实践角度重新理解下吧

发布时间:2019-10-23 21:06:53 所属栏目:建站 来源:追逐仰望星空
导读:副标题#e# 01 前言 这段时间自己在看一些Java中BIO和NIO之类的东西,看了很多博客,发现各种关于NIO的概念说的天花乱坠头头是道,可以说是非常的完整,但是整个看下来之后,自己对NIO还是一知半解的状态,所以这篇文章不会提到很多的概念,而是站在一个实践

当服务端启动,客户端还没有请求连接服务器时,控制台结果如下:

BIO和NIO了解多少呢?一起从实践角度重新理解下吧

当服务端启动,客户端连接服务端,但没有发送数据时,控制台结果如下:

BIO和NIO了解多少呢?一起从实践角度重新理解下吧

当服务端启动,客户端连接服务端,并且发送数据时,控制台结果如下:

BIO和NIO了解多少呢?一起从实践角度重新理解下吧

3.3 结论

从上文的运行结果中我们可以看到,服务器端在启动后,首先需要等待客户端的连接请求(第一次阻塞),如果没有客户端连接,服务端将一直阻塞等待,然后当客户端连接后,服务器会等待客户端发送数据(第二次阻塞),如果客户端没有发送数据,那么服务端将会一直阻塞等待客户端发送数据。服务端从启动到收到客户端数据的这个过程,将会有两次阻塞的过程。这就是BIO的非常重要的一个特点,BIO会产生两次阻塞,第一次在等待连接时阻塞,第二次在等待数据时阻塞。

04 BIO

4.1 在单线程条件下BIO的弱点

在上文中,我们实现了一个简易的服务器,这个简易的服务器是以单线程运行的,其实我们不难看出,当我们的服务器接收到一个连接后,并且没有接收到客户端发送的数据时,是会阻塞在read()方法中的,那么此时如果再来一个客户端的请求,服务端是无法进行响应的。换言之,在不考虑多线程的情况下,BIO是无法处理多个客户端请求的。

4.2 BIO如何处理并发

在刚才的服务器实现中,我们实现的是单线程版的BIO服务器,不难看出,单线程版的BIO并不能处理多个客户端的请求,那么如何能使BIO处理多个客户端请求呢。

其实不难想到,我们只需要在每一个连接请求到来时,创建一个线程去执行这个连接请求,就可以在BIO中处理多个客户端请求了,这也就是为什么BIO的其中一条概念是服务器实现模式为一个连接一个线程,即客户端有连接请求时服务器端就需要启动一个线程进行处理。

4.3 多线程BIO服务器简易实现

  1. public class Server { 
  2.     public static void main(String[] args) { 
  3.         byte[] buffer = new byte[1024]; 
  4.         try { 
  5.             ServerSocket serverSocket = new ServerSocket(8080); 
  6.             System.out.println("服务器已启动并监听8080端口"); 
  7.             while (true) { 
  8.                 System.out.println(); 
  9.                 System.out.println("服务器正在等待连接..."); 
  10.                 Socket socket = serverSocket.accept(); 
  11.                 new Thread(new Runnable() { 
  12.                     @Override 
  13.                     public void run() { 
  14.                         System.out.println("服务器已接收到连接请求..."); 
  15.                         System.out.println(); 
  16.                         System.out.println("服务器正在等待数据..."); 
  17.                         try { 
  18.                             socket.getInputStream().read(buffer); 
  19.                         } catch (IOException e) { 
  20.                             // TODO Auto-generated catch block 
  21.                             e.printStackTrace(); 
  22.                         } 
  23.                         System.out.println("服务器已经接收到数据"); 
  24.                         System.out.println(); 
  25.                         String content = new String(buffer); 
  26.                         System.out.println("接收到的数据:" + content); 
  27.                     } 
  28.                 }).start(); 
  29.                  
  30.             } 
  31.         } catch (IOException e) { 
  32.             // TODO Auto-generated catch block 
  33.             e.printStackTrace(); 
  34.         } 
  35.     } 

(编辑:惠州站长网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

推荐文章
    热点阅读