Java基础之《netty(5)—NIO之Selector》

news2024/11/23 11:53:45

一、基本介绍

1、Java的NIO,用非阻塞的IO方式,可以用一个线程,处理多个的客户端连接,就会使用到Selector(选择器)。

2、Selector能够检测多个注册的通道上是否有事件发生(注意:多个Channel以事件的方式可以注册到同一个Selector),如果有事件发生,便获取事件然后针对每个事件进行相应的处理。这样就可以只用一个单线程去管理多个通道,也就是管理多个连接和请求。

3、只有在连接(Channel)真正有读写事件发生时,才会进行读写,就大大地减少了系统开销,并且不必为每个连接都创建一个线程,不用去维护多个线程。

4、避免了多线程之间的上下文切换导致的开销。

二、NIO特点再说明

1、Netty的IO线程NioEventLoop聚合了Selector(选择器,也叫多路复用器),可以同时并发处理成百上千个客户端连接。

2、当线程从某客户端Socket通道进行读写数据时,若没有数据可用时,该线程可以进行其他任务。

3、线程通常将非阻塞IO的空闲时间用于在其他通道上执行IO操作,所以单独的线程可以管理多个输入和输出通道。

4、由于读写操作都是非阻塞的,这就可以充分提升IO线程的运行效率,避免由于频繁IO阻塞导致的线程挂起。

5、一个IO线程可以并发处理N个客户端连接和读写操作,这从根本上解决了传统同步阻塞IO一连接一线程模型,架构的性能、弹性伸缩能力和可靠性都得到了极大的提升。

三、Selector API介绍

1、Selector类
Selector类是一个抽象类,常用方法:
public static Selector open() throws IOException:得到一个选择器对象
public abstract int select(long timeout) throws IOException:监控所有注册的通道,当其中有IO操作可以进行时,将对应的SelectionKey加入到内部集合中并返回,参数用来设置超时时间
public abstract Set<SelectionKey> selectedKeys():从内部集合中得到所有的SelectionKey

2、继承关系

selectedKeys()方法遍历SelectionKey,通过SelectionKey反向得到Channel。SelectionKey就是和Channel关联的。

四、Selector注意事项

1、NIO中的ServerSocketChannel功能类似ServerSocket,SocketChannel功能类似Socket

2、selector相关方法说明
selector.select(); //阻塞
selector.select(1000); //阻塞1000毫秒,在1000毫秒后返回
selector.wakeup(); //唤醒selector
selector.selectNow(); //不阻塞,立马返回

五、NIO非阻塞网络编程原理分析图

NIO非阻塞网络编程相关的(Selector、SelectionKey、ServerSocketChannel和SocketChannel)关系

说明:
1、当客户端连接时,会通过ServerSocketChannel得到对应的SocketChannel
2、将SocketChannel注册到Selector上,一个Selector上可以注册多个SocketChannel

3、注册后返回一个SelectionKey,会和该Selector关联(以集合形式内联在Selector中)
4、Selector进行监听,用select()方法,返回有事件发生的通道个数
5、事件
OP_READ
OP_WRITE
OP_CONNECT
OP_ACCEPT
6、进一步得到各个SelectionKey(有事件发生的)
7、再通过SelectionKey反向获取SocketChannel
8、可以通过得到的channel,完成业务处理

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

[附源码]SSM计算机毕业设计新闻发布和评论管理系统JAVA

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…

【冰糖Python】Python 中的 assert 语句

assert 判断一个表达式的真假&#xff0c;在表达式条件为 false 的时候触发异常&#xff0c;返回错误 具体用法&#xff1a; assert expression assert expression [, arguments] 实际用例&#xff1a; 注意以上使用&#xff1a; 1、条件为True时&#xff0c;assert不执行…

基于PHP+MySQL高校教务选课系统的设计与实现

兴趣是最好的老师,只有学生选择了自己感兴趣的课程才能够更好的进行学习,目前有很多高校的选课中出现很多问题,如学生对开设的课程不了解,代选课程等等,这些问题多而繁杂,不容易解决。 本系统就是为了学生开放的在线选课系统,而网络选课系统是帮助学生了解到所学课程的内容,多自…

Android——使用ContentProvider共享数据

实验名称&#xff1a; 使用ContentProvider共享数据 实验目的&#xff1a; &#xff08;1&#xff09;能使用ContentProvider共享数据 &#xff08;2&#xff09;能使用内容观察者观察其他程序的数据变化 实验内容及原理&…

H2N-Hyp-FF-OH, 2493080-84-3

Hyp-Phe-Phe 是一种三肽&#xff0c;通过 Phe 环的芳香相互作用形成螺旋状的薄片&#xff0c;构成一个交叉螺旋结构。Hyp-Phe-Phe 具有很高的剪切压电特性&#xff0c;可作为一种压电材料。Hyp-Phe-Phe is a tripeptide that forms helical-like sheets via aromatic interacti…

Flowable定时器与实时流程图江南一点雨

1. 定时器 1.1. 流程定义定时激活 在之前松哥给小伙伴们介绍流程定义的时候&#xff0c;流程都是定义好之后立马就激活了&#xff0c;其实在流程定义的这个过程中&#xff0c;我们还可以设置一个激活时间&#xff0c;也就是流程定义好之后&#xff0c;并不会立马激活&#xf…

数据存储——存储视频

数据存储——存储视频视频的数字化一、视频采样二、视频量化总结&#xff1a;视频数字化的过程视频的数字化 1.视频是图像&#xff08;帧&#xff09;在时间上的表示 图象是离散的视频&#xff0c;视频是连续的图像 2.视频储存 每一帧图像或帧被转化为位模式并加以储存 一、视…

