Java NIO学习系列三:Selector

  前面的两篇文章中总结了Java NIO中的两大基础组件Buffer和Channel的相关知识点,在NIO中都是通过Channel和Buffer的协作来读写数据的,在这个基础上通过selector来协调多个channel以同时读写数据,本文我们就来学习一下selector。

  Java NIO中引入了"selector"的概念,一个selector其实是一个Java对象,能够通过诸如连接打开、数据就绪等事件监控多个channel。如此在单个线程中就可以通过一个selector同时处理多个channel,同样也可以同时处理多个网络连接。

  本文会围绕如下几个方面展开:

  为什么要有selector

  创建selector及注册channel

  SelectionKey

  从Selector中选择Channels  

  Selector的一些其他操作

  总结

 

1. 为什么要有selector

  利用单个线程处理多个channel的好处是可以减少线程的数量,节省开销。实际上,可以只用一个线程处理所有的channels。因为线程间的切换是很耗费操作系统资源的一项操作,并且每个线程都要占用一定操作系统资源(内存)。因此,线程数量当然是越少越好,而通过引入selector的概念可以显著减少线程的数量,同时又不会减少系统处理的连接数,可以简单理解为吞吐量。

  如下示例解释了一个Selector处理3个Channel:

2. 创建selector及注册channel

  通过调用Selector的静态方法open()来创建一个selector对象:

Selector selector = Selector.open();

  要让Selector处理Channel就需要先将Channel注册到Selector中,可以通过调用SelectableChannel.register()方法完成:

channel.configureBlocking(false);
SelectionKey key = channel.register(selector, SelectionKey.OP_READ);

  Channel必须处于非阻塞模式下才能被Selector所使用,因此FileChannel不能为Selector所用,因为它不能切换到非阻塞模式。Socket channels则支持这种工作模式,通过channel的configureBlocking()方法设置其工作模式是阻塞还是非阻塞式。

  register()的第二个参数是一个set集合(interest set),用来指代那些Selector有兴趣监听的事件。一共有四种事件类型:

  • Connect
  • Accept
  • Read
  • Write

  一个channel触发了某一事件其实是代表着它的某些状态已经就绪,四种事件类型分别对应如下四种情况:

  • 一个channel成功和服务器连接上就是"connect ready",由SelectionKey.OP_CONNECT指代;
  • 一个server socket channel接受了一个连接就称为"accept ready",由SelectionKey.OP_ACCEPT指代;
  • 一个channel中数据准备好了被读就是"read ready",由SelectionKey.OP_READ指代;
  • 一个channel可供写入数据就是"write ready",由SelectionKey.OP_WRITE指代;

   通过这种传参的方式,我们可以指定selector监听channel哪些事件,如果需要同时表示多种事件,则可以如下方式来表示:

int interestSet = SelectionKey.OP_READ | SelectionKey.OP_WRITE; 

 

3. SelectionKey

  如上一部分所示,当往Selector中注册一个Channel时,register()方法会返回一个SelectionKey对象,其包含了如下属性:

  • The interest set
  • The ready set
  • The Channel
  • The Selector
  • An attached object (optional)

3.1 Interest Set

  可以通过如下方法读写Interest Set:

int interestSet = selectionKey.interestOps();
boolean isInterestedInAccept  = interestSet & SelectionKey.OP_ACCEPT;
boolean isInterestedInConnect = interestSet & SelectionKey.OP_CONNECT;
boolean isInterestedInRead    = interestSet & SelectionKey.OP_READ;
boolean isInterestedInWrite   = interestSet & SelectionKey.OP_WRITE;

  可以看到,采用的是与的方式来判断一个指定的event是否在interestSet中

3.2 Ready Set

  这个指代channel就绪的操作的集合。在selection之后就能够获得一个ready set(这个selection稍后会介绍到),可以通过如下方式获取:

int readySet = selectionKey.readyOps();

  可以通过如下方式判断是否就绪:

selectionKey.isAcceptable();
selectionKey.isConnectable();
selectionKey.isReadable();
selectionKey.isWritable();

3.3 Channel + Selector

  通过如下方式来获取channel和selector:

Channel  channel  = selectionKey.channel();
Selector selector = selectionKey.selector();

3.4 Attaching Objects

  可以给SelectionKey附带对象,这是一个手动标记一个channel的方式,或者是给channel附带更多信息的方式。你可以附带和channel连接的Buffer或者别的对象,使用方式如下:

// 可以这样搞
selectionKey.attach(theObject);
Object attachedObj = selectionKey.attachment();// 也可以这样搞
SelectionKey key = channel.register(selector, SelectionKey.OP_READ, theObject);

 

4. 从Selector中选择Channels

  当你往Selector中注册了多个channel时,你可以调用select()方法用以获取感兴趣且就绪的channel,该方法有如下三种重载格式:

int select()
int select(long timeout)
int selectNow()
  • select()会一直阻塞,直到有一个channel就绪;
  • select(long timeout)只会阻塞一段指定的时间(单位为ms),直到有channel就绪;
  • selectNow()不会阻塞,不管是否有channel就绪都会立即返回;

  返回的int值指代有多少channel就绪(是从上一次调用select()之后开始算起)。比如调用select(),返回1,再次调用select(),这时又有一个channel就绪,此时任然是返回1。

