当前位置: 首页 > 编程笔记 >

深入了解java NIO之Selector(选择器)

欧阳俊逸
2023-03-14
本文向大家介绍深入了解java NIO之Selector(选择器),包括了深入了解java NIO之Selector(选择器)的使用技巧和注意事项,需要的朋友参考一下

这一节我们将探索选择器(selectors)。选择器提供选择执行已经就绪的任务的能力,这使得多元 I/O 成为可能。就像在第一章中描述的那样,就绪选择和多元执行使得单线程能够有效率地同时管理多个 I/O 通道(channels)。C/C++代码的工具箱中,许多年前就已经有 select()和 poll()这两个POSIX(可移植性操作系统接口)系统调用可供使用了。许过操作系统也提供相似的功能,但对Java 程序员来说,就绪选择功能直到 JDK 1.4 才成为可行的方案。

下面我们来使用选择器:

通过 Selector.open()方法, 我们可以创建一个选择器:

Selector selector = Selector.open();

将 Channel 注册到选择器中:

channel.configureBlocking(false);

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

注意, 如果一个 Channel 要注册到 Selector 中, 那么这个 Channel 必须是非阻塞的, 即channel.configureBlocking(false);因为 Channel 必须要是非阻塞的, 因此 FileChannel 不能够使用选择器, 因为 FileChannel 都是阻塞的.

注意到, 在使用 Channel.register()方法时, 第二个参数指定了我们对 Channel 的什么类型的事件感兴趣, 这些事件有:

  • Connect, 即连接事件(TCP 连接), 对应于SelectionKey.OP_CONNECT
  • Accept, 即确认事件, 对应于SelectionKey.OP_ACCEPT
  • Read, 即读事件, 对应于SelectionKey.OP_READ, 表示 buffer 可读.
  • Write, 即写事件, 对应于SelectionKey.OP_WRITE, 表示 buffer 可写.

一个 Channel发出一个事件也可以称为 对于某个事件, Channel 准备好了. 因此一个 Channel 成功连接到了另一个服务器也可以被称为 connect ready.

我们可以使用或运算|来组合多个事件, 例如:

int interestSet = SelectionKey.OP_READ | SelectionKey.OP_WRITE;

注意, 一个 Channel 仅仅可以被注册到一个 Selector 一次, 如果将 Channel 注册到 Selector 多次, 那么其实就是相当于更新 SelectionKey 的 interest set. 例如:

channel.register(selector, SelectionKey.OP_READ);
channel.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE);

上面的 channel 注册到同一个 Selector 两次了, 那么第二次的注册其实就是相当于更新这个 Channel 的 interest set 为 SelectionKey.OP_READ | SelectionKey.OP_WRITE.

但是Java NIO的selector允许一个单一线程监听多个channel输入。我们可以注册多个channel到selector上,然后然后用一个线程来挑出一个处于可读或者可写状态的channel。selector机制使得单线程管理多个channel变得容易。

下面我们写一个完整的例子,看一下Selector的用法:

//创建选择器
Selector selector = Selector.open();
channel.configureBlocking(false);
//注册通道
SelectionKey key = channel.register(selector, SelectionKey.OP_READ);
while(true) {
  //查看selector中的key是否准备好
  int readyChannels = selector.select();
  //小于0超时,等于0没准备好,大于0已经准备完毕
  if(readyChannels == 0) continue;
  //获取选择器中的key
  Set<SelectionKey> selectedKeys = selector.selectedKeys();
  Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
  while(keyIterator.hasNext()) {
    SelectionKey key = keyIterator.next();
    //遍历已选择键集中的每个键,并检测各个键所对应的通道的就绪事件
    if(key.isAcceptable()) {
      // 连接已经被ServerSocketChannel所接受
    } else if (key.isConnectable()) {
      // 连接已经被远程终止.
    } else if (key.isReadable()) {
      // 通道已经准备好读数据
    } else if (key.isWritable()) {
      // 通道已经准备好写数据
    }
    keyIterator.remove();
  }
}

选择器的使用还有很多的细节,我们应该多查看api文档了解各个方法的用法。下一节我们做一个综合练习,总结一下NIO的使用。

以上就是深入了解java NIO之Selector(选择器)的详细内容,更多关于java nio Selector(选择器)的资料请关注小牛知识库其它相关文章!

 类似资料:
  • 问题内容: 我正在将项目的语法切换到Swift 2.2(xCode可以帮助我自动完成);但是,我不理解新语法。 举个例子: 这有选择器 这意味着什么?您可以将其他变量添加到此选择器吗?说,。 与早期版本的Swift的基于字符串的实现相比,此语法有何不同的一般信息将受到极大的赞赏。 问题答案: 括号中的位是一种用于标识所需选择器的参数列表的机制。 我建议您查看Swift Evolution 的“ 通

  • 本文向大家介绍深入理解$.each和$(selector).each,包括了深入理解$.each和$(selector).each的使用技巧和注意事项,需要的朋友参考一下 $.each:该方法用于遍历任何集合,包括数组和对象 $(selector).each:该方法用于遍历Jquery对象 语法:$.each(obj,callback,args) ①遍历数组 var arry = ["a","b"

  • Selector是Java NIO中的一个组件,用于检查一个或多个NIO Channel的状态是否处于可读、可写。如此可以实现单线程管理多个channels,也就是可以管理多个网络链接。 为什么使用Selector(Why Use a Selector?) 用单线程处理多个channels的好处是我需要更少的线程来处理channel。实际上,你甚至可以用一个线程来处理所有的channels。从操作

  • 对用爬取信息的解析,我们在之前已经介绍了正则re、Xpath、Beautiful Soup和PyQuery。 而Scrapy还给我们提供自己的数据解析方法,即Selector(选择器)。 Selector(选择器)是基于lxml来构建的,支持XPath、CSS选择器以及正则表达式,功能全面,解析速度和准确度非常高。 3.1 直接使用: Selector(选择器)是一个可以独立使用模块。 直接导入模

  • logstash 已经拥有数以百计的插件,并提供了一站式的部署方式,极大的方便了新手入门。但在实际运用上,我们终究会碰上其他人还没碰到过,或者碰到过但没公布出来完整解决方案的问题。可能是某些环境适配,可能是某个环节的性能不佳,可能是某处硬编码设置不合理,等等等等。这时候,了解一些 logstash 的代码逻辑,了解 logstash 之所以做出当前选择的缘由。是有助于解决实际问题的。 此外,log

  • 主要内容:1 为什么要使用选择器?,2 创建一个选择器,3 向选择器注册频道,4 选择键,5 通过选择器选择频道,6 wakeup()方法,7 close()方法,8 完整的选择器示例Java NIO的选择器(Selector)是一个组件,可以选择一个或多个通道(Channel) 实例,并确定准备好进行读取或写入的通道。这样,单个线程可以管理多个通道(Channel),从而可以管理多个网络连接。 1 为什么要使用选择器? 仅使用单个线程来处理多个通道的优点是您需要更少的线程来处理通道。实际上,您