Java-NIO篇章（4）——Selector选择器详解

Selector介绍

选择器（Selector）是什么呢？选择器和通道的关系又是什么？这里详细说明，假设不用选择器，那么一个客户端请求数据传输那就需要建立一个连接，为了避免线程阻塞，那么每个客户端开辟一个线程。而学过JVM的都知道，默认每开一个线程需要栈空间内存1MB大小。如果这时候有大量的客户端连接请求，那么这个内存占用是非常可怕的，而且开辟大量的线程将导致CPU频繁上下文切换，效率非常低。举个例子，我们的服务器就是一家餐厅，客户端就是顾客，餐厅为顾客服务，如果每来一个客人（客户端请求）我们就派一个服务员（线程）那么这样消耗是消耗不起的。最正常的逻辑是，餐厅只招聘一个服务员（一个线程），然后通过一个监控器（Selector）监控所有顾客的需求（监控IO事件），如果哪个顾客需要服务就喊一下（这个信号就是下面的IO事件），然后服务员就跑过去为他服务。这样虽然一个线程很累，但是只需要一个线程就可以处理大量的socket连接，参考Redis单线程模式设计就知道一个线程如果专心处理非阻塞不耗时的业务是非常非常快的。借用一张网图非常清楚地描述了Selector、Channel、Buffer三个核心组件的关系，如下图所示：
在这里插入图片描述

来一段专业的介绍：选择器的使命是完成IO的多路复用，其主要工作是通道的注册、监听、事件查询。一个通道代表一条连接通路，通过选择器可以同时监控多个通道的IO（输入输出）状况。选择器和通道的关系，是监控和被监控的关系。 选择器提供了独特的API方法，能够选出（select）所监控的通道已经发生了哪些IO事件，包括读写就绪的IO操作事件。 一般是一个单线程处理一个选择器，一个选择器可以监控很多通道。所以，通过选择器，一个单线程可以处理数百、数千、数万、甚至更多的通道。在极端情况下（数万个连接），只用一个线程就可以处理所有的通道，这样会大量地减少线程之间上下文切换的开销。

先介绍什么是IO事件吧，这里的IO事件不是对通道的IO操作，而是通道处于某个IO操作的就绪状态，表示通道具备执行某个IO操作的条件。 比方说某个SocketChannel传输通道，如果完成了和对端的三次握手过程，则会发生“连接就绪” （OP_CONNECT）的事件。再比方说某个ServerSocketChannel服务器连接监听通道，在监听到一个新连接的到来时，则会发生“接收就绪”（OP_ACCEPT）的事件。还比方说，一个SocketChannel通道有数据可读，则会发生“读就绪”（OP_READ）事件；一个等待写入数据的SocketChannel通道，会发生写就绪（OP_WRITE）事件。这里注意，只有FileChannel文件通道不可用被选择器监控或选择的。其他的三个通道都可以被Selector监控。

通道和选择器之间的关联，通过register（注册）的方式完成。调用通道的Channel.register （Selector selector， int ops）方法，可以将通道实例注册到一个选择器中。 register方法有两个参数：第一个参数，指定通道注册到的选择器实例； 第二个参数，指定选择器要监控的IO事件类型。可供选择器监控的通道IO事件类型，包括以下四种：

  • 可读： SelectionKey.OP_READ
  • 可写：SelectionKey.OP_WRITE
  • 连接：SelectionKey.OP_CONNECT
  • 接收： SelectionKey.OP_ACCEPT

以上的事件类型常量定义在SelectionKey类中。如果选择器要监控通道的多种事件，可以用“按位或”运算符来实现。例如，同时监控可读和可写IO事件：

//监控通道的多种事件，用“按位或”运算符来实现
int key = SelectionKey.OP_READ | SelectionKey.OP_WRITE ;

SelectionKey选择键