4.1 selectedKeys()

  当调用了一次select()方法并且返回一个int值,这时你可以通过"selected key set"来获取这些就绪的channels:

Set<SelectionKey> selectedKeys = selector.selectedKeys(); 

  通过调用selectedKeys()方法,返回的是一个Set,你可以遍历以获取就绪的channel:

Set<SelectionKey> selectedKeys = selector.selectedKeys();
Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
while(keyIterator.hasNext()) { SelectionKey key = keyIterator.next();if(key.isAcceptable()) {// a connection was accepted by a ServerSocketChannel.} else if (key.isConnectable()) {// a connection was established with a remote server.} else if (key.isReadable()) {// a channel is ready for reading} else if (key.isWritable()) {// a channel is ready for writing
    }keyIterator.remove();
}

   通过判断其对应的事件类型来做对应的操作。

 

5. Selector的一些其他操作

5.1 wakeUp()

  线程调用Selector的select()方法之后会阻塞,在这种情况下可以通过另一个线程调用同一个Selector的wakeup()方法来将其唤醒。如果一个线程调用了Selector的wakeup方法但是当前并没有线程阻塞,则下一个调用Selector的select()方法的线程则不会阻塞(还记得不,前面讲到select()方法会一直阻塞)。

5.2 close()

  当使用完了Selector,需要调用其close()方法来释放资源,该方法会关闭Selector并使所有相关的SelectionKey失效,但是和Selector相关的channel并不会被关闭。

5.3 一个例子

  开启一个Selector,往其中注册一个channel,并且一直监控:

Selector selector = Selector.open();
channel.configureBlocking(false);
SelectionKey key = channel.register(selector, SelectionKey.OP_READ);
while(true) {int readyChannels = selector.selectNow();if(readyChannels == 0) continue;Set<SelectionKey> selectedKeys = selector.selectedKeys();Iterator<SelectionKey> keyIterator = selectedKeys.iterator();while(keyIterator.hasNext()) {SelectionKey key = keyIterator.next();if(key.isAcceptable()) {// a connection was accepted by a ServerSocketChannel.} else if (key.isConnectable()) {// a connection was established with a remote server.} else if (key.isReadable()) {// a channel is ready for reading} else if (key.isWritable()) {// a channel is ready for writing
    }keyIterator.remove();}
}

 

6. 总结

  本文简单总结了Java NIO中的Selector,有了Selector,我们可以实现多路复用,通过少量的线程来监控大量的连接,实现更高性能的服务器,很多现代服务器中都采用了这一特性,比如Tomcat、netty。

  我们可以往Selector中注册一些Channel,并且指定我们需要监听的事件类型,然后监控这些channel,一旦获取到就绪的事件,则可以执行下一部的操作,这就是一个Selector处理channel的基本流程。

 

转载于:https://www.cnblogs.com/volcano-liu/p/11066885.html

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

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

相关文章

Java JTable3

预览&#xff1a; 代码 &#xff1a; /*** */ package com.han;import java.awt.Color; import java.awt.GridLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.MouseAdapter; import java.awt.event.MouseEvent; imp…

关于ASCII字符的那些事儿

1、单字符一般用单引号加一个字符表示&#xff0c;比如字符1表示为‘1’&#xff0c;而数字1直接表示为1&#xff1b; char ch 1 ;int num 1;2、计算机用数字来存储字符&#xff0c;比如字符1&#xff0c;在计算机里面为49&#xff08;十进制&#xff09;&#xff1b;而数字…

JqueryMobile学习之二---对话框

对话框 通过在链接中添加data-rel”dialog”的属性&#xff0c;可以使链接页面的显示方式变为对话框。给显示的对话框加入切换的效果也是一个不错的选择 例如我们将about的链接变成一个对话框并加入相应的切换效果。代码如下 <p><a href"#about" data-rel&q…

“leave the world behind”十一快乐出行

这个十一你打算怎么过&#xff1f;每天睡到自然醒&#xff0c;然后闷在家里埋头上网&#xff1f;选择晴朗好天气出去逛街&#xff0c;四处淘宝贝&#xff0c;淘美食&#xff1f;还是选择一个好的路线出去玩一周&#xff1f;其实行无论宅着还是选择出行&#xff0c;一定要让自己…

分享一个文件上传工具类

文件上传状态枚举类&#xff1a; View Code 1 package com.hoo.enums;2 3 4 5 /**6 7 * <b>function:</b> 文件上传状态8 9 * package com.hoo.enums 10 11 * fileName UploadState.java 12 13 * createDate 2010-10-11 下午1…

静态库和动态库的区别

库是写好的&#xff0c;现有的&#xff0c;成熟的&#xff0c;可以复用的代码。现实中每个程序都要依赖很多基础的底层库&#xff0c;不可能每个人的代码都从零开始&#xff0c;因此库的存在意义非同寻常。 本质上来说&#xff0c;库是一种可执行代码的二进制形式&#xff0c;可…

257. Binary Tree Paths

