【Java】网络编程之NIO_一站式学习java网络编程 全面理解bio/nio/aio

简单记录 慕课网-解锁网络编程之NIO的前世今生 & 一站式学习Java网络编程 全面理解BIO/NIO/AIO

内容概览

NIO是很重要的 网络编程

1、【了解】 NIO网络编程模型

1.1、NIO简介

• 姓名：Non-blocking I/O 或 New I/O

  非阻塞IO

• 出生：JDK 1.4

  JDK 1.4 及以上版本里提供的新API（New IO）

• 职务：高并发网络服务器支持岗

  高性能和高并发场景使用

NIO是全新的输入输出标准库，作为原始I/O的补充。

IO和NIO的区别

原有的 IO 是面向流的、阻塞的，NIO 是面向块的、非阻塞的。

1.2、编程模型

• 模型：对事物共性的抽象

• 编程模型：对编程共性的抽象

  实际的问题 具体的解决方案 抽象出一套

  依靠这个模型解决这一类的问题

BIO编程模型

NIO编程模型

AIO 编程模型

1.3、网络编程三剑客 BIO & NIO & AIO

网络编程三剑客 BIO & NIO & AIO

始于BIO 陷于NIO 终于AIO

网络编程演进史 java.io

阻塞式编程BIO -> 非阻塞式编程NIO -> 异步编程AIO

BIO Java1.4以前 NIO Java 1.4 AIO Java 1.7

网络编程模型扎心三剑客，一直听说过BIO/NIO/AIO ，但未深入理解 过，实际的项目代码也未曾实现过。

为什么要学习网络编程模型呢？

• 应用广泛 互联网大厂很多应用都是基于网络服务来实现的 。

• 能接触到经典模式、经典代码 ，可用学习总结。

• 业界、工作、面试，都会问到网络编程 ，要求熟悉TCP/IP、HTTP协议以及网络编程。

1.4、BIO是什么

BIO就是我们传统意义上的IO，它的特点是阻塞的。例如以前我们进行网络编程时，一个客户端使用一个线程来进行处理。这样会导致一个问题：服务器的线程数是有限制的，而不是每个客户端时时都有数据进行传输的。所以大量空的线程占了位置，但是又不工作，导致服务器的性能受限。

BIO和NIO对比：

BIO基于流，而NIO基于 Buffer. BIO 只能按照顺序读，而NIO可以随意读。

1.5、BIO网络模型

解决网络编程问题

基于阻塞IO实现的

• 服务器启动：监听建立客户端的连接请求

• 客户端启动：向服务器端发送建立连接请求

• 服务端启动新线程： 服务器在接收到客户端的请求后，将会创建一个新的线程

• 线程响应客户端： 服务端新创建的线程会与客户端建立socket连接，用于响应客户端的请求，通知客户端连接建立成功，随时可以发送数据。

• 等待客户端再次发送请求：服务器端处理完客户端的请求之后，就会处于等待状态 可能一直等待中

服务器端为每一个客户端建立一个线程，一旦客户端请求过多，服务器端线程数量也会过多，服务器压里会变得过大 甚至是崩溃。 大量的并发

BIO网络模型缺点

• 阻塞式I/O模型

  会导致服务器端的业务线程会因阻塞IO的问题一直阻塞等待客户端发起请求，如果客户端不发起请求，服务端的业务线程会一直存在。

  服务端一直等待客户端发送请求，对应的线程也一直存在。

• 弹性伸缩能力差

  客户端与服务器端的线程数呈现1：1的关系， 如果是有很多客户端发送请求，对应的线程数也会有很多很多。

• 多线程耗资源

  每一个线程都会对CPU的调度资源进行占用，一旦占用而不释放，则会导致资源的紧缺，甚至服务器的异常宕机、崩溃了。

  BIO的缺点是阻塞式I/O 引起的

1.6、NIO网络模型猜想

暂停一下，YY一波。

NIO，客户端的个数与服务器端的线程数呈M:1的关系

1.7、NIO网络模型

**第一步：**注册连接并提供服务：Selector 中初始化注册并建立连接事件，提供给Client建立连接的服务；