(3)点云数据处理学习——KD树近邻搜索

1、主要参考资料 &#xff08;1&#xff09;kd树原理 数组索引的kdtree建立及简明快速的k近邻搜索方法 &#xff08;2&#xff09;open3d 爆肝5万字 Open3D 点云数据处理基础&#xff08;Python版&#xff09;&#xff09;-技术圈 (3)视频参考 【PythonOpen3D处理点云数据…

12【MyBatis注解开发】

文章目录三、Mybatis注解开发3.1 快速入门3.1.1 常用注解说明3.1.2 注解实现开发3.2 注解实现一对一映射3.2.1 接口3.2.2 测试类3.3 注解实现一对多映射3.2.1 接口3.2.2 测试类三、Mybatis注解开发 3.1 快速入门 3.1.1 常用注解说明 注解功能Insert新增Update更新Delete删除…

创新指南|如何以STEPPS模型6招打造病毒式传播产品

从爆款产品到网络流行语&#xff0c;这种流行绝对不是依赖于运气&#xff0c;更不是神话。让人们喜欢读某些文章&#xff0c;让人们尝试某项新服务&#xff0c;甚至是投票竞选&#xff0c;这些事情的背后都有STEPPS模型的驱动&#xff0c;遵循或者仅仅应用STEPPS中的某几条&…

【毕业设计】21-基于单片机的智能恒温箱_温度报警装置设计(原理图+仿真+源代码+答辩论文+答辩PPT)

【毕业设计】21-基于单片机的智能恒温箱/温度报警装置设计&#xff08;原理图仿真源代码答辩论文答辩PPT&#xff09; 文章目录【毕业设计】21-基于单片机的智能恒温箱/温度报警装置设计&#xff08;原理图仿真源代码答辩论文答辩PPT&#xff09;任务书设计说明书摘要设计框架架…

Tomcat:servlet与servlet容器

前言 在介绍Tomcat之前&#xff0c;我们首先需要了解它的作用&#xff0c;简单的说&#xff0c;tomcat就是一个servlet容器。因此&#xff0c;本文首先从Web 应用程序开始讲起&#xff0c;逐步介绍servlet。 Web即表示网页的意思&#xff0c;它用于表示 Internet 主机上供外界访…

【Android App】GPS获取定位经纬度和根据经纬度获取详细地址讲解及实战(附源码和演示 超详细)

需要全部代码请点赞关注收藏后评论区留言私信~~~ 一、获取定位信息 开启定位相关功能只是将定位的前提条件准备好&#xff0c;若想获得手机当前所处的位置信息&#xff0c;还要依靠下列的3种定位工具。 &#xff08;1&#xff09;定位条件器Criteria 定位条件器用于设置定位的…

如何从报表控件FastReport .NET中连接到 PostgreSQL 数据库?

FastReport.NET官方版下载 Fastreport是目前世界上主流的图表控件&#xff0c;具有超高性价比&#xff0c;以更具成本优势的价格&#xff0c;便能提供功能齐全的报表解决方案&#xff0c;连续三年蝉联全球文档创建组件和库的“ Top 50 Publishers”奖。 慧都科技是Fast Repor…

Nacos注册中心和服务消费方式(服务治理)

目录 一、服务治理介绍 什么是服务治理&#xff1f; 二、nacos简介 三、nacos实战入门 1.搭建nacos环境 2.将商品、订单、微服务注册到nacos 四、实现服务调用的负载均衡 1.什么是负载均衡 2. DiscoveryClient实现负载均衡 3.Ribbon实现负载均衡 Ribbon支持的负载…

Nacos作为配置中心详解

前言 在单体架构的时候我们可以将配置写在配置文件中&#xff0c;但有⼀个缺点就是每次修改配置都需要重启服务才能生效。 当应用程序实例比较少的时候还可以维护。如果转向微服务架构有成百上千个实例&#xff0c;每修改⼀次配置要将全部实例重启&#xff0c;不仅增加了系统的…

Spring Boot FailureAnalyzer 应用场景

Spring Boot 自定义FailureAnalyzer 今天在学习Spring Boot 源码的过程中&#xff0c;在spring.factories 文件中无意中发现了FailureAnalyzer 这个接口。由于之前没有接触过&#xff0c;今天来学习一下 FailureAnalyzer 接口的作用。 在学习FailureAnalyzer之前, 我们先看以…

Spark 3.0 - 8.ML Pipeline 之决策树原理与实战

目录 一.引言 二.决策树基础-信息熵 三.决策树的算法基础 - ID3 算法 四.ML 中决策树的构建 1.信息增益计算 2.连续属性划分 五.ML 决策树实战 1.Libsvm 数据与加载 2.StringIndexer 3.VectorIndexer 4.构建决策树与 Pipeline 5.测试与评估 6.获取决策树 六.总结…

【学习笔记67】JavaScript中的闭包

一、认识函数的过程 1. 定义 在堆内存中开辟一段内存空间(XF001)把函数体的内容&#xff0c;完全百分百的照抄一份&#xff0c;存放在内存空间中(XF001)把内存空间的地址(XF001) 赋值给函数名2. 调用 根据函数名内存储的地址 (XF001) &#xff0c;去堆内存中找到对应函数会去…

Nginx安装Openresty加载Lua代码

1、下载 VM环境&#xff1a;ubuntu 16 http://openresty.org/cn/download.html 我选择的是截图红框的那个版本&#xff0c;其他高级的版本&#xff0c;我编译的时候都会报错&#xff0c;所以选择了这个版本&#xff0c;大家编译失败的时候不要放弃&#xff0c;继续选择其他版…