皮皮网

1.Netty源码-Reactor线程模型之NioEventLoopGroup研究
2.Netty源码-一分钟掌握4种tcp粘包解决方案
3.Netty原理-从NIO开始
4.netty源码解析（三十五）---Netty启动3 成功bind 等待连接
5.Netty源码-Sharable注解，码入我猜你理解错了！码入
6.跟着源码学IM(九)：基于Netty实现一套分布式IM系统

Netty源码-Reactor线程模型之NioEventLoopGroup研究

       在Netty网络编程中，码入NioEventLoopGroup作为线程池的码入核心组件，其作用至关重要。码入从初始化的码入论文检索源码逻辑分析来看，NioEventLoopGroup扮演多重角色，码入不仅提供了线程池相关功能，码入同时也继承了线程模型的码入ScheduledExecutorService，ExecutorService和Executor接口，码入体现其多功能性。码入

       其层次结构显示，码入NioEventLoopGroup从底层向上层层封装，码入实现了线程池模型的码入关键功能。进一步深入分析，码入NioEventLoopGroup通过继承自MultithreadEventLoopGroup，并在构造函数中执行关键初始化操作，展现了其独特的设计。首先，NioEventLoopGroup在初始化时创建线程工厂，构建线程执行器Executor，故事平台 源码如果未提供自定义Executor，将使用DefaultThreadFactory创建FastThreadLocalThread线程执行任务。其次，根据指定数量nThreads创建子线程组，若nThreads未定义或设为0，则默认设置为2倍的CPU线程数。最后，在初始化子线程组时，NioEventLoopGroup通过newChild()方法执行初始化，这一步操作具体实现由NioEventLoop类完成，其初始化参数包括线程选择器chooser，以及其他多个关键参数，确保线程高效运行。

       NioEventLoopGroup与Java线程池之间的区别主要体现在其面向特定应用场景的设计上，尤其在事件驱动和非阻塞IO模型的支持方面。Netty通过NioEventLoopGroup实现了更灵活、高效的并发处理机制，使得在处理高并发、高网络流量场景时，性能得到显著提升。aspnet分块源码

       在研究NioEventLoopGroup的过程中，我们深入学习到了设计模式的应用，如单例模式确保了线程选择器的唯一性，工厂模式则负责创建不同类型的线程组。此外，模板设计模式的使用，使得NioEventLoopGroup能够提供高度抽象的初始化逻辑，同时保持了代码的复用性和可扩展性。通过这种设计，Netty不仅优化了资源管理，还提升了系统的整体性能和稳定性。

Netty源码-一分钟掌握4种tcp粘包解决方案

       TCP报文的传输过程涉及内核中recv缓冲区和send缓冲区。发送端，数据先至send缓冲区，经Nagle算法判断是否立即发送。接收端，数据先入recv缓冲区，再由内核拷贝至用户空间。

       粘包现象源于无明确边界。解决此问题的充电收费源码关键在于界定报文的分界。Netty提供了四种方案来应对TCP粘包问题。

       Netty粘包解决方案基于容器存储报文，待所有报文收集后进行拆包处理。容器与拆包处理分别在ByteToMessageDecoder类的cumulation与decode抽象方法中实现。

       FixedLengthFrameDecoder是通过设置固定长度参数来识别报文，非报文长度，避免误判。

       LineBasedFrameDecoder以换行符作为分界符，确保准确分割报文，避免将多个报文合并。

       LengthFieldPrepender通过设置长度字段长度，实现简单编码，为后续解码提供依据。

       LengthFieldBasedFrameDecoder则是一种万能解码器，能够解密任意格式的编码，灵活性高。

       实现过程中涉及的参数包括：长度字段的起始位置offset、长度字段占的字节数lengthFieldLength、长度的调整lengthAdjustment以及解码后需跳过的字节数initialBytesToStrip。

       在实际应用中，指标源码集合为自定义协议，需在服务器与客户端分别实现编码与解码逻辑。服务器端负责发送经过编码的协议数据，客户端则接收并解码，以还原协议信息。

