什么是NIO？

NIO在操作系统当前一般定义为：non-blocking io，JDK1.4开始新引入了NIO相关的类库，所以有时候人们在Java中有叫他：new io。

当你使用NIO请求时，等待客户端请求，或者等待数据的到达都不会阻塞了，而是直接返回给你一个错误信息。

简单来说就是如果socket标记为阻塞，那么accept调用就会阻塞，直接有连接到达，如果socket标记为非阻塞，并且也没有连接到达，那么就会返回一个EAGAIN或EWOULDBLOCK类型的错误。

在这里插入图片描述

代码演示

服务端代码

import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.ServerSocketChannel;import java.nio.channels.SocketChannel;import java.util.ArrayList;import java.util.Iterator;import java.util.List;public class SocketNIO {
       public static void main(String[] args) throws Exception {
           //保存所有已经连接进来的客户端        List
   
     socketChannelList = new ArrayList<>();        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();        serverSocketChannel.bind(new InetSocketAddress(9090));        serverSocketChannel.configureBlocking(false);//一定要设置为非阻塞模式        System.out.println("
    <服务端启动，并且设置为非阻塞模式！>
     ");        while (true) {
               SocketChannel accept = serverSocketChannel.accept();            if (accept == null) {
                   Thread.sleep(5000);//这里纯粹为了演示效果，实际情况下可以不需要休眠，直接快速处理后面的read事件                System.out.println("accept 没有阻塞，而是返回了null！");            } else {
                   //如果有请求到达时，设置为后续事件为非阻塞模式                System.out.println("---接受客户端连接请求，并设置为非阻塞模式！---");                accept.configureBlocking(false);//一定要设置为非阻塞模式                socketChannelList.add(accept);//添加集合中            }            ByteBuffer byteBuffer = ByteBuffer.allocateDirect(1024);            Iterator
     
       iterator = socketChannelList.iterator();            while (iterator.hasNext()) {
                   SocketChannel sc = iterator.next();                //遍历所有客户端，看看是否有数据到达，有则read大于0，没有也不会阻塞了。                try {
                       int read = sc.read(byteBuffer);                    if (read > 0) {
                           byteBuffer.flip();                        byte[] bytes = new byte[byteBuffer.limit()];                        byteBuffer.get(bytes);                        System.out.println("接收到客户端：" + sc.socket().getPort() + "，发送的数据:" + new String(bytes));                        byteBuffer.clear();                    } else {
                           System.out.println("客户端没有数据到达。。。");                    }                } catch (Exception e) {
                       System.out.println("---客户端下线---");                    byteBuffer.clear();                    iterator.remove();                }            }        }    }}

客户端代码

import java.io.*;import java.net.Socket;public class SocketCli {
       public static void main(String[] args) throws Exception {
           Socket socket = new Socket("localhost", 9090);        System.out.println("客户端启动...");        OutputStream outputStream = socket.getOutputStream();        BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));        while (true) {
               String readLine = reader.readLine();            if (readLine.equals("quit")) {
                   bufferedWriter.write(readLine);                bufferedWriter.newLine();                bufferedWriter.flush();                System.exit(-1);            } else {
                   bufferedWriter.write(readLine);                bufferedWriter.newLine();                bufferedWriter.flush();            }        }    }}

代码很简单，通过nio提供的api，可以简单的实现一个服务端单线程下不阻塞的处理多个客户端的请求。