解读 Netty资源泄漏追踪 Netty有办法去知道目前系统正在发生内存资源泄漏吗？ 答案是：有的！ 前置知识：引用，Netty依赖于引用队列技术实现资源泄漏追踪；在此略微科普下，大概引用实例关联对象被 gc时，引用实例会先被加入到 pending队列中，而当 Reference类加载时，会默认启动一个线程去消费 pending队列中元素，根据元素类型去做些响应处理，其中有一种处理逻辑便是将元素存入到引用队列中去 前置知识，对 DirectByteBuffer解读 - 良夜的博客 (liangye-xo.xyz) …

怎么理解 Netty中内存资源泄漏？ 什么是资源？线程、内存、连接、文件皆是资源！ 对于服务器而言，我们显然更关注前两者 介于资源创建的昂贵，引用了一些相关的池化技术，如线程池、连接池、对象池、内存池等等，池化技术的引入，实实在在地提升了程序的性能，但相应地也带来了一些问题，so，我们需要来对其进行处理 Netty中池化内存同样如此！使用不当，仍然可能会带来内存泄漏的隐患！ 经过前面分析，我们知道，当我们向程序去申请内存时，内存的管理是经由内存池的 当我们去申请内存时，首先会到对象池中去获取一个空闲的 ByteBu…

尝试三之 Arena中 PoolChunkList进行分配 接着往下看： // 锁住当前 Arena synchronized (this) { // 最为复杂的逻辑... Arena的 subpagePools和线程的本地缓存 PoolThreadCache都没能满足内存的分配, 则会走 allocateNormal逻辑 // 参数一：上一步获取的一个内存容器, 下面逻辑会给 buf去分配真正的内存 // 参数二：指定想要去分配的内存容量 // 参数三：规格化后的 size allocateNormal(buf,…

对内存申请的解读 调用 ByteBufAllocator.DEFAULT.buffer()，业务层面指定想要去获取的内存大小 @Override public ByteBuf buffer(int initialCapacity) { // 我们来考虑分配直接内存的情况 if (directByDefault) { return directBuffer(initialCapacity); } return heapBuffer(initialCapacity); } // 参数：指定想要去分配的内存 @Overr…

解读内存池 解读 PooledByteBufAllocator 对于池化内存管理器 (PooledByteBufAllocator)而言，其内部存在两种类型的 Arena，一种是 Heap类型的 Arena，另一种则是 Direct类型的 Arena，Arena的引入其实为了解决 cpu缓存行冲突导致的数据不一致需要进行同步带来的开销问题而引入的，对于 heapArena、directArena的数目其实适合 cpu核心数有关的，通常情况下是 cpu核心数 * 2 这里还涉及到了 Netty中规定的一些规格，如 N…

Aop异常的玩法 在 ThrowsAdvice上看到这么一段注释，这段注释给出了异常的一些玩法： * <p>Some examples of valid methods would be: * * <pre class="code">public void afterThrowing(Exception ex)</pre> * <pre class="code">public void afterThrowing(RemoteE…

最近有点过于焦虑了，放平心态，焦虑导致人心劳累，先修养身心一段时间吧。。

消息出站 上层业务调用 ctx.flush()时，最终会来到 HeadContext.flush() @Override public void flush(ChannelHandlerContext ctx) { unsafe.flush(); } 接着，来到 Adstract.flush() // ctx.flush() - 最终会来到此 @Override public final void flush() { assertEventLoop(); ChannelOutboundBuffer outbound…

解读 出站缓冲区 (ChannelOutboundBuffer) 数据是怎么进行出站的？我们直观上认为，数据经过处理器的层层传递，最终会传递到 HeadContext，由 HeadContext负责将数据写入到与 Socket相关的写缓冲区中去，实现数据的发送 然，事实并非如此，so，此篇来对 "出站缓冲区"进行解读！ 首先，需要清楚一个概念：当我们将数据通过 ctx进行 write操作时，数据并没有直接写到对端，而当我们真正去调用 ctx.flush()方法时，才会去将数据真正发送到对端，当然…

Around与 其它通知之间的区别？ Around区别于其他的通知，可以认为，除了 Around之外的其它通知都是被动去执行的，而 Around不同，其是需要我们主动去执行的 (结合 ProceedingJoinpoint)，若是不显式去调用目标代码的话，那么之后的通知以及对应的目标方法也不会被执行，这也是区别于其它 Advice的地方 为什么 Spring Aop不需要去设计 Around Advice？ 从 AspectJ @Around执行上来讲，其是需要和 ProceedingJoinPoint配合执行被代…

风，四处游走，串联起夜的消息，从沉睡的窗口到沉睡的窗口，去探望被白昼忽略了的心

对 Aop的些许思考： Aop实际上就是提供了一些横切点，供我们去进行一些插拔式的动作 Aspect实际是就是一些横切点的组织形式，而 Joinpoint其实就是方法执行过程中定义良好的一个点 so，Aspect其实就是定义了一个模块去组织 Joinpoint Pointcut其实就是断言，Pointcut会去匹配 Joinpoint，匹配成功，则进行对应 Advice的执行，即将特定动作的 Advice织入 Joinpoint中去 AopProxy的实现不是 public的，其实也是根据某种方式进行的封装，外部通…

解读 Pipeline 先来看看 Pipeline的接口设计： 对应 Invoker中实际上来规定了可往 pipeline中传递的出站、入站事件，而 pipeline本身相当于就是一个容器，其提供了许多对容器中存储元素的增删改查方法，以及对 Invoker继承来的方法做了些许修改(返回值) 而对于 ChannelPipeline呢，其里面提供了许多对 ChannelHandlerContext的增删改查的方法，其实由启动流程时我们也知道，管道中存储的并不是 handler本身，而是对 handler的封装，Defa…

Aop源码 场景：无侵入性的日志、数据监控、安全防护等 面向接口的 Java动态代理 面向类的一个 Cglib的提升 入门 demo public interface Animal { void eat(); } public class Cat implements Animal{ @Override public void eat() { System.out.println("猫猫吃 猫粮"); } } /** * 目标：返回给外部被代理后的对象 * 完成被代理对象的增强 */ publi…