Netty原理-从NIO开始

       Netty是基于NIO的异步通信框架（曾经引入过AIO，后来放弃），故要说Netty原理我们要先从NIO开始。

        NIO 是JAVA在JDK4中引入的同步非阻塞通信模型，在NIO出现之前（JDK4之前）市场上只有一个BIO模型顾名思义BLOCKING IO （同步阻塞通信模型）

        BIO（BLOCKING I/O）：

        BIO 为一个连接 一个线程的模式，当有连接时服务器会开启一个线程来处理请求

        若此请求啥都不想干此时线程会怎么样？

        此线程会进入阻塞模式（BLOCKING）！---啥也不干，干等着zzZZ~

        这种一连接，一线程的模式会造成服务器资源不必要的开销并且在大量连接访问时 服务器会发生什么？车道（线程）不足，车太多--我堵车了

        由此就出现了NIO

        ↓

        NIO（new/NONBLOCKING I/O）:

        NIO为同步非阻塞通信模型，Select（多路复用器）为此模型的核心，实现了多个连接一个线程

        当有客户端连接请求时 此连接请求会被注册至select上，当select检测到此连接有I/O请求时才会打开一个线程去对此I/O请求进行处理-----单线程模型

        这个时候有人问了：这么多操作都在一个线程里，线程忙不过来怎么办？

        此时 由于网络请求、I/O读写、业务操作都在一个线程下，会导致在高并发的情况下存在性能瓶颈 于是乎有人就提出来 将业务操作丢到另一个线程怎么样？

        于是出现了第三种reactor模型-使用线程池进行操作网络请求、IO在一个线程，业务操作在另个一个线程 的业务分离----线程池模型

        从此图中可以看出此时 模型中使用一个线程池来进行网络请求、IO读取

        当读取完成后将业务操作绑定在线程池中另外的线程上-------网络IO与业务操作可以同步进行了！一切都完美了起来！

        但是！事情还没完！！这个时候又有人提出问题：在高并发的时候咋办？会不会有性能瓶颈

        因为网络IO是非常消耗CPU的，当网络请求与网络IO在同个线程中时，造CK的情况下单个线程并不足以支撑起所有的IO操作！因此也形成了在高并发状态下的性能瓶颈

        于是大佬们就想着，如果把IO拆出来让单个线程池去接收网络请求，用另一个线程池来进行IO与业务操作会不会更好

        于是第四种Reactor模型应运而生--主从Reactor多线程模型

        此模型中 mainReactor只用于接收网络请求，而subReactor中为一个线程池，线程池中每个线程上绑定一个select

        当mainReactor接收到请求时（一个描述符） 系统会生成一个新的描述符代表此连接生效，此时mainReactor会将新的描述符通过一个算法在线程池中选定一个线程 将此描述符绑定至此线程池上的select上，由此线程来对请求进行I/O 与业务操作

        从此百万连接高并发不是问题

        写到这 我们是不是想起了Netty的启动过程

        1、声明两个EventLoopGroup一个为boss（mainReactor）一个为worker（subReactor）

        EventLoopGroup（线程池）初始化的时候会生成（懒加载）指定数量的EventLoop（线程）若无指定 则会生成CPU数X2的线程

        2、声明一个启动辅助类Bootstrap并将EventLoopGroup注册到启动辅助类BootStrap上(bootStrap.group)

        接着再给bootstrap指定channel模型等属性，再添加上业务流水线（channelpipeline）并且在pipeline中添加上业务操作handler，（通过channelpipeline可以对传入数据为所欲为）

        3、绑定端口

        Netty启动完成

        这时候可能有人会问了：这和你上面说的reactor？NIO有啥关系？

        这个时候我们要这么看

        ↓

        若我们将boss与worker线程池设置为相同的一个线程池，那么会发生什么事？

        此时关注一下第三个Reactor模型时就会发现 当BOSS=WORKER时候 netty实现的就是第三种Reactor模型 使用线程池模型

        而当boss不等于worker的时候使用的就是第四种 主从多线程模型

        Netty就是基于Reactor模型来对NIO进行了易用化封装，从Netty源码中就可以看出来其实底层还都是NIO的接口

        此次处为自己读源码之后的理解 如有误请指正

        感恩

        反手拿下第一个赞

