首页 文章 精选 留言 我的

JDK10都发布了，nio你了解多少？

2018-05-13 513

前言

只有光头才能变强

回顾前面：

本来我预想是先来回顾一下传统的IO模式的，将传统的IO模式的相关类理清楚(因为IO的类很多)。

但是，发现在整理的过程已经有很多优秀的文章了，而我自己来整理的话可能达不到他们的水平。并且传统的IO估计大家都会用，而NIO就不一定了。

下面我就贴几张我认为整理比较优秀的思维导图(下面会给出图片来源地址，大家可前往阅读)：

按操作方式分类结构图：

img_3abd22f73e146b121e5681fd430ca05a.jpe

字节流的输入和输出对照图：

img_5d274d13ea07e1342f5aa4169b9399df.jpe

字符流的输入和输出对照图：

img_9cf1ec06c707080c2cc10ca7c3de4448.jpe

按操作对象分类结构图：

img_504689f9560695a9c3da3858bdc86e84.jpe

**上述图片原文地址，知乎作者@小明**：

还有阅读传统IO源码的优秀文章：

相信大家看完上面两个给出的链接+理解了包装模式就是这么简单啦，传统的IO应该就没什么事啦~~

而NIO对于我来说可以说是挺陌生的，在当初学的时候是接触过的。但是一直没有用它，所以停留认知：nio是jdk1.4开始有的，比传统IO高级。

相信很多初学者都跟我一样，对NIO是不太了解的。而我们现在jdk10都已经发布了，jdk1.4的nio都不知道，这有点说不过去了。

所以我花了几天去了解NIO的核心知识点，期间看了《Java 编程思想》和《疯狂Java 讲义》的nio模块。但是，会发现看完了之后还是很迷，不知道NIO这是干嘛用的，而网上的资料与书上的知识点没有很好地对应。

  • 网上的资料很多都以IO的五种模型为基础来讲解NIO，而IO这五种模型其中又涉及到了很多概念：同步/异步/阻塞/非阻塞/多路复用，而不同的人又有不同的理解方式。
  • 还有涉及到了unix的select/epoll/poll/pselect，fd这些关键字，没有相关基础的人看起来简直是天书
  • 这就导致了在初学时认为nio远不可及

我在找资料的过程中也收藏了好多讲解NIO的资料，这篇文章就是以初学的角度来理解NIO。也算是我这两天看NIO的一个总结吧。

  • 希望大家可以看了之后知道什么是NIO，NIO的核心知识点是什么，会使用NIO~

那么接下来就开始吧，如果文章有错误的地方请大家多多包涵，不吝在评论区指正哦~

声明：本文使用JDK1.8

一、NIO的概述

JDK 1.4中的java.nio.*包中引入新的Java I/O库，其目的是提高速度。实际上，“旧”的I/O包已经使用NIO重新实现过，即使我们不显式的使用NIO编程，也能从中受益。

  • nio翻译成 no-blocking io 或者 new io 都无所谓啦，都说得通~

在《Java编程思想》读到“即使我们不显式的使用NIO编程，也能从中受益”的时候，我是挺在意的，所以：我们测试一下使用NIO复制文件和传统IO复制文件的性能：


import java.io.*;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

public class SimpleFileTransferTest {

    private long transferFile(File source, File des) throws IOException {
        long startTime = System.currentTimeMillis();

        if (!des.exists())
            des.createNewFile();

        BufferedInputStream bis = new BufferedInputStream(new FileInputStream(source));
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(des));

        //将数据源读到的内容写入目的地--使用数组
        byte[] bytes = new byte[1024 * 1024];
        int len;
        while ((len = bis.read(bytes)) != -1) {
            bos.write(bytes, 0, len);
        }

