selector简介

    最近在学习java NIO,发现java nio selector 相对 channel ,buffer 这两个概念是比较难理解的 ,把学习理解的东西以文字的东西记录下来,就像从内存落地到硬盘,把内存中内容换成该知识点的索引。
    在介绍Selector之前先明确以下3个问题:
              1、selector的作用是什么?
              2、selector如何做到网络通信的?
              下面就针对上面的2个问题来展开介绍:
           1、Selector(选择器)是Java NIO中能够检测一到多个NIO渠道,并能够知晓渠道是否为诸如读写事件做好准备的组件。这样,一个单独的线程可以管理多个channel,从而管理多个网络连接。
           2、selector 操作的过程 
           2.1 首先创建Selector
                  Selector selector = Selector.open();
           2.2 向selector注册channel,和感兴趣的事件,
                  channel.configureBlocking(false);
                  SelectionKey key = channel.register(selector,Selectionkey.OP_READ); 
                  注意register()方法的第二个参数, 这是一个interest集合,意思是在通过Selector监听Channel时对什么事件感兴趣。可以监听以下4中不同类型的事件:
                     服务端接收客户端连接事件   SelectionKey.OP_ACCEPT
                     客户端连接服务端事件   SelectionKey.OP_CONNECT
                     读事件   SelectionKey.OP_READ
                     写事件   SelectionKey.OP_WRITE
                   如果你对不止一种事件感兴趣,那么可以用“位或”操作符将常量连接起来如下:
                   SelectionKey key = channel.register(selector,Selectionkey.OP_READ|SelectionKey.OP_WRITE); 
                   当向Selector注册Channel时,registor()方法会返回一个SelectorKey对象。这个对象包含了一些你感兴趣的属性。
                            interest集合
                            ready集合
                            Channel
                            Selector
                            附加的对象(可选) 
            2.2.1 interest集合
       就像向Selector注册通道一节中所描述的,interest集合是你所选择的感兴趣的事件集合。可以通过SelectionKey读写interest集合,像这样:
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; 
  可以看到,用“位与”操作interest 集合和给定的SelectionKey常量,可以确定某个确定的事件是否在interest集合中。
    2.2.2 ready集合
   ready 集合是通道已经准备就绪的操作的集合。在一次选择(Selection)之后,你会首先访问这个ready set。Selection将在下一小节进行解释。可以这样访问ready集合:
            int readySet = selectionKey.readyOps(); 
可以用像检测interest集合那样的方法,来检测channel中什么事件或操作已经就绪。但是,也可以使用以下四个方法,它们都会返回一个布尔类型:
selectionKey.isAcceptable();  
selectionKey.isConnectable();  
selectionKey.isReadable();  
selectionKey.isWritable(); 
            2.2.3 Channel + Selector
                从SelectionKey访问Channel和Selector很简单。如下:
Channel  channel  = selectionKey.channel(); 
Selector selector = selectionKey.selector();
    2.2.4 附加对象
   可以将一个对象或者更多信息附着到SelectionKey上,这样就能方便的识别某个给定的通道。例如,可以附加 与通道一起使用的Buffer,或是包含聚集数据的某个对象。使用方法如下:
selectionKey.attach(theObject);  
                Object attachedObj = selectionKey.attachment(); 
还可以在用register()方法向Selector注册Channel的时候附加对象。如:
SelectionKey key = channel.register(selector, SelectionKey.OP_READ, theObject); 
            2.3 通过Selector选择通道
                一旦向Selector注册了一或多个通道,就可以调用几个重载的select()方法。这些方法返回你所感兴趣的事件(如连接、接受、读或写)已经准备就绪的那些通道。
