nio

NIO

Java nio(new io)是从Java1.4版本开始引入的一个新的io api,可以替代标准的Java IO API。NIO与原来IO有同样的作用和目的。

• 面向缓存区(Buffer)
• 基于IO通道(Channel)
• 支持同步和异步
• 更高效读写

  NIO和IO的主要区别

  | IO | NIO | | :—-: | :—-: | | 面向流 | 面向缓存区 | | 同步IO | 同步IO/异步IO | | | 选择器(Selectors) |

Buffer的常用方法

直接与非直接缓冲区

非直接缓存区

直接缓存区

通道(Channel)

Java 为Channel接口提供的最主要实现类如下:

• FileChannel：用于读取、写入、映射和操作文件的通道。
• DatagramChannel：通过UDP读写网络中的数据通道。
• SocketChannel：通过TCP读写网络中的数据。
• ServerSocketChannel：可以监听新进来的TCP连接，对每一个新进来 的连接都会创建一个SocketChannel。

获取通道:

• FileInputStream.getChannel()
• FileOutputStream.getChannel()
• RandomAccessFile.getChannel()
• DatagramSocket.getChannel()
• Socket.getChannel()
• ServerSocket.getChannel()
• XXXChannel.open()

transferFrom()和transferTo()

将数据从源通道传输到其他 Channel 中,该方法操控直接内存

选择器（Selector）

选择器(Selector)是SelectableChannle对象的多路复用器,Selector可以同时监控多个SelectableChannel的IO状况,也就是说,利用Selector可使一个单独的线程管理多个Channel。Selector是非阻塞IO的核心。

SelectionKey

表示 SelectableChannel 和Selector之间的注册关系。每次向 选择器注册通道时就会选择一个事件(选择键)。选择键包含两个表示为整 数值的操作集。操作集的每一位都表示该键的通道所支持的一类可选择操 作。

代码

public class NioSocket {
    @Test
    public void sent() {
        try (SocketChannel sc = SocketChannel.open(new InetSocketAddress("127.0.0.1", 9098))) {
            sc.configureBlocking(false);
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            Scanner scanner = new Scanner(System.in);
            while (scanner.hasNext()) {
                String s = scanner.next();
                buffer.put(s.getBytes());
                buffer.flip();
                sc.write(buffer);
                buffer.clear();
            }
        } catch (IOException ignored) {
        }
    }
    @Test
    public void accept() {
        try (ServerSocketChannel sc = ServerSocketChannel.open()) {
            sc.bind(new InetSocketAddress(9098));
            sc.configureBlocking(false);
            ByteBuffer buffer = ByteBuffer.allocate(1024);
            Selector selector = Selector.open();
            sc.register(selector, SelectionKey.OP_ACCEPT);
            while (selector.select() > 0) {
                Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
                while (iterator.hasNext()) {
                    SelectionKey selectionKey = iterator.next();
                    if (selectionKey.isAcceptable()) {
                        SocketChannel socket = sc.accept();
                        socket.configureBlocking(false);
                        socket.register(selector, SelectionKey.OP_READ);
                    } else if (selectionKey.isReadable()) {
                        SocketChannel socket = (SocketChannel) selectionKey.channel();
                        while (socket.read(buffer) > 0) {
                            buffer.flip();
                            System.out.println(new String(buffer.array(),0,buffer.limit()));
                            buffer.clear();
                        }
                    }
                    iterator.remove();
                }
            }
        } catch (IOException ignored) {
        }
    }
}

OpenOption实现类