最近开始学习Netty,在学习Netty之前,先学习下NIO
相对于传统的Socket。Nio提供了SocketChannel和ServerSocketChannel两种不同的套接字通道
NIO有下面几个概念
1:缓冲区Buffer
Buffer是一个对象,它包含了要读取或者要写入的数据,在面向流的·IO中,都是直接把数据写入或者读取到Stream对象中。
在NIO库中,所有的数据都是用缓冲区来处理的,在读取数据时,是直接读取缓冲区中的数据,在写入数据时,也是直接写入到缓冲区中, 任何时候访问NIO中的数据,都是通过缓冲区进行操作。
缓冲区实质上还是一个数组,通常是一个字节数组,ByteBuffer,但不仅仅是字节数组,还提供了对数据的结构化访问和维护读写位置limit等信息。
Position代表了下标,Flip表示固定下标,其他人不能改变。
当我们从通道中读取数据到缓冲区的时候:注意从通道中读取数据,相当于从缓冲区中写入数据,
如果读取了4个数据,那么此时Position的值为4.表示下一个将要写入的索引为4,而limit仍然为10
当要向输出通道里面写数据的时候,相当于从缓冲区中读取数据。
需要使用到flip方法。
flip方法完成了2件事情
1: 将limit设置为Position的值
2:将position的值设置为0;
如图所示:
先调用put方法从通道中读取数据到缓冲区,然后在调用flip方法
Limit表示当前可以操作的数据范围。
使用完毕后,调用clear方法,又回来了初始状态。
2:通道Channel
Channel是一个通道,网络数据通过Channel的读取和写入,通道与流的区别在于:
通道是双向的,而流是单向的。全双工的。
3:多路复用器
Selector 一个多路复用器Selector可以同时轮训多个Channel,它会不断的轮询注册在上面的Channel,如果某个Channel上产生了可读/写事件,这个Channel就处于就绪状态,会被轮询出来,然后通过SelectionKey可以获取就绪的Channel集合,进行后续的操作。
代码:
public class BufferProgram {
public static void main(String[] args) throws Exception {
//这用用的是文件IO处理
FileInputStream fin = new FileInputStream("F:/一般代码/buffer.txt");
//创建文件操作的管道
FileChannel fileChannel = fin.getChannel();
//分配一个5个大小缓冲区,说白了就是分配一个5个大小的byte数组
ByteBuffer buffer = ByteBuffer.allocate(5);
output("初始化", buffer);
//先从通道中读取数据到缓冲区。一次性读取5数据
fileChannel.read(buffer);
output("调用read()", buffer);
//准备操作之前,锁定缓冲区
buffer.flip();
output("调用flip()", buffer);
//判断有没有可读的数据
while(buffer.remaining()>0){
byte b = buffer.get();
System.out.println(b);
}
output("调用get()", buffer);
//解锁,重新读取
buffer.clear();
output("调用clear()", buffer);
//最后把管道关闭
fin.close();
}
private static void output(String step, ByteBuffer buffer) {
System.out.println(step + " : ");
//容量,数组大小
System.out.println("capacity容量为:"+buffer.capacity()+",");
//当前操作数据所在的位置,也可以叫做游标
System.out.println("position:"+buffer.position()+",");
////锁定值,flip,数据操作范围索引只能在position - limit 之间
System.out.println("limit: "+buffer.limit()+",");
System.out.println("**********************************");
}
}