换句话说,如果你对“读就绪”的通道感兴趣,select()方法会返回读事件已经就绪的那些通道。


                下面是select()方法:(该方法是阻塞方法)
 
                int select()
                int select(long timeout)
                int selectNow()
                select()阻塞到至少有一个通道在你注册的事件上就绪了。
                select(long timeout)和select()一样,除了最长会阻塞timeout毫秒(参数)。
                selectNow()不会阻塞,不管什么通道就绪都立刻返回(译者注:此方法执行非阻塞的选择操作。如果自从前一次选择操作后,没有通道变成可选择的,则此方法直接返回零。)。
                select()方法返回的int值表示有多少通道已经就绪。亦即,自上次调用select()方法后有多少通道变成就绪状态。如果调用select()方法,因为有一个通道变成就绪状态,返回了1,
若再次调用select()方法,如果另一个通道就绪了,它会再次返回1。如果对第一个就绪的channel没有做任何操作,现在就有两个就绪的通道,但在每次select()方法调用之间,只有一个通道就绪了。
                
    2.3.1 selectedKeys()
                一旦调用了select()方法,并且返回值表明有一个或更多个通道就绪了,然后可以通过调用selector的selectedKeys()方法,访问“已选择键集(selected key set)”中的就绪通道。如下所示:
                Set selectedKeys = selector.selectedKeys(); 
                当像Selector注册Channel时,Channel.register()方法会返回一个SelectionKey 对象。这个对象代表了注册到该Selector的通道。可以通过SelectionKey的selectedKeySet()方法访问这些对象。
                可以遍历这个已选择的键集合来访问就绪的通道。如下:


                Set selectedKeys = selector.selectedKeys();  
                Iterator 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();  
                } 
                这个循环遍历已选择键集中的每个键,并检测各个键所对应的通道的就绪事件。
 
                注意每次迭代末尾的keyIterator.remove()调用。Selector不会自己从已选择键集中移除SelectionKey实例。必须在处理完通道时自己移除。下次该通道变成就绪时,Selector会再次将其放入已选择键集中。
 
                SelectionKey.channel()方法返回的通道需要转型成你要处理的类型,如ServerSocketChannel或SocketChannel等。
 
                wakeUp()
 
                某个线程调用select()方法后阻塞了,即使没有通道已经就绪,也有办法让其从select()方法返回。只要让其它线程在第一个线程调用select()方法的那个对象上调用Selector.wakeup()方法即可。阻塞在select()方法上的线程会立马返回。如果有其它线程调用了wakeup()方法,但当前没有线程阻塞在select()方法上,下个调用select()方法的线程会立即“醒来(wake up)”。
 
                close()
 

                用完Selector后调用其close()方法会关闭该Selector,且使注册到该Selector上的所有SelectionKey实例无效。通道本身并不会关闭。 

             总结:1、创建Selector,

                         2、创建Channel,()

                         3、向Selector中注册Channel,及感兴趣的事件,

                         4.1、等待注册的事件到达,不然就一直等待 selector.select()

           4.2、获取selector中选中项的迭代器,选中的项为注册的事件 Iterator ite = this.selector.selectedKeys().iterator();

           4.3、针对选中的事件对感兴趣的事件进行处理。 

           5、要想快速理解selector过程,结合代码来学习。

 

             2.3.2 server端实例代码

       

                    

