NIO

2022-10-27 16:49:21 浏览数 (3)

代码语言:javascript复制
一.概述

1.NIO的作用:传输数据

2.Java中IO的分类

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

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

代码语言:javascript复制
二.BIO的缺点

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

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

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

代码语言:javascript复制
三.缓冲区-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

代码语言:javascript复制
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下通道的使用

服务端

代码语言:javascript复制
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()));
    }
}

客户端

代码语言:javascript复制
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();
    }
}
代码语言:javascript复制
五.多路复用选择器

1.可以监听不同的事件从而做出不同的判断,避免了BIO中的空连接.

2.Selector要求注册的通道为非阻塞的

0 人点赞