2018/1/19 Netty学习笔记(一)

这段时间学了好多好多东西,不过更可能是细节和思想上的,好比分布式事物,二次提交,改善代码质量,还有一些看了一些源码什么的;

记录一下真正的技术学习,关于Netty的学习过程;

首先说Netty以前先说一下BIO,NIO和AIO的区别吧,我这里对于AIO只说个大概,下午或者晚上有时间会写个具体的,其实原本想说说websocket的不过太基础了,各位百度下就行;

BIO,NIO和AIO的区别
BIO也就是同步阻塞的I/O,由JAVA程序本身处理I/O流操做;一个线程启用I/O请求后,必须等I/O处理完毕才能进行下一步;
NIO是同步非阻塞的I/O,仍是由JAVA处理应用操做,不过单独开启一个线程去作I/O处理,并且会将数据读写到一个Buffer缓冲区中,以后交由OS去进行处理,缺点是须要多路复用器不断去轮询,在触发I/O操做后,用户线程也会须要时不时的去访问查看是否已经完成(jdk7后已经使用了epoll进行了改善)
AIO也就是NIO2.0,只须要发起一个I/O请求,以后具体的I/O操做都交由系统完成,系统在完成后会自行通知程序;

不论是NIO仍是AIO都是避免了传统BIO使用TCP链接建立输出和输入流通道进行通讯的弊端,它们使用的是http长链接创建了一个可读写的通道(channel);

Channel 管道(这里只说网络读写的Channel (SelecttableChannel 它有两个子类SocketChannel和ServerSockerChannel)避免了传统BIO的三次握手模型创建的OutputStream,InputStream链接通道),既能够读也能够写,也能够读写同时进行,而且channel上有四种状态位,分别是(Connect 链接状态,Accept 阻塞状态,Read 可读状态,Write 可写状态)不论是读写数据都是要先进入一个Buffer中,
而Buffer其实也是一个对象,有对应JAVA八种基本数据类型的八种缓存区,但咱们通常使用ByteBuffer对象进行读写的存储就够了;

Selector 多路复用器,管理着一个注册的通道集合的信息和它们的就绪状态(使用轮询),若是某个通道发生了读写操做,会被它轮询出来,并经过SelectionKey能够取得就绪的Channel集合,从而进行后续的I/O操做;
一个Selector能够管理成千上万个Channel通道,若是使用传统的轮询机制就会使得性能很底下,因此JDK使用了epoll(内部对于通道的节点位置使用红黑树存储,对于每一个通道都添加了一个事件,只有当进程调用了必定的方法后,扫描才会被触发,并且能够并利用红黑树快速找到通道的节点位置)
Selector模式: 当管道注册到选择器之后,selector会分配给每一个管道一个key值,至关于标签.selector选择器是以轮询的方式方式进行查找注册的全部IO事件(管道),当咱们的IO事件(管道准备就绪后),selector会识别,并经过对应的key值找到对应的管道,进行相关的数据处理操做(从管道中读获写数据,读的话就是写到咱们的数据缓冲区中).

每一个管道都有不一样的事件状态,以便选择器查找;
SelectionKey.OP_CONNECT
SelectionKey.OP_ACCEPT
SelectionKey.OP_READ
SelectionKey.OP_WRITE

//Buffer api
public void test() {
ByteBuffer byteBuffer = ByteBuffer.allocate(10);
byteBuffer.put((byte) 1);
byteBuffer.put((byte) 2);
System.out.println(byteBuffer);
// 打印此缓冲区,注意看它的结构 java.nio.HeapByteBuffer[pos=2 lim=10 cap=10]
// pos:至关于一个游标,lim是具体长度,cap是容量上限,能够看到如今lim长度不对
// 复位
byteBuffer.flip();
System.out.println(byteBuffer);
// 此时再打印 java.nio.HeapByteBuffer[pos=0 lim=2 cap=10]能够看到游标变成了0,lim也正常了;
//为何会这样?
/* public final Buffer flip() {
limit = position;
position = 0;
mark = -1;
return this;
}*/
//看源码就知道了,那么若是不复位会发生什么呢?当你想取得数据的时候会发现会把后面没有数据的部分也打印出来
//咱们在复位的状况下打印下试试
for (int i = 0; i < byteBuffer.limit(); i++) {
byte b = byteBuffer.get(i);
System.out.print(b+"\t");
}
//结果为1 2
//再看看不复位的状况下是什么 1 2 0 0 0 0 0 0 0 0 ,也就是说咱们要保证limit,也就是实际长度的准备性

//事实上,若是咱们使用调用get()方法，也就是不经过索引查找数据，而且在没有复位的状况下，会连1 2都显示不出来，而是直接显示后面的默认值数据，由于get方法是以pos游标当前处日后推，而且还会致使溢出异常,由于不复位的状况下,limit是最大容量,也就是10;就算是默认值数据,也是如下标为准的,也就是10个数据,最大下标就是9,而get()会一直到10;

}