背景 从本文开始开启一个新的专题Netty系列，用于收集Netty相关的文章，内容包含Netty的使用方式、运行原理等。 基于io.netty:netty-all:4.1.49.Final版本进行介绍 1.NioEventLoopGroup 介绍NioEventLoopGroup之前，有几个相关的组件需要提前介绍。 1.1 SelectorProvider NIO中用于创建通道c

Netty源码分析：NioEventLoop启动以及其IO操作和Task任务的处理 在上篇博文分析服务端启动的过程中，我们遇到了如下的代码片段， if (eventLoop.inEventLoop()) {register0(promise);} else {try {eventLoop.execute(new OneTimeTask() {@Overridepubli

剖析方向 NioEventLoop是一个重量级的类，其中涉及到的方法都有很复杂的继承关系，调用链，要想把源码全部过一遍工作量实在是太大了，于是小编就基于下面的这些常见的问题来对NioEventLoop的源码来进行剖析 1.Seletor何时创建     1.1Selector为什么有两个Selector成员 2.nio线程在何时启动 3.每次循环时什么时候会进入SelecStrategy.S

1.入口 会调用到父类SingleThreadEventLoop的构造方法 2.SingleThreadEventLoop 继续调用父类SingleThreadEventExecutor的构造方法 3.SingleThreadEventExecutor 到这里完整的总结一下： 将线程执行器保存到每一个SingleThreadEventExcutor里面去创建了MpscQueu

引言 从本文开始，我们一起来阅读Netty的源码实现，主要针对Netty的核心实现进行进一步的梳理。但是话又说回来，如果我们直接看Netty源码的话，可能不知道该如何下手，大大小小那么多个源码包，就像一团乱麻，千头万绪。所以本文从Netty服务启动开始，根据启动流程来逐渐打开Netty的神秘面纱，理清Netty的技术脉络。 NioEventLoop创建总结 今天是周末，但是生物钟还是准

准备赶趟上春招实习的车，刚开始学netty，感觉项目很简单，所以就想看看源码，非科班看这些是真吃力。。放点小笔记，都是站在巨人的肩膀上总结的(小抄)，加油！ 前置芝士： 需要知道Executor执行器的一些操作。 Demo public class NettyServer { int port; public NettyServer(int port) { this.port = port; }

问题现象 近期我们使用NioEventLoop出现一个奇怪的现象，在消息密集的情况下，服务端处理会断断续续的，一会性能看着又没问题，一会又会阻塞很久再处理消息。经过不断的摸索排查发现是线程池使用不当导致的，我们不妨来看看这个问题的代码。 代码演示 在演示代码之前，我们不妨先来了解一下这个需求，如下图，客户端和服务端建立连接之后，会向该通道不断发送消息。然后服务端收到消息，会将消息提交到业务线

简介 NioEventLoop是Netty基于Java NIO(new I/O)包实现的一个重要组件，它具备以下几个重要的特点： 非阻塞式IO模型：通过非阻塞的IO模型，实现单个线程处理大量并发连接。事件驱动：基于事件驱动模型，管理和执行各种网络操作，例如：数据读写、连接管理、定时任务等，实现高效异步处理。事件队列：NioEventLoop内部包含一个事件队列，它会并按照收到的事件类型分发到对

在Netty中NioEventLoop以及NioEventLoopGroup是很重要的两个类，而NioEventLoopGroup主要是对NioEventLoop进行管理；首先来看一下这两个类的关系图（错综复杂）：

NioEventLoop 任务的执行 今天跟核心方法，关于任务的处理 下面是EventLoop第一次执行execute方法的时候，会触发的逻辑，会执行一个核心Runnable任务，该任务会进行selector的选择，然后处理三类任务，以及I/O就绪事件： 注册、绑定端口、为NioServerChannel的pipline添加连接处理器等任务都会放到任务队列taskQueue，这是一类还有一类是