zoukankan      html  css  js  c++  java
  • nio学习四

    Selector##

    Selector(选择器)是Java NIO中能够检测一到多个NIO通道,并能够知晓通道是否为诸如读写事件做好准备的组件。这样,一个单独的线程可以管理多个channel,从而管理多个网络连接。

    为什么使用Selector?

    仅用单个线程来处理多个Channels的好处是,只需要更少的线程来处理通道。事实上,可以只用一个线程处理所有的通道。对于操作系统来说,线程之间上下文切换的开销很大,而且每个线程都要占用系统的一些资源(如内存)。因此,使用的线程越少越好。

    但是,需要记住,现代的操作系统和CPU在多任务方面表现的越来越好,所以多线程的开销随着时间的推移,变得越来越小了。实际上,如果一个CPU有多个内核,不使用多任务可能是在浪费CPU能力。不管怎么说,关于那种设计的讨论应该放在另一篇不同的文章中。在这里,只要知道使用Selector能够处理多个通道就足够了。

    Selector的创建
    通过调用Selector.open()方法创建一个Selector,如下:

    Selector selector = Selector.open();

    向Selector注册通道

    为了将Channel和Selector配合使用,必须将channel注册到selector上。通过SelectableChannel.register()方法来实现,如下:

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

    与Selector一起使用时,Channel必须处于非阻塞模式下。这意味着不能将FileChannel与Selector一起使用,因为FileChannel不能切换到非阻塞模式。而套接字通道都可以。(我理解表明这个nio适合网络编程)

    注意register()方法的第二个参数。这是一个“interest集合”,意思是在通过Selector监听Channel时对什么事件感兴趣。可以监听四种不同类型的事件:

    • Connect
    • Accept
    • Read
    • Write

    通道触发了一个事件意思是该事件已经就绪。所以,某个channel成功连接到另一个服务器称为“连接就绪”。一个server socket channel准备好接收新进入的连接称为“接收就绪”。一个有数据可读的通道可以说是“读就绪”。等待写数据的通道可以说是“写就绪”。

    这四种事件用SelectionKey的四个常量来表示:

    • SelectionKey.OP_CONNECT
    • SelectionKey.OP_ACCEPT
    • SelectionKey.OP_READ
    • SelectionKey.OP_WRITE

    如果你对不止一种事件感兴趣,那么可以用“位或”操作符将常量连接起来,如下:

    int interestSet = SelectionKey.OP_READ | SelectionKey.OP_WRITE;

    在下面还会继续提到interest集合。

    SelectionKey

    在上一小节中,当向Selector注册Channel时,register()方法会返回一个SelectionKey对象。这个对象包含了一些你感兴趣的属性:

    • interest集合
    • ready集合
    • Channel
    • Selector
    • 附加的对象(可选)
      下面描述这些属性:

    链接 :http://ifeve.com/selectors/

    FileChannel

    写文件:

    package filechannel;
    
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.nio.ByteBuffer;
    import java.nio.channels.FileChannel;
    
    public class Example02 {
    	public static void main(String[] args) throws IOException {
    		FileChannel channel=new FileOutputStream("text.txt").getChannel();
    		ByteBuffer buffer=ByteBuffer.allocate(1024);
    		buffer.clear();
    		buffer.put("测试FileChannel写".getBytes());
    		buffer.flip();
    		while(buffer.hasRemaining()){
    			channel.write(buffer);
    		}
    		
    //		channel.write(ByteBuffer.wrap("测试".getBytes()));
    	}
    }
    

    这里两种方式都可以写进去,但是需要注意一点的是写的内容必须是缓冲区能装的下的内容,如果写的内容大于了缓冲区,那么会报异常。

    链接 http://ifeve.com/file-channel/

    SocketChannel

    链接 http://ifeve.com/socket-channel/

    ServerSocketChannel

    链接 http://ifeve.com/server-socket-channel/

  • 相关阅读:
    将项目中某些常用设置做成配置项
    资产管理平台去除zabbix字样
    navicat远程连接报错
    Excel数据导入MySql数据库
    Ubuntu16.04使用命令行安装jdk1.8
    zabbix4.0配置短信报警
    整洁代码系列(2)
    找回篮球场上的快乐
    努力做人、努力学习、努力让身边的人过得更好 --2016年总结、2017年规划
    整洁代码系列(1)
  • 原文地址:https://www.cnblogs.com/joeCqupt/p/6891361.html
Copyright © 2011-2022 走看看