通道和选择器的监控关系， 本质是一种多对一的关联关系。 一个选择器Selector可以监控多个通道Channel，那么如何区分不同的Channel呢？很简单，给每个Channel取一个唯一的名字就行，这个名字就是SelectionKey，这样就可以维护不同的Channel了。Selector并不直接去管理Channel，而是直接管理SelectionKey，通过SelectionKey与Channel发生关系。一个Channel最多能向Selector注册一次，注册之后就形成了唯一的SelectionKey， 然后被Selector管理起来。 Selector有一个核心成员keys，专门用于管理注册上来的SelectionKey， Channel注册到Selector后所创建的那一个唯一的SelectionKey，添加在这个keys成员中，这是一个HashSet类型的集合。 除了成员keys之外， Selector还有一个核心成员selectedKeys，用于存放已经发生了IO事件的SelectionKey。怎么样？绕晕了吗？别慌，看下面的图：

在这里插入图片描述

SelectionKey是IO事件的记录者（或存储者） ， SelectionKey 有三个核心成员，一个是关联的Channel通道，另外两个分别存储着自己关联的Channel上的感兴趣IO事件和已经发生的IO事件。Channel通道上可以发生多种IO事件，比如说读就绪事件、写就绪事件、新连接就绪事件，但是SelectionKey记录事件的成员却是一个整数类型。 这样问题就来了，一个整数如何记录多个事件呢？答案是，通过比特位来完成的。 具体的IO事件所占用的哪一个比特位，通过常量的方式定义在SelectionKey中， 如下：

//读取就绪事件，第 0 位
public static final int OP_READ = 1 << 0;
//写入就绪事件，第 2 位
public static final int OP_WRITE = 1 << 2;
//传输通道建立成功的 IO 事件，第 3 位
public static final int OP_CONNECT = 1 << 3;
//新连接就绪事件，第 4 位
public static final int OP_ACCEPT = 1 << 4;

通过SelectionKey的interestOps成员上相应的比特位，可以设置、查询关联的Channel所感兴趣的IO事件；通过SelectionKey的readyOps上相应的比特位，可以查询关联Channel所已经发生的IO事件。 对于interestOps成员上的比特位， 应用程序是可以设置的；但是对于readyOps上的比特位，应用程序只能查询，不能设置。因为，readyOps上的比特位是已经发生了的IO事件，只能由客户端被动触发，不能主动设置。readyOps发生的IO事件只能是Channel感兴趣的interestOps中的IO事件。通道和选择器的监控关系注册成功后， Selector就可以查询就绪事件。具体的查询操作，是通过调用选择器Selector的select( )系列方法来完成。通过select系列方法，可以不断地查询通道中所发生操作的就绪状态（或者IO事件） ， 并且把这些发生了底层IO事件，转换成Java NIO中的IO事件，记录在的通道关联的SelectionKey的readyOps上。除此之外，发生了IO事件的SelectionKey，还会记录在Selector内部selectedKeys集合中。简单来说， 一旦在通道中发生了某些IO事件（就绪状态达成），这个事件就被记录在SelectionKey的readyOps上，并且这个SelectionKey被记录在Selector内部的selectedKeys集合中。（1） 通道必须在Selector注册过；（2） 所发生的事件必须是SelectionKey上interestOps成员记录的事件。

使用Selector选择器

使用选择器，主要有以下三步：

  • 获取选择器实例；
  • 将通道注册到选择器中；
  • 轮询感兴趣的IO就绪事件（选择键集合）。

第一步：获取选择器实例。选择器实例是通过调用静态工厂方法open()来获取的，具体如下：

//调用静态工厂方法 open()来获取 Selector 实例
Selector selector = Selector.open();

第二步：将通道注册到选择器实例。要实现选择器管理通道，需要将通道注册到相应的选择器上，简单的示例代码如下：

// 2.获取通道
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
// 3.设置为非阻塞
serverSocketChannel.configureBlocking(false);
// 4.绑定连接
serverSocketChannel.bind(new InetSocketAddress(18899));
// 5.将通道注册到选择器上,并制定监听事件为：“接收连接”事件
serverSocketChannel.register(selector， SelectionKey.OP_ACCEPT);

这里需要注意：注册到选择器的通道，必须处于非阻塞模式下，否则将抛出IllegalBlockingModeException异常。还需要注意：一个通道，并不一定要支持所有的四种IO事件。例如服务器监听通道ServerSocketChannel，仅仅支持Accept（接收到新连接） IO事件；而传输通道SocketChannel则不同，该类型通道仅不支持Accept类型的IO事件。

