Netty知识点

1.阻塞io (blocking i/o)

2.非阻塞io (non blocking i/o)

3.IO多路复用 (mulitplexing i/o)

4.信号驱动 (signal driven i/o)

1.异步io (asyncchronous i/o)

关键示例

系统庞大后存在的问题

Netty默认会在ChannelPipline的最后添加一个tail handler帮你完成ByteBuf的release

如果中途没有使用fireChannelRead传递下去也要自己释放

通过Channel或ChannelHandlerContext创建的但是没有传递下去的ByteBuf也要手动释放

ResourceLeakDetector

检测级别

参数设置

非阻塞传输，基于java.nio

非阻塞传输，基于JNI的epoll，只支持linux，性能优于NIO。linux-2.5.44（2002）+

阻塞传输，基于java.net

本地传输，在VM内部通过管道通讯

测试使用

EventLoopGroup

ServerChannel

ChannelHandler

bind()

ScheduledFuture

ChannelHandlerContext.alloc()

Unpooled

ByteBuf.order()

ByteBuf.duplicate()

AbstractNioByteChannel.read()

Channel.write()

ChannelPipeline.write()

ChannelHandlerContext.write()

write写入字节大于sendBuffer大小

进行MSS大小的Segment分段

以太网帧的payload大于MTU

消息定长

消息尾分隔符

分为消息头消息体，头中包含消息长度

半包

粘包

加分割符

长度

消息头(消息体长度)

netty 自带解码器解决这个问题

分支主题

Java 对象根据协议封装成二进制数据包的过程成为编码public ByteBuf encode(Packet packet) {// .... return byteBuf;}

// 1. 创建 ByteBuf 对象 ByteBuf byteBuf = ByteBufAllocator.DEFAULT.ioBuffer()

// 2. 序列化 Java 对象 byte[] bytes = Serializer.DEFAULT.serialize(packet);

// 3. 实际编码过程 byteBuf.writeInt(MAGIC_NUMBER); byteBuf.writeByte(packet.getVersion()); byteBuf.writeByte(Serializer.DEFAULT.getSerializerAlgorithm()); byteBuf.writeByte(packet.getCommand()); byteBuf.writeInt(bytes.length); byteBuf.writeBytes(bytes);

二进制数据包中解析出 Java 对象的过程成为解码

public Packet decode(ByteBuf byteBuf) { // 跳过 magic number byteBuf.skipBytes(4); // 跳过版本号 byteBuf.skipBytes(1); // 序列化算法标识 byte serializeAlgorithm = byteBuf.readByte(); // 指令 byte command = byteBuf.readByte(); // 数据包长度 int length = byteBuf.readInt(); byte[] bytes = new byte[length]; byteBuf.readBytes(bytes); Class requestType = getRequestType(command); Serializer serializer = getSerializer(serializeAlgorithm); if (requestType != null && serializer != null) { return serializer.deserialize(requestType, bytes); } return null;}

长度固定，容量不能动态扩展收缩，出现数组越界

只有一个位置标识指针，读写转换时要手动调用flip()

api功能有限

flip()

典型用法

写入

读取

discardRead

clear

readSlice（int length）

wirteZero（int length）

readerIndex和writeIndex

discardable bytes

Clear操作

Mard Reset

Derived buffer

set/get随机读写

查找

基于堆内存分配回收速度快，缺点是需要额外一次内存copy

readerIndex

writerIndex

本质上类似于提供一个或多个ByteBuf的组合视图，可以根据需要添加和删除不同类型的ByteBuf

已经存在的缓冲区的视图

修改了这个新的ByteBuf实例的具体内容，那么对应的源实例也会被修改，因为其内部存储是共享的

使用派生缓冲区，避免了复制内存的开销，有效提高程序的性能

于堆外分配的直接内存，不会占用堆的容量。适用于套接字传输过程，避免了数据从内部缓冲区拷贝到直接缓冲区的过程，性能较好

优点: 使用Socket传递数据时性能很好，避免了数据从Jvm堆内存拷贝到直接缓冲区的过程。提高了性能

缺点: 相对于堆缓冲区而言，Direct Buffer分配内存空间和释放更为昂贵

数据存放在JVM的堆空间，通过将数据存储在数组中实现

堆缓冲的优点: 由于数据存储在Jvm堆中可以快速创建和快速释放，并且提供了数组直接快速访问的方法

堆缓冲的缺点: 每次数据与I/O进行传输时，都需要将数据拷贝到直接缓冲区

在池化的时候无法使用jvm回收内存,需要靠手动回收内存

堆外内存分配，分配回收速度慢，0copy

池化使用了对象池技术，减少gc，但是会带来额外维护开销

门限4MB，新申请的容量大于4m小于maxCap时以4m的大小增长，小于4m时则以64的倍数进行增长

PoolArena

chunk

page

byteBufHolder

bytebufAllocator

CompositeBytebuf

BytebufUtil

NioServerSocketChannel

EpollServerSocketChannel

OioServerSocketChannel

Local

Embedded

ChannelConfig

3.netty里面主要对象

ChannelPipeline

EventLoop

ChannelFuture

写入ChannelPipeline缓存

ChannelPipeline

Channel

EventExecutor

ChannelFuture

ByteBufAllocator

abstract： ChannelInboundHandlerAdapter

abstract： ChannelOutboundHandlerAdapter

IdleStateHandler

ByteToMessageDecoder

abstractMessageToMessageDecoder

ChannelRegistered（）

channelActive

channelread

channelReadComplete

exceptionCauth

userEventTriggered

channelWriabilityChanged

channelInactive

MessageToByteEncoder

abstractMessageToMessageEncoder

abstract:MessageToMessageCodec

数据粘包/拆包处理

加解密处理

业务流程处理

分层处理，网络处理和业务处理分离

分支主题

nio线程职责

分支主题

特点

不要在channelHandler中启动用户线程

解码要放在NIO线程调用解码Handler中进行，不要切换到用户线程完成

如果业务操作简单，可以直接在NIO线程上完成逻辑

如果业务复杂耗时，可封装成task发到业务线程池中完成

分支主题

与多线程reactor相比，使用线程池接收客户端请求

NioEventLoopGroup

EpollEventLoopGroup

OioEventLoopGroup

operationComplete