NIO

姜同学

发布于 2022-10-27 16:49:21

2790

发布于 2022-10-27 16:49:21

文章被收录于专栏：姜同学姜同学

一.概述

1.NIO的作用：传输数据

2.Java中IO的分类

a.BIO:同步阻塞式IO
b.NIO:同步非阻塞式IO
c.AIO:异步非阻塞式IO,jdk1.8出现，AIO本身是在NIO的
基础上进行了改变,因此AIO称之为NIO.2，但是因为出现
的太晚，所以市面上没有成熟的框架.所以你懂得。

3.NIO包含三个组件:Buffer(缓冲区),Channel(通道),Selector(多路复用选择器)

二.BIO的缺点

1.阻塞式IO,效率很低。

2.一对一连接:每一个客户端发起一个连接都会在服务端产生一个线程取处理这个连接，如果出现大量的连接，服务端线程资源耗尽，服务器就会产生卡顿甚至崩溃。

3.如果一个连接不产生任何操作而保持这个连接，服务器也不会释放。

三.缓冲区-Buffer

1.作用：存储数据

2.在NIO中，Buffer针对基本类型进行存储：ByteBuffer，ShortBuffer， IntBuffer，LongBuffer，FloatBuffer，DoubleBuffer，CharBuffer

3.因为Buffer的构造方法是默认的没有任何权限修饰符，所以无法在其他包中使用构造方法创建对象,所以Buffer提供了两个静态方法创建对象。 ByteBuffer allocate = ByteBuffer.allocate(4); // 需要指定容量位 ByteBuffer wrap = ByteBuffer.wrap(“Hello！”.getBytes());// 数据已知时使用

4.底层使用数组进行存储，例如ByteBuffer底层就是基于字节数组进行存储

5.重要位置capacity >= limit >= position >= mark

a.capacity(容量为):用于标记缓冲区容量,缓冲区定义好容量位不可变
	b.position(操作位):用于标记缓冲区读写位置，默认为0
	c.limit(限制位):用于标记position的最大位置，默认大小等于
	capacity。
	d.mark(标记位):可类别为我们打游戏时候的存档，万一我们的缓冲区
	很大读到某个位置的时候异常了，存档不就可以提高效率了吗.

四.通道-Channel

1.作用:传输数据

2.Channel是双向传输的可读可写

3.Channel默认是阻塞的，可手动设置为非阻塞

4.分类: a. 文件:fileChannel b. UDP:DatagramChannel c. TCP：SocketChannel，ServerSocketChannel

TCP下通道的使用

服务端

package com.jmy.io;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;

public class NioServer {
    public static void main(String[] args) throws IOException {
        ServerSocketChannel ssc = ServerSocketChannel.open();
        // 监听端口
        ssc.bind(new InetSocketAddress());
        SocketChannel sc = ssc.accept();

        // 一直建立连接
        while (sc == null) {
            sc = ssc.accept();
        }

        ByteBuffer b = ByteBuffer.allocate();

        sc.read(b);

        System.out.println(new String(b.array(),,b.position()));
    }
}

客户端

package com.jmy.io;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;

public class NioClient {
    public static void main(String[] args) throws IOException {
        // 创建通道
        SocketChannel sc = SocketChannel.open();

        // 设置为非阻塞通道
        sc.configureBlocking(false);
        // 发起连接
        sc.connect(new InetSocketAddress("127.0.0.1", ));
        // 多次连接
        while (!sc.isConnected()) {
            sc.finishConnect();
        }
        // 写入数据 需要传入一个缓冲区对象
        ByteBuffer b = ByteBuffer.wrap("你好呀！服务端！".getBytes());
        sc.write(b);
        // 关流
        sc.close();
    }
}