        long endTime = System.currentTimeMillis();
        return endTime - startTime;
    }

    private long transferFileWithNIO(File source, File des) throws IOException {
        long startTime = System.currentTimeMillis();

        if (!des.exists())
            des.createNewFile();

        RandomAccessFile read = new RandomAccessFile(source, "rw");
        RandomAccessFile write = new RandomAccessFile(des, "rw");

        FileChannel readChannel = read.getChannel();
        FileChannel writeChannel = write.getChannel();


        ByteBuffer byteBuffer = ByteBuffer.allocate(1024 * 1024);//1M缓冲区

        while (readChannel.read(byteBuffer) > 0) {
            byteBuffer.flip();
            writeChannel.write(byteBuffer);
            byteBuffer.clear();
        }

        writeChannel.close();
        readChannel.close();
        long endTime = System.currentTimeMillis();
        return endTime - startTime;
    }

    public static void main(String[] args) throws IOException {
        SimpleFileTransferTest simpleFileTransferTest = new SimpleFileTransferTest();
        File sourse = new File("F:\\电影\\[电影天堂www.dygod.cn]猜火车-cd1.rmvb");
        File des = new File("X:\\Users\\ozc\\Desktop\\io.avi");
        File nio = new File("X:\\Users\\ozc\\Desktop\\nio.avi");

        long time = simpleFileTransferTest.transferFile(sourse, des);
        System.out.println(time + "：普通字节流时间");

        long timeNio = simpleFileTransferTest.transferFileWithNIO(sourse, nio);
        System.out.println(timeNio + "：NIO时间");


    }

}

我分别测试了文件大小为13M，40M，200M的：

img_e885f0bd9aa351554434af86601f7497.png

img_ae51deebc4945a6e287a39d2f07dc3f1.png

img_71891c935273babefa53435261edabb8.png

1.1为什么要使用NIO

可以看到使用过NIO重新实现过的传统IO根本不虚，在大文件下效果还比NIO要好(当然了，个人几次的测试，或许不是很准)

  • 而NIO要有一定的学习成本，也没有传统IO那么好理解。

那这意味着我们可以不使用/学习NIO了吗？

答案是否定的，IO操作往往在两个场景下会用到：

  • 文件IO
  • 网络IO

NIO的魅力：在网络中使用IO就可以体现出来了！

  • 后面会说到网络中使用NIO，不急哈~

二、NIO快速入门

首先我们来看看IO和NIO的区别：

img_e770a297e39bc8bf51675b2e69fed54d.png

  • 可简单认为：IO是面向流的处理，NIO是面向块(缓冲区)的处理
    • 面向流的I/O 系统一次一个字节地处理数据。
    • 一个面向块(缓冲区)的I/O系统以块的形式处理数据。

NIO主要有三个核心部分组成：

  • buffer缓冲区
  • Channel管道
  • Selector选择器

2.1buffer缓冲区和Channel管道

在NIO中并不是以流的方式来处理数据的，而是以buffer缓冲区和Channel管道配合使用来处理数据。

简单理解一下：

  • Channel管道比作成铁路，buffer缓冲区比作成火车(运载着货物)

而我们的NIO就是通过Channel管道运输着存储数据的Buffer缓冲区的来实现数据的处理！

  • 要时刻记住：Channel不与数据打交道，它只负责运输数据。与数据打交道的是Buffer缓冲区
    • Channel-->运输
    • Buffer-->数据

相对于传统IO而言，流是单向的。对于NIO而言，有了Channel管道这个概念，我们的读写都是双向的(铁路上的火车能从广州去北京、自然就能从北京返还到广州)！

2.1.1buffer缓冲区核心要点

我们来看看Buffer缓冲区有什么值得我们注意的地方。

Buffer是缓冲区的抽象类：

img_c79582345ff57bf950710d9bfc300c32.png

其中ByteBuffer是用得最多的实现类(在管道中读写字节数据)。

img_4db99a7cd5890579f5de0b99f747dd68.png

拿到一个缓冲区我们往往会做什么？很简单，就是读取缓冲区的数据/写数据到缓冲区中。所以，缓冲区的核心方法就是:

  • put()
  • get()

img_6feed136dbc0545c24f96b79cc944913.png

img_6ee88003f145a8e4d30d2e38a318e4df.png

Buffer类维护了4个核心变量属性来提供关于其所包含的数组的信息。它们是：

  • 容量Capacity
    • 缓冲区能够容纳的数据元素的最大数量。容量在缓冲区创建时被设定，并且永远不能被改变。(不能被改变的原因也很简单，底层是数组嘛)
  • 上界Limit
    • 缓冲区里的数据的总数，代表了当前缓冲区中一共有多少数据。
  • 位置Position
    • 下一个要被读或写的元素的位置。Position会自动由相应的 get( )和 put( )函数更新。
  • 标记Mark
    • 一个备忘位置。用于记录上一次读写的位置。