Client通过Selector连接与AcceptorHandler 发送创建客户端的连接，并又AcceptorHandler方法返回响应结果；同时该AcceptorHandler方法向Selector中注册可读事件（Client连接客户端成功后）。

**第二步：**提供服务：Client 发送请求，Selector中对注册状态及客户端可读性验证，正常情况下，已通过第一步，所以直接连接到处理器进行读写操作，根据需求执行业务逻辑，并响应给客户。

第三步：客户端连接可读，在向client响应客户端请求后，注册连接可读事件到Selector 中，所注册的是具体执行业务的Handler。

1.8、NIO网络模型改进

NIO网络模型改进改进优化

• 非阻塞式I/O模型

  服务器端提供一个单线程的selector来统一管理所有客户端接入的连接，并负责监听每个连接所关心的事件。

• 弹性伸缩能力强

  服务器端一个线程处理所有客户端的连接请求，客户端的个数与服务器端的线程数呈M比1的关系

  一个线程 处理所有请求。

• 单线程节省资源

  避免了线程的频繁创建和销毁，同时也避免了多个线程之间上下文的切换，提高了执行效率

  线程创建、切换什么的都没了，节省了资源。

2、【熟悉】NIO网络编程详解

2.1、NIO核心类之Channel

NIO核心

• Channel：通道
• Buffer：缓冲区
• Selector：选择器 或 多路复用器

Channel简介 Channel通道

• 双向性
• 非阻塞性
• 操作唯一性

channel是信息传输的通道，是jdk NIO中对输入输出方法的另一种抽象，类比IO中的流，与流不同之处在于，channel具有双向性，而流是单向传输的，一个流必须是InputStream或OutputStream的子类，而通道可以用于读或写、二者也可同时进行。channel可以工作在非阻塞模式下，构成NIO的基础。在NIO中，操作channel的唯一方式是使用buffer，通过buffer操作channel，可实现数据块的传输。

Channel实现

• 文件类：FileChannel

  用于对文件的读写

• UDP类：DatagramChannel

  用于UDP数据读写

• TCP类：ServerSocketChannel / SocketChannel

  TCP数据读写

数据读写

Socket回顾

Channel使用

2.2、NIO核心类之Buffer

Buffer简介 Buffer缓冲区

• 作用：读写Channel中数据
• 本质：一块内存区域

Buffer：缓冲区，它提供唯一与channel进行交互的方式，作用是读写channel中的数据。Buffer从本质上说是一块内存区域，它是一块可以写入数据，读取数据的内存。

Buffer属性

• Capacity：容量

  分配的buffer容量，一旦写入的最大字节数超过这个容量，需要将其清空之后，才能继续往里面写数据的。

• Position：位置

  范围0到容量-1

  当前操作的位置，初始值为0，最大值是容量值-1。

• Limit：上限

  上限，写模式下等于Capacity，读模式下等于最多能读取的数据量。

• Mark：标记

  标记，记录mark的位置，调用reset方法时，position会回到mark的位置。

操作

Buffer使用

/*
   * 初始化长度为10的byte类型 buffer
   */
ByteBuffer.allocate(10);//allocate分配、指定的意思
1
2
3
4

 /*
   * 向byteBuffer中写入三个字节
   */
  byteBuffer.put("abc".getBytes(Charset.forName("UTF-8")));
1
2
3
4

 /*
   * 将byteBuffer从写模式切换成读模式
   */
  byteBuffer.flip()://flip
1
2
3
4

/**
 * 从byteBuffer中读取一个字节
 */
byteBuffer.get();
1
2
3
4

/**
 * 调用mark方法记录下当前position的位置
 */
 byteBuffer.mark();
1
2
3
4

 /*
   * 将b先调用get方法读取下一个字节
   * 再调用reset方法将position重置到mark位置
   */
  byteBuffer.get():
  byteBuffer.reset();
1
2
3
4
5
6

/*
   * 调用clear方法，将所有属性重置
   */
byteBuffer.clear();
1
2
3
4

数据读写