第三步：选出感兴趣的IO就绪事件（选择键集合）。通过Selector选择器的select()方法 ，选出已经注册的、已经就绪的IO事件，并且保存到SelectionKey选择键集合中。 SelectionKey集合保存在选择器实例内部，其元素为SelectionKey类型实例。调用选择器的selectedKeys()方法，可以取得选择键集合。

//轮询，选择感兴趣的 IO 就绪事件（选择键集合）
while (selector.select() > 0) {Set selectedKeys = selector.selectedKeys();Iterator keyIterator = selectedKeys.iterator();while(keyIterator.hasNext()) {SelectionKey key = keyIterator.next();//根据具体的 IO 事件类型，执行对应的业务操作if(key.isAcceptable()) {// IO 事件： ServerSocketChannel 服务器监听通道有新连接} else if (key.isConnectable()) {// IO 事件：传输通道连接成功} else if (key.isReadable()) {// IO 事件：传输通道可读} else if (key.isWritable()) {// IO 事件：传输通道可写}//处理完成后，移除选择键keyIterator.remove();}
}

处理完成后，需要将选择键从这个SelectionKey集合中移除，防止下一次循环的时候，被重复的处理。 SelectionKeys集合不能添加元素。select()方法的返回值的是整数类型（int），表示发生了IO事件的数量。更准确地说，是从上一次select到这一次select之间，有多少通道发生了IO事件，更加准确地说，是指发生了选择器感兴趣（注册过）的IO事件数。

用于选择就绪的IO事件的select()方法，有多个重载的实现版本，具体如下：

  • select()：阻塞调用，一直到至少有一个通道发生了注册的IO事件。
  • select(long timeout)：和select()一样，但最长阻塞时间为timeout指定的毫秒数。
  • selectNow()：非阻塞，不管有没有IO事件，都会立刻返回。

常用的是select()：阻塞调用，因为如果没有IO事件发生的话CPU就不用在那儿空旋了，这样大大减少了系统消耗。

客户端连接服务器并发送数据例子

下面将举例将上面介绍的三个核心组件以一个案例的形式综合运用，代码如下：

首先是服务端的代码：

public class SelectorServer {public static void main(String[] args) throws IOException {// 1.创建selector,管理多个channelSelector selector = Selector.open();// ServerSocketChannel 可以获取连接通道和套接字通道ServerSocketChannel ssc = ServerSocketChannel.open();ssc.configureBlocking(false);//开启非阻塞时连接，影响的只是 channel.accept();// 2. 建立selector与channel之间的联系(注册channel)// （事件有四种：accept 有连接请求时触发 、connect 客户端建立后触发的事件、read 可读事件、write 可写事件）// sscKey 代表了 ssc连接通道与selector的关联关系SelectionKey sscKey = ssc.register(selector, SelectionKey.OP_ACCEPT, null);sscKey.interestOps(SelectionKey.OP_ACCEPT); // 表示 ssc通道 只关注 accept 事件log.debug("sscKey:"+sscKey);ssc.bind(new InetSocketAddress(8080)); // 服务器程序的端口号，ip为本机ipwhile (true){//3. select 方法，发生了上述事件才会向下继续执行，否则阻塞// selector 在事假未被处理时会将事件重新加入，因此一个事件要么处理要么取消，不能置之不理// 如果没有事件则阻塞，如果有事件未被处理则不会被阻塞，不处理需要selectorKey.cancel();取消事件selector.select(); //4. 处理事件 , 获取所有发生的事件// 获取所有注册的channel的key，可以拿到key访问channelSet<SelectionKey> selectionKeys = selector.selectedKeys(); Iterator<SelectionKey> iter = selectionKeys.iterator();while (iter.hasNext()){SelectionKey selectionKey = iter.next();iter.remove(); // 拿到了立即移除,处理完了只标记不删除，需要remove删除log.debug("Key:"+selectionKey);try{if(selectionKey.isAcceptable()){// 如果是连接就绪事件，那就获取对应的ServerSocketChannel，// 然后在接受获得可以数据传输的SocketChannel// 通过key获取channelServerSocketChannel channel = (ServerSocketChannel) selectionKey.channel(); SocketChannel sc = channel.accept(); // 处理事件、 前面设置了非阻塞，没有连接就返回nullsc.configureBlocking(false); //开启非阻塞读，影响的只是 channel.read(buffer);SelectionKey scKey = sc.register(selector, SelectionKey.OP_READ, null);//其实上面第二个参数已经绑定了感兴趣的IO事件，这行不写也行,或者下面这行保留，上面第二个参数给0就行scKey.interestOps(SelectionKey.OP_READ);log.debug("SocketChannel:"+sc);} else if (selectionKey.isReadable()) {// 如果是可读事件，那么就读取内容SocketChannel channel = (SocketChannel) selectionKey.channel();ByteBuffer buffer = ByteBuffer.allocate(1024);int read = channel.read(buffer);if(-1==read){// 如果客户端正常断开则读到的数据无，返回-1System.out.println("客户端主动断开...");selectionKey.cancel();}else {buffer.flip();CharBuffer charBuffer = StandardCharsets.UTF_8.decode(buffer);String msg = charBuffer.toString();System.out.println("客户端发来的信息：" + msg);}}else {selectionKey.cancel(); // 标记已处理}}catch (IOException e){e.printStackTrace();selectionKey.cancel();}}ssc.close();}}
}

其次是客户端的代码：

public class Client {public static void main(String[] args) throws IOException {SocketChannel sc = SocketChannel.open();sc.connect(new InetSocketAddress("localhost",8080));sc.configureBlocking(false);System.out.println("waiting......");while(!sc.finishConnect()){// 没有连接完成时等待Thread.yield();}System.out.println("客户端连接成功！");ByteBuffer byteBuffer = ByteBuffer.allocate(1024);byteBuffer.put("Hello world".getBytes());// 发送到服务器byteBuffer.flip();sc.write(byteBuffer);// 下面断开操作会触发一读事件sc.shutdownOutput();sc.close(); }
}

注意：客户端突然断开会触发一个IO事件，并且服务器会抛出异常，需要捕获异常并且cancel()取消掉这个事件。如果客户端主动正常close()断开也会让Selector查询到一个读事件，也需要处理取消该事件。 如果不处理则Selector则一直会有事件未处理，则不会被阻塞一直死循环。

在NIO中，服务器接收新连接的工作，是异步进行的。不像Java的OIO那样，服务器监听连接，是同步的、阻塞的。 NIO可以通过选择器（也可以说成：多路复用器），后续不断地轮询选择器的选择键集合，选择新到来的连接。 有了Linux底层的epoll支持，以及Java NIO Selector选择器等等应用层IO复用技术， Java程序从而可以实现IO通信的高TPS、高并发，使服务器具备并发数十万、数百万的连接能力。 Java的NIO技术非常适合用于高性能、高负载的网络服务器。鼎鼎大名的通信服务器中间件Netty，就是基于Java的NIO技术实现的。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/638130.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【Linux】进程间通信——system V 共享内存、消息队列、信号量

【Linux】进程间通信——system V 共享内存、消息队列、信号量

需要云服务器等云产品来学习Linux的同学可以移步/–>腾讯云<–/官网&#xff0c;轻量型云服务器低至112元/年&#xff0c;优惠多多。&#xff08;联系我有折扣哦&#xff09; 文章目录 写在前面1. 共享内存1.1 共享内存的概念1.2 共享内存的原理1.3 共享内存的使用1.3.1 …
阅读更多...
磁盘分区机制

磁盘分区机制

lsblk查看分区 Linux分区 挂载的经典案例 1. 虚拟机增加磁盘 点击这里&#xff0c;看我的这篇文章操作 添加之后&#xff0c;需要重启系统&#xff0c;不重启在系统里看不到新硬盘哦 出来了&#xff0c;但还没有分区 2. 分区 还没有格式化 3. 格式化磁盘 4. 挂载 5. 卸载…
阅读更多...
国标GB28181安防视频监控EasyCVR级联后上级平台视频加载慢的原因排查

国标GB28181安防视频监控EasyCVR级联后上级平台视频加载慢的原因排查

国标GB28181协议安防视频监控系统EasyCVR视频综合管理平台&#xff0c;采用了开放式的网络结构&#xff0c;可以提供实时远程视频监控、视频录像、录像回放与存储、告警、语音对讲、云台控制、平台级联、磁盘阵列存储、视频集中存储、云存储等丰富的视频能力&#xff0c;同时还…
阅读更多...
一、用户管理中心——前端初始化

一、用户管理中心——前端初始化

一、Ant Design Pro初始化 1.创建空文件夹 2.打开Ant Design Pro官网 3.打开终端进行初始化 在终端输入npm i ant-design/pro-cli -g 在终端输入pro create myapp 选择umi3 选择simple 项目创建成功后&#xff0c;在文件夹中出现myapp 4.安装依赖 使用vscode打开项目 …
阅读更多...
STL中的stack、queue以及deque

STL中的stack、queue以及deque

目录 一、关于deque容器&#xff08;双端队列&#xff09; 1、deque的底层实现 2、deque的缺点 3、关于stack与squeue默认使用deque容器 二、stack简介 1、stack的成员函数&#xff08;接口&#xff09; 2、stack的模拟实现 三、queue简介 1、queue的成员函数&#xff08…
阅读更多...
安全防御-基础认知

安全防御-基础认知

目录 安全风险能见度不足&#xff1a; 常见的网络安全术语 &#xff1a; 常见安全风险 网络的基本攻击模式&#xff1a; 病毒分类&#xff1a; 病毒的特征&#xff1a; 常见病毒&#xff1a; 信息安全的五要素&#xff1a; 信息安全的五要素案例 网络空间&#xff1a…
阅读更多...
docker配置阿里云镜像加速器

docker配置阿里云镜像加速器

1、阿里云镜像加速器地址获取&#xff1a; 2、配置ECS镜像加速器&#xff0c;重启docker mkdir -p /etc/docker tee /etc/docker/daemon.json <<-EOF {"registry-mirrors": ["https://2lg9kp55.mirror.aliyuncs.com"] } EOF sudo systemctl daemon-…
阅读更多...
谈判(贪心算法)

谈判(贪心算法)

题目 import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Scanner;public class Main {public static void main(String[] args) { Scanner sc new Scanner(System.in);int n sc.nextInt();sc.nextLine();List<Integ…
阅读更多...
H3C交换机S6850配置M-LAG三层转发

H3C交换机S6850配置M-LAG三层转发

正文共&#xff1a;1999 字 30 图&#xff0c;预估阅读时间&#xff1a;3 分钟 前面提到M-LAG是一种跨设备链路聚合技术&#xff0c;将两台物理设备在聚合层面虚拟成一台设备来实现跨设备链路聚合&#xff0c;从而提供设备级冗余保护和流量负载分担。 之前已经做了DRNI的三层转…
阅读更多...
微前端小记

微前端小记

步骤 将普通的项目改造成 qiankun 主应用基座&#xff0c;需要进行三步操作&#xff1a; 1. 创建微应用容器 - 用于承载微应用&#xff0c;渲染显示微应用&#xff1b; a. 设置路由routeb.主应用的布局包括&#xff1a; 主应用菜单&#xff0c;用于渲染菜单主应用渲染区域&a…
阅读更多...
ubuntu安装vm和Linux

ubuntu安装vm和Linux

1、下载Ubuntu Index of /releaseshttps://old-releases.ubuntu.com/releases/ 2、下载VMware 官方正版VMware下载&#xff08;16 pro&#xff09;&#xff1a;https://www.aliyundrive.com/s/wF66w8kW9ac 下载Linux系统镜像&#xff08;阿里云盘不限速&#xff09;&#xff…
阅读更多...
webpack 核心武器：loader 和 plugin 的使用指南（上）

webpack 核心武器：loader 和 plugin 的使用指南（上）

&#x1f90d; 前端开发工程师、技术日更博主、已过CET6 &#x1f368; 阿珊和她的猫_CSDN博客专家、23年度博客之星前端领域TOP1 &#x1f560; 牛客高级专题作者、打造专栏《前端面试必备》 、《2024面试高频手撕题》 &#x1f35a; 蓝桥云课签约作者、上架课程《Vue.js 和 E…
阅读更多...
Twisted Circuit洛谷绿题题解

Twisted Circuit洛谷绿题题解

Twisted Circuit 题面翻译 读入四个整数 0 0 0 或者 1 1 1&#xff0c;作为如图所示的电路图的输入。请输出按照电路图运算后的结果。 感谢PC_DOS 提供的翻译 题目描述 输入格式 The input consists of four lines, each line containing a single digit 0 or 1. 输出格…
阅读更多...
读书笔记之《万物起源》：宇宙与人类的极简史

读书笔记之《万物起源》：宇宙与人类的极简史

《万物起源&#xff1a;从宇宙大爆炸到文明的兴起》讲述了从大爆炸直到今日&#xff0c;约140亿年间所有重大事物的起源&#xff0c;依次覆盖了量子力学&#xff0c;天体物理学&#xff0c;化学&#xff0c;行星科学&#xff0c;地质学&#xff0c;生物学和人类历史等等学科。 …
阅读更多...
08- OpenCV：形态学操作（膨胀与腐蚀 、提取水平与垂直线）

08- OpenCV：形态学操作（膨胀与腐蚀 、提取水平与垂直线）

目录 前言 一、膨胀&#xff08;Dilation&#xff09;与 腐蚀&#xff08;Erosion&#xff09; 二、形态学操作 1、开操作&#xff08;Opening&#xff09; 2、闭操作&#xff08;Closing&#xff09; 3、形态学梯度&#xff08;Morphological Gradient&#xff09; 4、…
阅读更多...
Spring成长之路—Spring MVC

Spring成长之路—Spring MVC

在分享SpringMVC之前&#xff0c;我们先对MVC有个基本的了解。MVC(Model-View-Controller)指的是一种软件思想&#xff0c;它将软件分为三层&#xff1a;模型层、视图层、控制层 模型层即Model&#xff1a;负责处理具体的业务和封装实体类&#xff0c;我们所知的service层、poj…
阅读更多...
LLM之RAG实战（十九）| 利用LangChain、OpenAI、ChromaDB和Streamlit构建RAG

LLM之RAG实战（十九）| 利用LangChain、OpenAI、ChromaDB和Streamlit构建RAG

生成式人工智能以其创造与上下文相关内容的能力彻底改变了技术&#xff0c;开创了人工智能可能性的新时代。其核心是检索增强生成&#xff08;RAG&#xff09;&#xff0c;将信息检索与LLM相结合&#xff0c;从外部文档中产生智能、知情的响应。 本文将深入研究使用ChromaDB构建…
阅读更多...
三.Winform使用Webview2加载本地HTML页面

三.Winform使用Webview2加载本地HTML页面

Winform使用Webview2加载本地HTML页面 往期目录创建Demo2界面创建HTML页面在Demo2窗体上添加WebView2和按钮加载HTML查看效果 往期目录 往期相关文章目录 专栏目录 创建Demo2界面 经过前面两小节 一.Winform使用Webview2(Edge浏览器核心) 创建demo(Demo1)实现回车导航到指定…
阅读更多...
广和通AI解决方案“智”赋室外机器人迈向新天地！

广和通AI解决方案“智”赋室外机器人迈向新天地！

大模型趋势下&#xff0c;行业机器人将具备更完善的交互与自主能力&#xff0c;逐步迈向AI 2.0时代&#xff0c;成为人工智能技术全面爆发的重要基础。随着行业智能化&#xff0c;更多机器人应用将从“室内”走向“室外”&#xff0c;承担更多高风险、高智能工作。复杂的室外环…
阅读更多...
代码随想录二刷 ｜ 二叉树 ｜ 把二叉搜索树转换为累加树

代码随想录二刷 ｜ 二叉树 ｜ 把二叉搜索树转换为累加树

代码随想录二刷 &#xff5c; 二叉树 &#xff5c; 把二叉搜索树转换为累加树 题目描述解题思路递归法迭代法 代码实现递归法迭代法 题目描述 538.把二叉搜索树转换为累加树 给出二叉 搜索 树的根节点&#xff0c;该树的节点值各不相同&#xff0c;请你将其转换为累加树&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023