[java] view plain copy
  1. package com.anders.selector;  
  2.   
  3. import java.io.IOException;  
  4. import java.net.InetSocketAddress;  
  5. import java.nio.ByteBuffer;  
  6. import java.nio.channels.SelectableChannel;  
  7. import java.nio.channels.SelectionKey;  
  8. import java.nio.channels.Selector;  
  9. import java.nio.channels.ServerSocketChannel;  
  10. import java.nio.channels.SocketChannel;  
  11. import java.util.Iterator;  
  12. import java.util.Set;  
  13.   
  14. public class NIOServer {  
  15.     // 通道管理器  
  16.     private Selector selector;  
  17.   
  18.     public void initServer(int port) throws Exception {  
  19.         // 获得一个ServerSocket通道  
  20.         ServerSocketChannel serverChannel = ServerSocketChannel.open();  
  21.         // 设置通道为 非阻塞  
  22.         serverChannel.configureBlocking(false);  
  23.         // 将该通道对于的serverSocket绑定到port端口  
  24.         serverChannel.socket().bind(new InetSocketAddress(port));  
  25.         // 获得一耳光通道管理器  
  26.         this.selector = Selector.open();  
  27.   
  28.         // 将通道管理器和该通道绑定,并为该通道注册selectionKey.OP_ACCEPT事件  
  29.         // 注册该事件后,当事件到达的时候,selector.select()会返回,  
  30.         // 如果事件没有到达selector.select()会一直阻塞  
  31.   
  32.         serverChannel.register(selector, SelectionKey.OP_ACCEPT);  
  33.     }  
  34.   
  35.     // 采用轮训的方式监听selector上是否有需要处理的事件,如果有,进行处理  
  36.     public void listen() throws Exception {  
  37.         System.out.println("start server");  
  38.         // 轮询访问selector  
  39.         while (true) {  
  40.             // 当注册事件到达时,方法返回,否则该方法会一直阻塞  
  41.             selector.select();  
  42.             // 获得selector中选中的相的迭代器,选中的相为注册的事件  
  43.             Iterator ite = this.selector.selectedKeys().iterator();  
  44.             while (ite.hasNext()) {  
  45.                 SelectionKey key = (SelectionKey) ite.next();  
  46.                 // 删除已选的key 以防重负处理  
  47.                 ite.remove();  
  48.                 // 客户端请求连接事件  
  49.                 if (key.isAcceptable()) {  
  50.                     ServerSocketChannel server = (ServerSocketChannel) key.channel();  
  51.                     // 获得和客户端连接的通道  
  52.                     SocketChannel channel = server.accept();  
  53.                     // 设置成非阻塞  
  54.                     channel.configureBlocking(false);  
  55.                     // 在这里可以发送消息给客户端  
  56.                     channel.write(ByteBuffer.wrap(new String("hello client").getBytes()));  
  57.                     // 在客户端 连接成功之后,为了可以接收到客户端的信息,需要给通道设置读的权限  
  58.                     channel.register(this.selector, SelectionKey.OP_READ);  
  59.                     // 获得了可读的事件  
  60.   
  61.                 } else if (key.isReadable()) {  
  62.                     read(key);  
  63.                 }  
  64.   
  65.             }  
  66.         }  
  67.     }  
  68.   
  69.     // 处理 读取客户端发来的信息事件  
  70.     private void read(SelectionKey key) throws Exception {  
  71.         // 服务器可读消息,得到事件发生的socket通道  
  72.         SocketChannel channel = (SocketChannel) key.channel();  
  73.         // 穿件读取的缓冲区  
  74.         ByteBuffer buffer = ByteBuffer.allocate(10);  
  75.         channel.read(buffer);  
  76.         byte[] data = buffer.array();  
  77.         String msg = new String(data).trim();  
  78.         System.out.println("server receive from client: " + msg);  
  79.         ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());  
  80.         channel.write(outBuffer);  
  81.     }  
  82.   
  83.     public static void main(String[] args) throws Throwable {  
  84.         NIOServer server = new NIOServer();  
  85.         server.initServer(8989);  
  86.         server.listen();  
  87.     }  

 

            2.3.3 client 实例代码

 

                           

