Java专题十一（2）：NIO

标签：exception   tor   字节流   except   硬件   不可   pos   一个   令行   

Java专题十一（2）：NIO

0. NIO是什么

Non-blocking IO（非阻塞IO）

NIO可以让你非阻塞的使用IO，当线程从通道读取数据到缓冲区时，线程还是可以进行其他事情。当数据被写入到缓冲区时，线程可以继续处理它。从缓冲区写入通道也类似。

1. 通道Channel

通道代表面向实体的开放式连接，执行读写等IO操作，其中实体包括硬件设备，文件，网络套接字等

通道Channel与缓冲区Buffer密不可分，不同于IO从字符或字节流中读写操作，Channel既可以从Buffer中读取数据，也可以写入数据到Buffer中

类图关系如下：

• Channel
  • InterruptibleChannel
    • FileChannel
    • SelectableChannel：能与选择器Selector结合实现多路IO复用
      • SocketChannel
      • ServerSocketChannel
      • DatagramChannel
  • ReadableByteChannel：读取Channel数据到Buffer中, int read(ByteBuffer dst)
  • WritableByteChannel：写入Buffer数据到Channel中, int write(ByteBuffer src)

Channel中一些重要方法：

2. 缓冲区Buffer

相当于内存块，可读可写

类图关系如下：

• Buffer
  • ByteBuffer：
    • HeapByteBuffer
  • CharBuffer：
  • ShortBuffer：
  • IntBuffer：
  • LongBuffer：
  • FloatBuffer：
  • DoubleBuffer：
• DirectBuffer
  • DirectByteBuffer

ByteBuffer中一些重要方法：

capacity、position、limit说明：

• capacity：缓冲区的大小，最多可以存放capacity个数据
• position：写模式下，代表写入了多少个数据，使用flip()切换为读模式时，position设为0
• limit：读模式下，代表能读取到的数据大小，使用flip()切换为读模式时，limit设为position

3. 选择器Selector

一个Selector可以处理多个Channel，通常与SelectableChannel类型的Channel结合使用

Selector中一些重要方法：

4.一个完整示例

import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;

public class Server {
    public static void main(String[] args) throws Exception{
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.socket().bind(new InetSocketAddress("127.0.0.1", 8017));
        Selector selector = Selector.open();
        serverSocketChannel.configureBlocking(false);
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
        while(true){
            selector.select();
            Set selectionKeys = selector.selectedKeys();
            Iterator iterator = selectionKeys.iterator();
            while(iterator.hasNext()){
                SelectionKey key = iterator.next();
                if(key.isAcceptable()){
                    System.out.println("key.isAcceptable()");
                    iterator.remove();
                    SocketChannel socketChannel = ((ServerSocketChannel)key.channel()).accept();
                    socketChannel.configureBlocking(false);
                    socketChannel.register(selector, SelectionKey.OP_READ);
                }else if(key.isReadable()){
                    System.out.println("key.isReadable()");
                    iterator.remove();
                    SocketChannel socketChannel = (SocketChannel)key.channel();
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    socketChannel.read(buffer);
                    System.out.println(new String(buffer.array()));
                    socketChannel.register(selector, SelectionKey.OP_WRITE);
                }else if(key.isWritable()){
                    System.out.println("key.isWritable()");
                    iterator.remove();
                    SocketChannel socketChannel = (SocketChannel)key.channel();
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    buffer.put(new String("i am server!!!").getBytes());
                    socketChannel.write(buffer);
                    System.out.println(new String(buffer.array()));
                    socketChannel.register(selector, SelectionKey.OP_READ);
                }
            }
        }
    }
}

1. 运行Server.java
2. 在CMD命令行输入telnet 127.0.0.1 8017 ，换行，输入ab
3. 控制台输出如下：

key.isAcceptable()
key.isReadable()
a                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                               
key.isWritable()
i am server!!!                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                  
key.isReadable()
b                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                               
key.isWritable()
i am server!!!       

Java专题十一（2）：NIO

标签：exception   tor   字节流   except   硬件   不可   pos   一个   令行   

原文地址：https://www.cnblogs.com/myibu/p/12775637.html