一.概述
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要求注册的通道为非阻塞的