[java] view plain copy
    1. package com.anders.selector;  
    2.   
    3. import java.io.IOException;  
    4. import java.net.InetSocketAddress;  
    5. import java.nio.ByteBuffer;  
    6. import java.nio.channels.SelectionKey;  
    7. import java.nio.channels.Selector;  
    8. import java.nio.channels.SocketChannel;  
    9. import java.util.Iterator;  
    10.   
    11. public class NIOClient {  
    12.   
    13.     // 通道管理器  
    14.     private Selector selector;  
    15.   
    16.     /** 
    17.      * * // 获得一个Socket通道,并对该通道做一些初始化的工作 * @param ip 连接的服务器的ip // * @param port 
    18.      * 连接的服务器的端口号 * @throws IOException 
    19.      */  
    20.     public void initClient(String ip, int port) throws IOException { // 获得一个Socket通道  
    21.         SocketChannel channel = SocketChannel.open(); // 设置通道为非阻塞  
    22.         channel.configureBlocking(false); // 获得一个通道管理器  
    23.         this.selector = Selector.open(); // 客户端连接服务器,其实方法执行并没有实现连接,需要在listen()方法中调  
    24.         // 用channel.finishConnect();才能完成连接  
    25.         channel.connect(new InetSocketAddress(ip, port));  
    26.         // 将通道管理器和该通道绑定,并为该通道注册SelectionKey.OP_CONNECT事件。  
    27.         channel.register(selector, SelectionKey.OP_CONNECT);  
    28.     }  
    29.   
    30.     /** 
    31.      * * // 采用轮询的方式监听selector上是否有需要处理的事件,如果有,则进行处理 * @throws // IOException 
    32.      * @throws Exception  
    33.      */  
    34.     @SuppressWarnings("unchecked")  
    35.     public void listen() throws Exception { // 轮询访问selector  
    36.         while (true) {  
    37.             // 选择一组可以进行I/O操作的事件,放在selector中,客户端的该方法不会阻塞,  
    38.             // 这里和服务端的方法不一样,查看api注释可以知道,当至少一个通道被选中时,  
    39.             // selector的wakeup方法被调用,方法返回,而对于客户端来说,通道一直是被选中的  
    40.             selector.select(); // 获得selector中选中的项的迭代器  
    41.             Iterator ite = this.selector.selectedKeys().iterator();  
    42.             while (ite.hasNext()) {  
    43.                 SelectionKey key = (SelectionKey) ite.next(); // 删除已选的key,以防重复处理  
    44.                 ite.remove(); // 连接事件发生  
    45.                 if (key.isConnectable()) {  
    46.                     SocketChannel channel = (SocketChannel) key.channel(); // 如果正在连接,则完成连接  
    47.                     if (channel.isConnectionPending()) {  
    48.                         channel.finishConnect();  
    49.                     } // 设置成非阻塞  
    50.                     channel.configureBlocking(false);  
    51.                     // 在这里可以给服务端发送信息哦  
    52.                     channel.write(ByteBuffer.wrap(new String("hello server!").getBytes()));  
    53.                     // 在和服务端连接成功之后,为了可以接收到服务端的信息,需要给通道设置读的权限。  
    54.                     channel.register(this.selector, SelectionKey.OP_READ); // 获得了可读的事件  
    55.                 } else if (key.isReadable()) {  
    56.                     read(key);  
    57.                 }  
    58.             }  
    59.         }  
    60.     }  
    61.   
    62.     private void read(SelectionKey key) throws Exception {  
    63.         SocketChannel channel = (SocketChannel) key.channel();  
    64.         // 穿件读取的缓冲区  
    65.         ByteBuffer buffer = ByteBuffer.allocate(10);  
    66.         channel.read(buffer);  
    67.         byte[] data = buffer.array();  
    68.         String msg = new String(data).trim();  
    69.         System.out.println("client receive msg from server:" + msg);  
    70.         ByteBuffer outBuffer = ByteBuffer.wrap(msg.getBytes());  
    71.         channel.write(outBuffer);  
    72.   
    73.     }  
    74.   
    75.     /** 
    76.      * * // 启动客户端测试 * @throws IOException 
    77.      * @throws Exception  
    78.      */  
    79.     public static void main(String[] args) throws Exception {  
    80.         NIOClient client = new NIOClient();  
    81.         client.initClient("localhost", 8989);  
    82.         client.listen();  
    83.     }  
    84. }  