img_f9d0c54962a4ffd56ea4fd95534e85f1.png

2.1.2buffer代码演示

首先展示一下是如何创建缓冲区的，核心变量的值是怎么变化的。


    public static void main(String[] args) {

        // 创建一个缓冲区
        ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

        // 看一下初始时4个核心变量的值
        System.out.println("初始时-->limit--->"+byteBuffer.limit());
        System.out.println("初始时-->position--->"+byteBuffer.position());
        System.out.println("初始时-->capacity--->"+byteBuffer.capacity());
        System.out.println("初始时-->mark--->" + byteBuffer.mark());

        System.out.println("--------------------------------------");

        // 添加一些数据到缓冲区中
        String s = "Java3y";
        byteBuffer.put(s.getBytes());

        // 看一下初始时4个核心变量的值
        System.out.println("put完之后-->limit--->"+byteBuffer.limit());
        System.out.println("put完之后-->position--->"+byteBuffer.position());
        System.out.println("put完之后-->capacity--->"+byteBuffer.capacity());
        System.out.println("put完之后-->mark--->" + byteBuffer.mark());
    }

运行结果：

img_4f04fd464344b577c9381e1361be8b37.png

现在我想要从缓存区拿数据，怎么拿呀？？NIO给了我们一个flip()方法。这个方法可以改动position和limit的位置！

还是上面的代码，我们flip()一下后，再看看4个核心属性的值会发生什么变化：

img_fcc5241b9fb323b85c1d2481a9895968.png

很明显的是：

  • limit变成了position的位置了
  • 而position变成了0

看到这里的同学可能就会想到了：当调用完filp()时：limit是限制读到哪里，而position是从哪里读

一般我们称filp()为“切换成读模式”

  • 每当要从缓存区的时候读取数据时，就调用filp()“切换成读模式”。

img_ec9e6ad2a1e58ea20447004f8c92192c.png

切换成读模式之后，我们就可以读取缓冲区的数据了：


        // 创建一个limit()大小的字节数组(因为就只有limit这么多个数据可读)
        byte[] bytes = new byte[byteBuffer.limit()];

        // 将读取的数据装进我们的字节数组中
        byteBuffer.get(bytes);

        // 输出数据
        System.out.println(new String(bytes, 0, bytes.length));

img_cef08bb0d542141ba9ea7e345856ed01.png

随后输出一下核心变量的值看看：

img_65134c55a5d6bc06542eb42cf0bd91bb.png

读完我们还想写数据到缓冲区，那就使用clear()函数，这个函数会“清空”缓冲区：

  • 数据没有真正被清空，只是被遗忘掉了

img_6711db7114121062998699bb366e43d4.png

2.1.3FileChannel通道核心要点

img_a31f80cc8c666a2896867952e143dccf.png

Channel通道只负责传输数据、不直接操作数据的。操作数据都是通过Buffer缓冲区来进行操作！


        // 1. 通过本地IO的方式来获取通道
        FileInputStream fileInputStream = new FileInputStream("F:\\3yBlog\\JavaEE常用框架\\Elasticsearch就是这么简单.md");

        // 得到文件的输入通道
        FileChannel inchannel = fileInputStream.getChannel();

        // 2. jdk1.7后通过静态方法.open()获取通道
        FileChannel.open(Paths.get("F:\\3yBlog\\JavaEE常用框架\\Elasticsearch就是这么简单2.md"), StandardOpenOption.WRITE);

使用FileChannel配合缓冲区实现文件复制的功能：

img_868c22c3068deb47f5fcb240e1709579.png

使用内存映射文件的方式实现文件复制的功能(直接操作缓冲区)：

img_538b9514891f5e787d4321991e309246.png

通道之间通过transfer()实现数据的传输(直接操作缓冲区)：

img_82997a013a64d5a83864dd5c77dab3ec.png

2.1.4直接与非直接缓冲区

  • 非直接缓冲区是需要经过一个：copy的阶段的(从内核空间copy到用户空间)
  • 直接缓冲区不需要经过copy阶段，也可以理解成--->内存映射文件，(上面的图片也有过例子)。