2.3、NIO核心类之Selector

Selector简介 选择器/多路复用器

• 作用：I/O就绪选择
• 地位：NIO网络编程的基础

Selector使用

最重要的应该就是代码片段3： 在这一步对就绪事件进行监听，如果一直不通过，就一直阻塞等待，直到有就绪事件发生，并注册通过检测有效，方才放行

SelectionKey 简介

• 四种就绪状态常量

  连接就绪、接受就绪、读就绪、写就绪

• 有价值的属性

NIO编程实现步骤

• 第一步：创建Selector
• 第二步：创建ServerSocketChannel，并绑定监听端口
• 第三步：将Channel设置为非阻塞模式
• 第四步：将Channel注册到Selector上，监听连接事件
• 第五步：循环调用Selector的select方法，检测就绪情况
• 第六步：调用selectedKeys方法获取就绪channel集合
• 第七步：判断就绪事件种类，调用不同业务处理方法
• 第八步：根据业务需要决定是否再次注册监听事件，重复执行第四步操作

实战操作

3、【应用】NIO网络编程实战

服务器端功能实现

利用NIO编程知识，实现多人聊天室

服务器端业务处理功能实现

客户端功能实现 上

客户端功能实现 下

功能完善

NIO多人聊天室代码-https://github.com/liuawen/small-Project/tree/master/nio-chat-room

一个类运行多个实例

4、【掌握】NIO网络编程缺陷

缺陷分析

NIO网络编程缺陷

• 麻烦：NIO类库和API繁杂

• 心累：可靠性能力补齐，工作量和难度都非常大

  NIO网络编程实战中写的聊天室，Bug很多 测试

• 有坑：Selector空轮询，导致CPU100%

  JDK 8 仍存在 发生概率低了点

5、【深谙】NIO总结

NIO网络编程原理与实战

5.1、NIO网络编程模型

5.2、NIO网络编程详解

通道（Channel）

简介 双向性 非阻塞性 操作唯一性

实现 文件类 FileChannel UDP类 DatagramChannel TCP类 ServerSocketChannel SocketChannel

用法

缓冲区（Buffer）

简介 读写Channel中数据 本质室一块内存区域

属性 容量 Capacity 上限 Limit 位置 Position 标记 Mark

用法

多路复用器（Selector）

简介 I/O事件就绪选择 NIO网络编程基础之一

用法

选择键（SelectionKey）

简介 四种就绪状态处理 有价值的属性

5.3、NIO网络编程实战

NIO编程实现步骤

• 第一步：创建Selector
• 第二步：创建ServerSocketChannel，并绑定监听端口
• 第三步：将Channel设置为非阻塞模式
• 第四步：将Channel注册到Selector上，监听连接事件
• 第五步：循环调用Selector的select方法，检测就绪情况
• 第六步：调用selectedKeys方法获取就绪channel集合
• 第七步：判断就绪事件种类，调用不同业务处理方法
• 第八步：根据业务需要决定是否再次注册监听事件，重复执行第四步操作

写一波

5.4、NIO网络编程缺陷

NIO类库和API繁杂

可靠性能力补齐，工作量和难度非常大

Selector空轮询，CPU100%

NIO过于复杂

现在主流的网络通信是netty框架了，netty是常见的NIO框架

Netty是一个基于NIO的客户、服务器端的编程框架，是一个提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。使用Netty 可以快速简单地开发协议服务器和客户端等网络应用程序，Netty相当于简化和流线化了网络应用的编程开发过程，例如：基于TCP和UDP的socket服务开发。“快速”和“简单”并不用产生维护性或性能上的问题。Netty 是一个吸收了多种协议（包括FTP、SMTP、HTTP等各种二进制文本协议）的实现经验，并经过相当精心设计的项目。最终，Netty 成功的找到了一种方式，在保证易于开发的同时还保证了其应用的性能，稳定性和伸缩性。

官网：https://netty.io/

Github地址：https://github.com/netty/netty

Netty4.1

开发文档：https://netty.io/wiki/user-guide-for-4.x.html
API文档：https://netty.io/4.1/api/index.html