Netty（零散记录）

Netty：

1、Netty三种IO

在这里插入图片描述

2、Netty和Reactor的

1、Netty对Reactor的支持

Netty的线程模型时基于Reactor模型实现的，Netty对Reactor三种模式都有非常好的支持，并做了一定的改善，一般情况下，在服务端会采用主从架构模型。

在这里插入图片描述

tips：Netty是解决网络通信的，业务线程池不归Netty管

流程：所有的客户端连接首先注册到Boss EventLoopGroup (Main Reactor)，Boss EventLoopGroup不断轮询查询出Accept的客户端，交给Work EventLoopGroup，在Work EventLoopGroup中也在不断的轮询找出就绪的Read/Write事件交由pipeline来处理。（一个Socket Channel对应一个Pipeline，而一个pipeline中有多个handler来处理业务）

对于使用者来说只需要编写Handler即可，其他的主从Reactor模型Netty已经帮我们完成了

在这里插入图片描述

头和尾是Netty 初始化好的，因为第一步从Socket中读取数据相对来说是固定的代码，所以Netty替我们完成了，至于拿到数据后具体做什么业务，这个只能我们自己决定。所以Netty替我们初始化了一个Head handler；当我们业务完成后需要把数据写回去，这个代码也相对是固定的所以Netty通过Head Handler也完成了。至于Tail Handler则是做一些收尾工作，例如释放资源。

2、Netty中的ChannelHandler

Handler可以大致分为两类 inbound（入站）和outbound（出站）两种

- ChannelInboudHandler：入站处理器
- ChannelOutBoundHandler：出站处理器
- ChanelHandlerAdapter：提供了一些默认的实现，减少用户对于ChannelHandler的编写
- ChannelDuplexHandler：混合型，既可以处理出站也可以处理入站

3、Netty如何使用Reactor模型

Netty通过创建服务的时候配置不同的eventGroup来确认使用哪种Reactor模型

Reactor 单线程模式	EventLoopGroup group = new NioEventLoopGroup(1); ServerBootstrap serverBootstrap = new ServerBootstrap(); serverBootstrap.group(group);
非主从Reactor多线程模式	EventLoopGroup group = new NioEventLoopGroup(1); ServerBootstrap serverBootstrap = new ServerBootstrap(); serverBootstrap.group(group);
主从Reactor多线程模式	EventLoopGroup bossGroup = new NioEventLoopGroup(1); ServerBootstrap serverBootstrap = new ServerBootstrap(); EventLoopGroup workGroup = new NioEventLoopGroup(); serverBootstrap.group(bossGroup,workGroup);

4、Netty的核心组件

1、Bootstrap：引导类，用于配置整个Netty程序吗，将各个组件串起来，最后绑定端口启动Netty服务，Bootstrap分为两类，一种用于客户端的Bootstrap一种用于服务端的ServerBootstrap，两者的区别在于

（1）ServerBootstrap将绑定到一个端口，服务端必须要监听连接，而Bootstrap则是由想要连接的远程节点的客户端应用程序所使用。

（2）引导一个客户端只要一个EventLoopGroup，但是一个ServerBootstrap则需要两个

2、Channel

3、EventLoopGroup和EventLoop

4、ByteBuf

ByteBuf是Netty对NIO中 ByteBuffer的封装

对于直接缓冲区来说由于不受JVM的控制，所以基于Netty编写的程序如果没有处理好这部分逻辑，容易出现内存泄漏。同时，由于是向操作系统申请内存，操作系统有时候可能不会及时响应所以Netty是基于池化技术来做的。首先Netty再启动的时候会向操作系统申请一片内存，之后的操作都是基于这一片内存，从而不需要每次都进行分配内存和释放内存。

Netty默认使用了PooledByteBufAllocator，但是可以通过引导类设置非池化模式。

那么如何解决堆外内存无法被JVM管理从而无法释放的问题呢？手动释放（用完后归还给Netty内存池，注意是Release），Netty自身引入了应用技术，提供了ReferenceCounted接口，当引用计数=0时，会被释放（类似于JVM中的引用计数法）

手动释放的场景，例如现在有N多个Handler，其中一个handler的作用是把ByteBuf中的数据序列化成User对象，之后往后传的是User对象，而不是BtyeBuf了，此时就需要手动将其释放掉。

小结：

5、Future和Promise

Netty中的future 继承于JDK中的future，只不过在其基础上进行了扩展。例如添加监听器

Promise是基于netty中的 Future扩展而来， Netty中的future只增加了监听器，整个异步的状态是不能设置和修改的，于是netty的Promise接口扩展了netty的Future接口，可以设置异步执行结果。在IO操作过程中，如果顺利完成、或者发送异常，都可以设置Promise的结果，并通知给Promise的Listener们。

简单的来说，通过Promise机制，运行用户人为的控制异步任务中什么时候触发“回调函数”。

案例：