netty源码解析（三十五）---Netty启动3 成功bind 等待连接

       Netty启动过程中的bind操作在AbstractBootstrap类中启动，由于异步特性，ChannelFuture在register0方法后交给事件执行器处理，此时isDone返回为false。在sync同步等待时，主线程会阻塞在PendingRegistrationPromise上，等待绑定完成。

       PendingRegistrationPromise的创建和ChannelFuture的监听器是为了在绑定成功后执行后续操作。当bind0方法中的safeSetSuccess成功后，会触发监听器，进一步调用AbstractChannel的bind方法。这个过程会通过DefaultChannelPipeline的tail处理，最后在AbstractChannelHandlerContext的HeadContext中，调用handler的bind方法，其中HeadContext的unsafe.bind方法会调用到NioServerSocketChannel的unsafe的dobind方法。

       在NioServerSocketChannel中，真正的绑定操作是调用原生的jdk的bind方法。当绑定成功后，AbstractChannel的dobind方法会设置promise为success，从而唤醒主线程，继续执行后续代码。至此，Netty的bind操作等待连接的到来。

       总结整个流程：Bootstrap创建Promise等待，然后通过管道传递到AbstractChannel，通过HeadContext调用unsafe.bind，最终在NioServerSocketChannel中调用原生bind，主线程等待并处理bind结果。当连接到来时，整个绑定过程结束。

Netty源码-Sharable注解，我猜你理解错了！

       学习目标

       理解Sharable注解在Netty中的作用。个人臆想，只要在ChannelHandler上添加了@ChannelHandler.Sharable注解，所有的channel都共享这一个ChannelHandler实例。真是这样的吗？如果你认为所有channel共享一个pipeline，只能说明你对pipeline的初始化不理解。你臆想完全错误！！！

       Sharable注解介绍

       在深入探讨之前，建议阅读《Netty源码-ChannelPipeline的剖析》。阅读后，问题迎刃而解。同时，你可能还会疑惑Sharable注解的用途。它的主要目的是在pipeline之间共享信息，例如统计连接数、限流、白名单等。

       如何使用Sharable注解

       源码中有明确说明，你可以在ChannelHandler的成员变量上使用@ChannelHandler.Sharable注解，表示这个变量的实例可以被所有pipeline共享。如果不想共享，就每次创建新实例。通过代码示例可以直观理解共享实例和每次创建新实例的区别。

       使用场景

       Sharable注解适用于在pipeline之间需要共享数据或状态的场景。例如统计连接数、限流、白名单管理等。

       注意事项

       使用Sharable注解时，务必考虑线程安全。在多线程环境中，确保共享数据的正确性和一致性。

       实战应用-统计当前连接数

       通过实践，我们实现了一个简单的统计当前连接数的示例。执行结果如下：

       Connected to the target VM, address: '.0.0.1:', transport: 'socket' count:1 InBoundHandler1-channelRead:abc InBoundHandler1-channelRead:asd count:2 InBoundHandler1-channelRead:abc InBoundHandler1-channelRead:asd

跟着源码学IM(九)：基于Netty实现一套分布式IM系统

       本文作者小傅哥，以实践为导向，带你开发分布式即时通讯（IM）系统。通过动手实践，理解DDD+Netty技术的运用。

       多次实践即时通信项目后，这次将分享具体步骤和源码，涵盖系统架构、通信协议、用户操作（单聊、群聊、表情发送）等。代码实战贯穿始终，从UI事件驱动设计到系统架构拆分，如UI与业务逻辑分离，便于扩展和维护。

       知识准备方面，Netty是Java的高效网络编程框架，简化网络应用开发。对基础知识有需求的，推荐阅读相关入门文章。系统运行效果和源码下载链接可以在文中找到。

       系统设计采用DDD模式，易于操作和管理。UI设计包括聊天窗口、好友列表和事件驱动。通信设计上，我们探讨了系统架构选择和通信协议设计，如添加好友和消息应答的处理示例。

       后续内容包括网络连接的断线重连机制，集群通信的实现，以及整个项目的技术栈应用，如Netty、SpringBoot、Mybatis等。通过源码学习，掌握从HelloWorld到深度挖掘的完整过程。

       系列文章链接在文中列出，供进一步学习。对于希望深入理解IM开发的读者，务必结合源码进行实践，才能收获满满。本文是系列中的第九篇，提供丰富的实践资料和参考资料。