1、问题描述 2、代码&#xff08;非本人所写&#xff0c;十分精彩的C代码&#xff09; int pathsNum(struct TreeNode* root); void Traverse(struct TreeNode* root, char** array, char* spre, int* pindex); char* stringAdd(char* s, int val);char** binaryTreePaths(stru…

HDOJ树形DP专题之Centroid

题目链接 这题跟Balance Act那题差不多&#xff0c;求图的质点。我直接将那题改了一下提交&#xff0c;结果PE了一次&#xff0c;又WA了一次&#xff0c;最后发现是单case&#xff0c;多case的提交为什么WA呢&#xff1f; View Code 1 #include <stdio.h>2 #include <…

LAMP平台--部署Discuz论坛

环境&#xff1a;为了推广公司的产品并为客户服务提供一个交流平台&#xff0c;公司购买了一套Discuz论坛系统&#xff0c;要求安装到现有的LAMP服务器中&#xff0c;并简单划分论坛版块。需求&#xff1a;部署论坛服务器&#xff0c;安装Discuz论坛系统添加新区和版块产品发布…

ACM中java快速入门

2019独角兽企业重金招聘Python工程师标准>>> ACM中java快速入门 附&#xff1a; Chapter I. Java的优缺点各种书上都有&#xff0c;这里只说说用Java做ACM-ICPC的特点&#xff1a; (1) 最明显的好处是&#xff0c;学会Java&#xff0c;可以参加Java Challenge …

OV7725的帧率和PCLK寄存器设置

一、OV7725的PCLK的改变和以下几个寄存器有关&#xff1a; 1&#xff1a;OX0D&#xff08;COM4&#xff09;&#xff1b; ------------------------------------------------------------------------------------------------------------------ 0X0D COM4 41 …

演示:两台交换机成环后的STP计算原则

演示&#xff1a;两台交换机成环后的STP计算原则演示目标&#xff1a;理解两台交换机成环后&#xff0c;STP的计算原则&#xff0c;重点理解PID的作用。演示环境&#xff1a;如下图7.49所示。演示背景&#xff1a;上图所示的环境为两台交换机的生成树环境&#xff0c;其中S1有较…

引水入城

最近在搞提高组的题,这是某天早上给的T1 T1最难还行 原题目 最近考试考多了就是见题打暴力,打搜索, 然而这题真是搜索, 但是并不能只搜索,会T,没亲测,但一定有效 这并不是考试题,所以看看标签(理直气壮的理由) 是BFS啊... 那就用DFS吧 这里的DP一开始看没有什么感觉,但是做着做…

程序员必知8大排序3大查找(一)

每天都在叫嚣自己会什么技术&#xff0c;什么框架&#xff0c;可否意识到你每天都在被这些新名词、新技术所迷惑&#xff0c;.NET、XML等等技术固然诱人&#xff0c;可是如果自己的基础不扎实&#xff0c;就像是在云里雾里行走一样&#xff0c;只能看到眼前&#xff0c;不能看到…

最详细的U-BOOT源码分析及移植

本文从以下几个方面粗浅地分析u-boot并移植到FS2410板上&#xff1a; 1、u-boot工程的总体结构 2、u-boot的流程、主要的数据结构、内存分配。 3、u-boot的重要细节&#xff0c;主要分析流程中各函数的功能。 4、基于FS2410板子的u-boot移植。实现了NOR Flash和NAND Flash启动,…

织梦教程

/************************************************************************************************************************************************** 织梦 文件说明 很详细 http://bbs.admin5.com/thread-1952932-1-1.html /****************************************…

TinyXML:一个优秀的C++ XML解析器

2019独角兽企业重金招聘Python工程师标准>>> 读取和设置xml配置文件是最常用的操作&#xff0c;试用了几个C的XML解析器&#xff0c;个人感觉TinyXML是使用起来最舒服的&#xff0c;因为它的API接口和Java的十分类似&#xff0c;面向对象性很好。 TinyXML是一个开源…

《C++标准程序库》学习笔记5 — 第七章

1.(P252) 迭代器的分类及其能力&#xff1a;input迭代器只能读取元素一次。如果复制input迭代器&#xff0c;并使原迭代器和新产生副本都向前读取&#xff0c;可能会遍历到不同的值。output迭代器类似。 2.(P258) C不允许修改任何基本类型&#xff08;包括指针&#xff09;的暂…

Android无线调试——抛开USB数据线

开发Android的朋友都知道&#xff0c;真机调试需要把手机与PC相连&#xff0c;然后把应用部署到真机上进行安装和调试。长长的USB线显得很麻烦&#xff0c;而且如果需要USB接口与其他设备连接的话显得很不方便。今天介绍一种不通过USB线就可以进行真机调试的方法。首先让手机与…

VS2017动态链接库(.dll)的生成与使用

这里以VS2017为例子&#xff0c;讲解一下动态链接库&#xff08;.dll&#xff09;的生成与使用。 一、动态链接库&#xff08;.dll&#xff09;的生成 1、打开&#xff1a;“文件”-“新建”-“项目” 2、打开&#xff1a;“已安装”-“模板”-“Visual C”-“Win32”-“Win3…