img_915afa079591f69f0d68f318be994ad1.png

img_adf3284de641d630cfd6d167291b93e9.png

使用直接缓冲区有两种方式：

  • 缓冲区创建的时候分配的是直接缓冲区
  • 在FileChannel上调用map()方法，将文件直接映射到内存中创建

img_d90bce67357534e26b726b61ea48f91a.png

2.1.5scatter和gather、字符集

这个知识点我感觉用得挺少的，不过很多教程都有说这个知识点，我也拿过来说说吧：

  • 分散读取(scatter)：将一个通道中的数据分散读取到多个缓冲区中
  • 聚集写入(gather)：将多个缓冲区中的数据集中写入到一个通道中

img_949b445b97f9f66d7c8b4f10aee1d3c1.png

img_aa10e39337df16ccd7863c7e1e0854fe.png

分散读取

img_d047494a12430565422e4be4ce417e06.png

聚集写入

img_fb52918d4b3bec44219d58ea34302c48.png

字符集(只要编码格式和解码格式一致，就没问题了)

img_48611918c70f0bf0c8face0488ad7565.png

三、IO模型理解

文件的IO就告一段落了，我们来学习网络中的IO~~~为了更好地理解NIO，我们先来学习一下IO的模型~

根据UNIX网络编程对I/O模型的分类，在UNIX可以归纳成5种I/O模型：

  • 阻塞I/O
  • 非阻塞I/O
  • I/O多路复用
  • 信号驱动I/O
  • 异步I/O

3.0学习I/O模型需要的基础

3.0.1文件描述符

Linux 的内核将所有外部设备都看做一个文件来操作，对一个文件的读写操作会调用内核提供的系统命令(api)，返回一个file descriptor（fd，文件描述符）。而对一个socket的读写也会有响应的描述符，称为socket fd（socket文件描述符），描述符就是一个数字，指向内核中的一个结构体（文件路径，数据区等一些属性）。

  • 所以说：在Linux下对文件的操作是利用文件描述符(file descriptor)来实现的。

3.0.2用户空间和内核空间

为了保证用户进程不能直接操作内核（kernel），保证内核的安全，操心系统将虚拟空间划分为两部分

  • 一部分为内核空间。
  • 一部分为用户空间。

3.0.3I/O运行过程

我们来看看IO在系统中的运行是怎么样的(我们以read为例)

img_e80c878620d9afc2e866b70eb403b383.png

可以发现的是：当应用程序调用read方法时，是需要等待的--->从内核空间中找数据，再将内核空间的数据拷贝到用户空间的。

  • 这个等待是必要的过程！

下面只讲解用得最多的3个I/0模型：

  • 阻塞I/O
  • 非阻塞I/O
  • I/O多路复用

3.1阻塞I/O模型

在进程(用户)空间中调用recvfrom，其系统调用直到数据包到达且被复制到应用进程的缓冲区中或者发生错误时才返回，在此期间一直等待。

img_5ad5c83ed696c7c7ef582d8d218c4ac6.png

3.2非阻塞I/O模型

recvfrom从应用层到内核的时候，如果没有数据就直接返回一个EWOULDBLOCK错误，一般都对非阻塞I/O模型进行轮询检查这个状态，看内核是不是有数据到来。

img_9f8f30250ba54c200b4354dbd0306d8a.png

3.3I/O复用模型

前面也已经说了：在Linux下对文件的操作是利用文件描述符(file descriptor)来实现的。

在Linux下它是这样子实现I/O复用模型的：

  • 调用select/poll/epoll/pselect其中一个函数，传入多个文件描述符，如果有一个文件描述符就绪，则返回，否则阻塞直到超时。

比如poll()函数是这样子的：int poll(struct pollfd *fds,nfds_t nfds, int timeout);

其中 pollfd 结构定义如下：


struct pollfd {
    int fd;         /* 文件描述符 */
    short events;         /* 等待的事件 */
    short revents;       /* 实际发生了的事件 */
};

img_1386971a37730af6bf62f45478a4159f.gif

