1.nettyԴ?码项目???Ŀ
2.Netty源码-一分钟掌握4种tcp粘包解决方案
3.跟着源码学IM(九)：基于Netty实现一套分布式IM系统
4.Netty源码解析 -- FastThreadLocal与HashedWheelTimer
5.netty源码解析（三十五）---Netty启动3 成功bind 等待连接

nettyԴ????Ŀ

       学习目标

       理解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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Netty源码解析 -- FastThreadLocal与HashedWheelTimer

       Netty源码分析系列文章接近尾声，本文深入解析FastThreadLocal与HashedWheelTimer。基于Netty 4.1.版本。

       FastThreadLocal简介：

       FastThreadLocal与FastThreadLocalThread协同工作。FastThreadLocalThread继承自Thread类，内部封装一个InternalThreadLocalMap，该map只能用于当前线程，存放了所有FastThreadLocal对应的值。每个FastThreadLocal拥有一个index，用于定位InternalThreadLocalMap中的值。获取值时，首先检查当前线程是否为FastThreadLocalThread，如果不是，则从UnpaddedInternalThreadLocalMap.slowThreadLocalMap获取InternalThreadLocalMap，这实际上回退到使用ThreadLocal。

       FastThreadLocal获取值步骤：

       #1 获取当前线程的InternalThreadLocalMap，如果是FastThreadLocalThread则直接获取，否则通过UnpaddedInternalThreadLocalMap.slowThreadLocalMap获取。

       #2 通过每个FastThreadLocal的index，获取InternalThreadLocalMap中的值。

       #3 若找不到值，则调用initialize方法构建新对象。

       FastThreadLocal特点：

       FastThreadLocal无需使用hash算法，通过下标直接获取值，复杂度为log(1)，性能非常高效。

       HashedWheelTimer介绍：

       HashedWheelTimer是Netty提供的时间轮调度器，用于高效管理各种延时任务。时间轮是一种批量化任务调度模型，能够充分利用线程资源。简单说，就是将任务按照时间间隔存放在环形队列中，执行线程定时执行队列中的任务。

       例如，环形队列有个格子，执行线程每秒移动一个格子，则每轮可存放1分钟内的任务。任务执行逻辑如下：给定两个任务task1（秒后执行）、task2（2分秒后执行），当前执行线程位于第6格子。那么，task1将放到+6=格，轮数为0；task2放到+6=格，轮数为2。执行线程将执行当前格子轮数为0的任务，并将其他任务轮数减1。

       HashedWheelTimer的缺点：

       时间轮调度器的时间精度受限于执行线程的移动速度。例如，每秒移动一个格子，则调度精度小于一秒的任务无法准时调用。

       HashedWheelTimer关键字段：

       添加延迟任务时，使用HashedWheelTimer#newTimeout方法，如果HashedWheelTimer未启动，则启动HashedWheelTimer。启动后，构建HashedWheelTimeout并添加到timeouts集合。

       HashedWheelTimer运行流程：

       启动后阻塞HashedWheelTimer线程，直到Worker线程启动完成。计算下一格子开始执行的时间，然后睡眠到下次格子开始执行时间。获取tick对应的格子索引，处理已到期任务，移动到下一个格子。当HashedWheelTimer停止时，取消任务并停止时间轮。

       HashedWheelTimer性能比较：

       HashedWheelTimer新增任务复杂度为O(1)，优于使用堆维护任务的ScheduledExecutorService，适合处理大量任务。然而，当任务较少或无任务时，HashedWheelTimer的执行线程需要不断移动，造成性能消耗。另外，使用同一个线程调用和执行任务，某些任务执行时间过久会影响后续任务执行。为避免这种情况，可在任务中使用额外线程执行逻辑。如果任务过多，可能导致任务长期滞留在timeouts中而不能及时执行。

       本文深入剖析FastThreadLocal与HashedWheelTimer的实现细节，旨在提供全面的技术洞察与实战经验。希望对您理解Netty源码与时间轮调度器有帮助。关注微信公众号，获取更多Netty源码解析与技术分享。

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结果。当连接到来时，整个绑定过程结束。