转载于:https://www.cnblogs.com/panxuejun/p/8631784.html

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

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

相关文章

java随机数排序算法_理解快速排序算法

快速排序在平均状况下,排序n个项目要Ο(n log n)次比较。在最坏状况下则需要Ο(n^2)次比较,但这种状况并不常见。事实上,快速排序通常明显比 其他Ο(n log n)算法更快,因为它的内部循环(inner loop)可以在大部分的架构上很有效率地…

开课吧视频内容汇总

1. 前端读取文件内容, FileReader对象 2. 用户联网状态 3. application/x-www-form-urlencoded 参数序列化 (具体借鉴jquery的$.param方法),后端接收到的数据格式是 a[0][a] 1,并不会将其整理成对象或者数组 var nextStr ;funct…

PhantomJS宣布终止开发

由于没有人贡献代码,我很快就要把这个项目归档了。也许未来的某一天,我又想开发了,还会重新启动起来。既然决定停止开发了,那么自然地,PhantomJS 2.5 和原定的 PhantomJS2.1.x 就告吹了。对应的,这两个版本…

Servlet和JSP中的文件上传示例

使用Servlet和JSP将文件上传到服务器是Java Web应用程序中的常见任务。 在对Servlet或JSP进行编码以处理文件上传请求之前&#xff0c;您需要了解一点有关HTML和HTTP协议中文件上传支持的知识。 如果要让用户从文件系统中选择文件并上传到服务器&#xff0c;则需要使用<inpu…

20165312-第4周-课上内容补做以及知识点总结

20165312-第4周-课上内容补做以及知识点总结 1、课上内容补做 教材代码完成情况测试p45这题很快就做完了&#xff0c;然后忘记提交了。。就开始做递归。想起来的时候已经过了时间。 public class Example3_7 {public static void main(String args[]) {int sum0,i,j;for(i1;i&l…

java入门就是死敲代码吗_JAVA入门第二季综合练习(直接思考敲的代码,面向过程,不好)...