img_335637bead258ec04f20be9f518b98c4.png

  • （1）当用户进程调用了select，那么整个进程会被block；
  • （2）而同时，kernel会“监视”所有select负责的socket；
  • （3）当任何一个socket中的数据准备好了，select就会返回；
  • （4）这个时候用户进程再调用read操作，将数据从kernel拷贝到用户进程(空间)。
  • 所以，I/O 多路复用的特点是通过一种机制一个进程能同时等待多个文件描述符，而这些文件描述符其中的任意一个进入读就绪状态，select()函数就可以返回。

select/epoll的优势并不是对于单个连接能处理得更快，而是在于能处理更多的连接。

3.4I/O模型总结

正经的描述都在上面给出了，不知道大家理解了没有。下面我举几个例子总结一下这三种模型：

阻塞I/O：

  • Java3y跟女朋友去买喜茶，排了很久的队终于可以点饮料了。我要绿研，谢谢。可是喜茶不是点了单就能立即拿，于是我在喜茶门口等了一小时才拿到绿研。
    • 在门口干等一小时

非阻塞I/O：

  • Java3y跟女朋友去买一点点，排了很久的队终于可以点饮料了。我要波霸奶茶，谢谢。可是一点点不是点了单就能立即拿，同时服务员告诉我：你大概要等半小时哦。你们先去逛逛吧~于是Java3y跟女朋友去玩了几把斗地主，感觉时间差不多了。于是又去一点点问：请问到我了吗？我的单号是xxx。服务员告诉Java3y：还没到呢，现在的单号是XXX，你还要等一会，可以去附近耍耍。问了好几次后，终于拿到我的波霸奶茶了。
    • 去逛了下街、斗了下地主，时不时问问到我了没有

I/O复用模型：

  • Java3y跟女朋友去麦当劳吃汉堡包，现在就厉害了可以使用微信小程序点餐了。于是跟女朋友找了个地方坐下就用小程序点餐了。点餐了之后玩玩斗地主、聊聊天什么的。时不时听到广播在复述XXX请取餐，反正我的单号还没到，就继续玩呗。~~等听到广播的时候再取餐就是了。时间过得挺快的，此时传来：Java3y请过来取餐。于是我就能拿到我的麦辣鸡翅汉堡了。
    • 听广播取餐，广播不是为我一个人服务。广播喊到我了，我过去取就Ok了。

四、使用NIO完成网络通信

4.1NIO基础继续讲解

回到我们最开始的图：

img_e770a297e39bc8bf51675b2e69fed54d.png

NIO被叫为 no-blocking io，其实是在网络这个层次中理解的，对于FileChannel来说一样是阻塞。

我们前面也仅仅讲解了FileChannel，对于我们网络通信是还有几个Channel的~

img_948c1d5d3fa8ced4da074dc1031dce9d.png

所以说：我们通常使用NIO是在网络中使用的，网上大部分讨论NIO都是在网络通信的基础之上的！说NIO是非阻塞的NIO也是网络中体现的！

从上面的图我们可以发现还有一个Selector选择器这么一个东东。从一开始我们就说过了，nio的核心要素有：

  • Buffer缓冲区
  • Channel通道
  • Selector选择器

我们在网络中使用NIO往往是I/O模型的多路复用模型！

  • Selector选择器就可以比喻成麦当劳的广播。
  • 一个线程能够管理多个Channel的状态

img_e24735751d397bc66bb3794681a85667.png

4.2NIO阻塞形态

为了更好地理解，我们先来写一下NIO在网络中是阻塞的状态代码，随后看看非阻塞是怎么写的就更容易理解了。

  • 是阻塞的就没有Selector选择器了，就直接使用Channel和Buffer就完事了。

客户端：


public class BlockClient {

    public static void main(String[] args) throws IOException {

        // 1. 获取通道
        SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 6666));

        // 2. 发送一张图片给服务端吧
        FileChannel fileChannel = FileChannel.open(Paths.get("X:\\Users\\ozc\\Desktop\\新建文件夹\\1.png"), StandardOpenOption.READ);

        // 3.要使用NIO，有了Channel，就必然要有Buffer，Buffer是与数据打交道的呢
        ByteBuffer buffer = ByteBuffer.allocate(1024);

        // 4.读取本地文件(图片)，发送到服务器
        while (fileChannel.read(buffer) != -1) {

            // 在读之前都要切换成读模式
            buffer.flip();

            socketChannel.write(buffer);

            // 读完切换成写模式，能让管道继续读取文件的数据
            buffer.clear();
        }

        // 5. 关闭流
        fileChannel.close();
        socketChannel.close();
    }
}

