效果展示

原理分析

NIO: 非阻塞型 IO

自从 jdk 1.4 之后，增加了 nio 库，支持非阻塞型 IO 操作

代码展示

package NIO;

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;

/**
 * ClassName: NioServer <br/>
 * Description: <br/>
 * date: 2021/8/20 15:17<br/>
 *
 * @author yiqi<br />
 * @since JDK 1.8
 */
public class NioServer {
    //保存客户端连接
    static List<SocketChannel> channelList = new ArrayList<>();

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

        // 创建 NIO ServerSocketChannel，与 BIO ServerSocket 类似
        ServerSocketChannel serverSocket = ServerSocketChannel.open();
        serverSocket.socket().bind(new InetSocketAddress(9000));
        // 设置 ServerSocketChannel 为非阻塞
        serverSocket.configureBlocking(false);
        System.out.println("服务启动成功");

        while (true) {
            // 非阻塞模式 accept 方法不会阻塞，否则会阻塞
            // NIO 的非阻塞是由操作系统内部实现的，底层调用了 Linux 内核的 accept 函数
            SocketChannel socketChannel = serverSocket.accept();
            // 如果有客户端进行连接
            if (socketChannel != null) {
                System.out.println("连接成功");
                // 设置 SocketChannel 为非阻塞
                socketChannel.configureBlocking(false);
                // 保存客户端连接在 List 中
                channelList.add(socketChannel);
            }

            // 遍历连接进行数据读取
            Iterator<SocketChannel> iterator = channelList.iterator();
            while (iterator.hasNext()) {
                SocketChannel sc = iterator.next();
                ByteBuffer byteBuffer = ByteBuffer.allocate(128);
                // 非阻塞模式 read 方法不会阻塞，否则会阻塞
                int len = sc.read(byteBuffer);
                // 如果有数据，把数据打印出来
                if (len > 0){
                    System.out.println("接收到消息：" + new String(byteBuffer.array(),0,len));
                }else if (len == -1){
                    //当连接客户端 断开连接的时候返回值为 -1，没有传数据是 0
                    iterator.remove(); //这句话是移除当前序列
                    System.out.println("客户端断开连接");
                }
            }
        }
    }
}

缺点

虽然这种方式不阻塞了，但是，如果有10万个连接 可是只有 100 个在发数据，那你还是得遍历这10万个连接 来找到这发数据的100个，性能不好。