package com.imocc;/*author ndh2016年3月27日 21:03:02*/import java.util.Scanner;public class DiDi {public static void main(String[] args){Scanner sc new Scanner(System.in);System.out.println("欢迎使用迪迪租车系统&#xff01;");System.out.println(…

JavaScript实现表单的全选,反选,获取值

构思 通过for循环和for in循环来实现&#xff0c;界面效果如下 步骤 全选&#xff1a; 循环给所有的表单设置checked 反选&#xff1a; 循环内判断checked是否为true&#xff0c;如果为true则改为false否则改为true 获取值&#xff1a; 最开始用for取&#xff0c;但是只打印最后…

jQuery.extend() 使用语法详解

今天在写插件&#xff0c;使用$.extend({}, defaults, options)的时候发现漏写了 {}&#xff0c;浪费了一些时间&#xff0c; 所以详细记录下该方法的 API 和使用。API 如下&#xff1a;jQuery.extend( [ deep ], target, [ object1 ], [ objectN ] )描述&#xff1a;合并两个或…

EJB钝化和激活示例

在本教程中&#xff0c;我们将了解状态Java企业会话Bean中激活和钝化的工作方式。 1.简介 有状态会话Bean通常保存有关特定客户端的信息&#xff0c;并在整个会话中保存该信息。 但是&#xff0c;事实是&#xff0c;客户端会话往往会在相当长的时间内保持活动状态&#xff0c;…

Python进阶_面对对象面对过程

这节主要讲面对对象与面对过程两种编程思想的主要区别。 一. 简单对比 面向过程是一种基础的方法&#xff0c;它考虑的是实际的实现步骤&#xff0c;一般情况下&#xff0c;面向过程是自顶向下逐步求精&#xff0c;其最重要的是模块化的思想方法。 面向对象的方法主要是把事物给…

puppet 安装mysql_Puppet安装dashboard

Puppet安装dashboard安装依赖包[rootmaster ~]# sudo yum install -y mysql mysql-devel mysql-server ruby ruby-devel ruby-irb ruby-mysql ruby-rdoc ruby-ri启动mysql并设置开机启动[rootmaster ~]# service mysqld start [rootmaster ~]# chkconfig mysqld on下载并安装…

命令模式详解

原文链接:https://www.cnblogs.com/java-my-life/archive/2012/06/01/2526972.html 在阎宏博士的《JAVA与模式》一书中开头是这样描述命令&#xff08;Command&#xff09;模式的&#xff1a; 命令模式属于对象的行为模式。命令模式又称为行动(Action)模式或交易(Transaction)模…

JDK 8中几乎命名的方法参数

有时在Java中命名方法参数确实很不错&#xff0c;这看起来可能不会出现很长时间了&#xff0c;但是始终还有其他一些解决方法&#xff0c;例如使用构建器模式来获得类似的行为&#xff0c;这将为一点点。 在我看来&#xff0c;使用JDK 8中的Lambda支持可以使您获得非常接近的效…

深入解析jQuery中的延时对象的概念

首先我们需要明白延时对象有什么用&#xff1f;第一个作用&#xff0c;解决时序以及动态添加执行函数的问题。function a(){alert(1)};function b(){alert(2)};function c(){alert(3)};a();setTimeout(function(){b();},0);c();很明显函数执行顺序是a->c->b,而不是按照函…

c mysql5.7_CentOS7下MySQL5.7的三种安装方式详解

操作系统环境&#xff1a;CentOS 7.4最小化安装[rootnode3 src]# cat /etc/redhat-releaseCentOS Linux release 7.4.1708 (Core)[rootnode3 ~]# uname -r3.10.0-693.5.2.el7.x86_64[rootnode3 ~]#安装版本为&#xff1a;MySQL 5.7.20一、编译安装MySQL5.71、下载源码包[rootno…

Struts2 学习之小白开始

Struts2 基础知识学习总结 Struts2 概述&#xff1a;Struts2 是一个用来开发 MVC 应用程序的框架&#xff0c;他提供了 Web 应用程序开发过程中的一些常见问题的解决方案&#xff0c;比如对于用户输入信息合法性的验证&#xff0c;统一的布局&#xff0c;国际化等&#xff0c;既…

机器学习的数学基础 - 信息论

机器学习的数学基础 - 信息论 信息论 信息论本来是通信中的概念&#xff0c;但是其核心思想“熵”在机器学习中也得到了广泛的应用。比如决策树模型ID3&#xff0c;C4.5中是利用信息增益来划分特征而生成一颗决策树的&#xff0c;而信息增益就是基于这里所说的熵。所以它的重要…

了解ElasticSearch分析器

令人遗憾的是&#xff0c;许多早期的互联网啤酒配方不一定采用易于消化的格式。 也就是说&#xff0c;这些食谱是通常在电子邮件或论坛帖子中最初组成的非结构化的方向和成分混合列表。 因此&#xff0c;尽管很难轻松地将这些配方放入传统的数据存储中&#xff08;表面上看是为…

c++简单程序设计-2

1.验证性实验部分①函数声明和函数定义各自的作用及二者的区别&#xff1a;函数声明就是调用函数之前提示一下有这个函数函数定义就是写一个函数②什么是形参&#xff1f;什么是实参&#xff1f;函数参数和返回值在函数中起到什么作用&#xff1f;函数定义时写的参数叫做形参&a…

java 同步的方法_关于Java中的同步方法

我有一个关于Java中方法同步的问题.考虑一个具有3个同步方法的类.class MyClass{public synchronized void methodA(){ ... }public synchronized void methodB(){ ... }public synchronized void methodC(){ ... }}考虑myObject,myClass的一个实例.以下内容哪些是对的&#xf…