服务端：


public class BlockServer {

    public static void main(String[] args) throws IOException {

        // 1.获取通道
        ServerSocketChannel server = ServerSocketChannel.open();

        // 2.得到文件通道，将客户端传递过来的图片写到本地项目下(写模式、没有则创建)
        FileChannel outChannel = FileChannel.open(Paths.get("2.png"), StandardOpenOption.WRITE, StandardOpenOption.CREATE);

        // 3. 绑定链接
        server.bind(new InetSocketAddress(6666));

        // 4. 获取客户端的连接(阻塞的)
        SocketChannel client = server.accept();

        // 5. 要使用NIO，有了Channel，就必然要有Buffer，Buffer是与数据打交道的呢
        ByteBuffer buffer = ByteBuffer.allocate(1024);

        // 6.将客户端传递过来的图片保存在本地中
        while (client.read(buffer) != -1) {

            // 在读之前都要切换成读模式
            buffer.flip();

            outChannel.write(buffer);

            // 读完切换成写模式，能让管道继续读取文件的数据
            buffer.clear();

        }

        // 7.关闭通道
        outChannel.close();
        client.close();
        server.close();
    }
}

结果就可以将客户端传递过来的图片保存在本地了：

img_82dff70ea384dafd57c818e0b76c020f.png

此时服务端保存完图片想要告诉客户端已经收到图片啦：

img_d1fb009e9170e8d1aea63a753dab5436.png

客户端接收服务端带过来的数据：

img_15af62fc52d0b36c05f48d3873696ca5.png

如果仅仅是上面的代码是不行的！这个程序会阻塞起来！

  • 因为服务端不知道客户端还有没有数据要发过来(与刚开始不一样，客户端发完数据就将流关闭了，服务端可以知道客户端没数据发过来了)，导致服务端一直在读取客户端发过来的数据。
  • 进而导致了阻塞！

于是客户端在写完数据给服务端时，显式告诉服务端已经发完数据了！

img_59a37dbc5b8e789252a8450328167980.png

4.3NIO非阻塞形态

如果使用非阻塞模式的话，那么我们就可以不显式告诉服务器已经发完数据了。我们下面来看看怎么写：

客户端：

public class NoBlockClient {

    public static void main(String[] args) throws IOException {

        // 1. 获取通道
        SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 6666));

        // 1.1切换成非阻塞模式
        socketChannel.configureBlocking(false);

        // 2. 发送一张图片给服务端吧
        FileChannel fileChannel = FileChannel.open(Paths.get("X:\\Users\\ozc\\Desktop\\新建文件夹\\1.png"), StandardOpenOption.READ);

        // 3.要使用NIO，有了Channel，就必然要有Buffer，Buffer是与数据打交道的呢
        ByteBuffer buffer = ByteBuffer.allocate(1024);

        // 4.读取本地文件(图片)，发送到服务器
        while (fileChannel.read(buffer) != -1) {

            // 在读之前都要切换成读模式
            buffer.flip();

            socketChannel.write(buffer);

            // 读完切换成写模式，能让管道继续读取文件的数据
            buffer.clear();
        }

        // 5. 关闭流
        fileChannel.close();
        socketChannel.close();
    }
}

服务端：


public class NoBlockServer {

    public static void main(String[] args) throws IOException {

        // 1.获取通道
        ServerSocketChannel server = ServerSocketChannel.open();

        // 2.切换成非阻塞模式
        server.configureBlocking(false);

        // 3. 绑定连接
        server.bind(new InetSocketAddress(6666));

        // 4. 获取选择器
        Selector selector = Selector.open();

        // 4.1将通道注册到选择器上，指定接收“监听通道”事件
        server.register(selector, SelectionKey.OP_ACCEPT);

        // 5. 轮训地获取选择器上已“就绪”的事件--->只要select()>0，说明已就绪
        while (selector.select() > 0) {
            // 6. 获取当前选择器所有注册的“选择键”(已就绪的监听事件)
            Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();

            // 7. 获取已“就绪”的事件，(不同的事件做不同的事)
            while (iterator.hasNext()) {

                SelectionKey selectionKey = iterator.next();

                // 接收事件就绪
                if (selectionKey.isAcceptable()) {

                    // 8. 获取客户端的链接
                    SocketChannel client = server.accept();

                    // 8.1 切换成非阻塞状态
                    client.configureBlocking(false);

                    // 8.2 注册到选择器上-->拿到客户端的连接为了读取通道的数据(监听读就绪事件)
                    client.register(selector, SelectionKey.OP_READ);

                } else if (selectionKey.isReadable()) { // 读事件就绪

                    // 9. 获取当前选择器读就绪状态的通道
                    SocketChannel client = (SocketChannel) selectionKey.channel();

                    // 9.1读取数据
                    ByteBuffer buffer = ByteBuffer.allocate(1024);

                    // 9.2得到文件通道，将客户端传递过来的图片写到本地项目下(写模式、没有则创建)
                    FileChannel outChannel = FileChannel.open(Paths.get("2.png"), StandardOpenOption.WRITE, StandardOpenOption.CREATE);

                    while (client.read(buffer) > 0) {
                        // 在读之前都要切换成读模式
                        buffer.flip();

                        outChannel.write(buffer);

                        // 读完切换成写模式，能让管道继续读取文件的数据
                        buffer.clear();
                    }
                }
                // 10. 取消选择键(已经处理过的事件，就应该取消掉了)
                iterator.remove();
            }
        }

    }
}

还是刚才的需求：服务端保存了图片以后，告诉客户端已经收到图片了。

在服务端上只要在后面写些数据给客户端就好了：

img_2f01c7379b2f8110126a83eb141e98e1.png

在客户端上要想获取得到服务端的数据，也需要注册在register上(监听读事件)！


public class NoBlockClient2 {

    public static void main(String[] args) throws IOException {

        // 1. 获取通道
        SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 6666));

        // 1.1切换成非阻塞模式
        socketChannel.configureBlocking(false);

        // 1.2获取选择器
        Selector selector = Selector.open();

        // 1.3将通道注册到选择器中，获取服务端返回的数据
        socketChannel.register(selector, SelectionKey.OP_READ);

        // 2. 发送一张图片给服务端吧
        FileChannel fileChannel = FileChannel.open(Paths.get("X:\\Users\\ozc\\Desktop\\新建文件夹\\1.png"), StandardOpenOption.READ);

        // 3.要使用NIO，有了Channel，就必然要有Buffer，Buffer是与数据打交道的呢
        ByteBuffer buffer = ByteBuffer.allocate(1024);

        // 4.读取本地文件(图片)，发送到服务器
        while (fileChannel.read(buffer) != -1) {

            // 在读之前都要切换成读模式
            buffer.flip();

            socketChannel.write(buffer);

            // 读完切换成写模式，能让管道继续读取文件的数据
            buffer.clear();
        }


        // 5. 轮训地获取选择器上已“就绪”的事件--->只要select()>0，说明已就绪
        while (selector.select() > 0) {
            // 6. 获取当前选择器所有注册的“选择键”(已就绪的监听事件)
            Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();

            // 7. 获取已“就绪”的事件，(不同的事件做不同的事)
            while (iterator.hasNext()) {

                SelectionKey selectionKey = iterator.next();

                // 8. 读事件就绪
                if (selectionKey.isReadable()) {

                    // 8.1得到对应的通道
                    SocketChannel channel = (SocketChannel) selectionKey.channel();

                    ByteBuffer responseBuffer = ByteBuffer.allocate(1024);

                    // 9. 知道服务端要返回响应的数据给客户端，客户端在这里接收
                    int readBytes = channel.read(responseBuffer);

                    if (readBytes > 0) {
                        // 切换读模式
                        responseBuffer.flip();
                        System.out.println(new String(responseBuffer.array(), 0, readBytes));
                    }
                }

                // 10. 取消选择键(已经处理过的事件，就应该取消掉了)
                iterator.remove();
            }
        }
    }


}

测试结果：

img_d2cb8d570e928672e0e5080b1b0af37d.png

下面就简单总结一下使用NIO时的要点：

  • 将Socket通道注册到Selector中，监听感兴趣的事件
  • 当感兴趣的时间就绪时，则会进去我们处理的方法进行处理
  • 每处理完一次就绪事件，删除该选择键(因为我们已经处理完了)

4.4管道和DataGramChannel

这里我就不再讲述了，最难的TCP都讲了，UDP就很简单了。

UDP:

img_0f62a949fff3f78e5a7ad36b49a0c503.png

img_8b3b4b872166937e18aad21f4dc2b840.png

管道：

img_337440fb58873994126972b21f624913.png

img_17b510a4dc1fb7478755dff3ca31a851.png

五、总结

总的来说NIO也是一个比较重要的知识点，因为它是学习netty的基础~

想以一篇来完全讲解NIO显然是不可能的啦，想要更加深入了解NIO可以往下面的链接继续学习~

参考资料：

如果文章有错的地方欢迎指正，大家互相交流。习惯在微信看技术文章，想要获取更多的Java资源的同学，可以关注微信公众号:Java3y。为了大家方便，刚新建了一下qq群：742919422，大家也可以去交流交流。谢谢支持了！希望能多介绍给其他有需要的朋友

文章的目录导航：

更多的文章可往： 文章的目录导航
上一篇 下一篇
优秀的个人博客,低调大师

微信关注我们

原文链接：https://yq.aliyun.com/articles/611699

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

JavaScript 编程精解 中文第三版 十八、HTTP 和表单

十八、HTTP 和表单 原文：HTTP and Forms 译者：飞龙 协议：CC BY-NC-SA 4.0 自豪地采用谷歌翻译 部分参考了《JavaScript 编程精解（第 2 版）》 通信在实质上必须是无状态的，从客户端到服务器的每个请求都必须包含理解请求所需的所有信息，并且不能利用服务器上存储的任何上下文。 Roy Fielding，《Architectural Styles and the Design of Network-based Software Architectures》 我们曾在第 13 章中提到过超文本传输协议（HTTP），万维网中通过该协议进行数据请求和传输。在本章中会对该协议进行详细介绍，并解释浏览器中 JavaScript 访问 HTTP 的方式。 协议 当你在浏览器地址栏中输入eloquentjavascript.net/18_http.html时，浏览器会首先找到和eloquentjavascript.net相关的服务器的地址，然后尝试通过 80 端口建立 TCP 连接，其中 80 端口是 HTTP 的默认通信端口。如果该服务器存在并且接受了该连接，...
2018-05-14
610
上一篇

HTML中id和name的区别（摘自网络）

HTML文本是由HTML命令组成的描述性文本，HTML命令可以说明文字、图形、动画、声音、表格、链接等。HTML的结构包括头部（Head）、主体（Body）两大部分，其中头部描述浏览器所需的信息，而主体则包含所要说明的具体内容。 name原来是为了标识之用，但是现在根据规范，都建议用id来标识元素。但是name在以下用途是不能替代的： 1. 表单（form）的控件名，提交的数据都用控件的name而不是id来控制。因为有许多name会同时对应多个控件，比如checkbox和radio，而id必须是全文档中唯一的。此外浏览器会根据name来设定发送到服务器的request。因此如果用id，服务器是无法得到数据的。 2. frame和window的名字，用于在其他frame或window指定target。 以下两者可以通用，但是强烈建议用id不要用name： 锚点，通常以前写作 <a name="myname"> 现在可以用任何的元素id来指定： <div id="myid"> 以下只能用id： 1. label与form控件的关联， <label for="M...
2018-05-14
495
下一篇

相关文章

发表评论

资源下载

更多资源
优质分享App

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

时间: 2025-12-03 大小: 4.36MB 下载: 23次
Mario

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

时间: 2025-12-12 大小: 211.28KB 下载: 54次
Spring

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

时间: 2025-12-17 大小: 5MB 下载: 1次
Rocky Linux

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

时间: 2025-12-17 大小: 1.42GB 下载: 1次
手机查看

扫码在手机上查看文章

扫描二维码，手机阅读更方便

热门标签
DeepSeek Kubernetes Docker Rocky HarmonyOS6 Jdk25 Redis SpringCloud Nacos3 Service Mesh SpringBoot4 Gemini3 OpenAi

欢迎您！

登录后，您将获得更多功能！

热门文章
联系我们

有任何问题或合作意向欢迎联系我们

Email: 99873273@qq.com

QQ: 99873273