1.node stream源码分析 — Readable
2.nodejs之setImmediate源码分析
3.nodejs 14.0.0源码分析之setImmediate
4.nodejs EventEmitter 源码分析
5.node-http-proxy 源码解读
6.nodejs原理&源码赏析（7）Node.js中的论坛事件循环，定时器和process.nextTick

node stream源码分析 — Readable

       Stream在Node.js中是源码源码一种数据传输的抽象机制，它分为四种类型：流、论坛可读流（Readable）、源码源码可写流（Writable）和可缓冲流（Transform）。论坛其中，源码源码游戏多开器源码可读流（Readable）用于从外部数据源读取数据。论坛

       可读流有两种模式：流动模式和非流动模式。源码源码非流动模式在监听到'data'事件时，论坛直接读取数据而不暂停，源码源码并不将数据存储到缓存区。论坛流动模式则在监听到'readable'事件时，源码源码将数据放入缓存区，论坛并等待'writable'调用来判断是源码源码否有空位，以此来决定是论坛否暂停。

       以下是对可读流（Readable）的源码分析。首先，让我们查看Readable的源码。源码文件位于'_stream_readable.js'中。

       在'fs.js'文件中，我们可以看到创建读取流的源码，而'Readable'则位于'_stream_readable.js'文件中。

       在'fs.js'文件中，我们可以通过调用`fs.createReadStream`来创建读取流。在'Readable'源码文件中，我们可以看到Node.js实现的可读流类，它提供了读取数据的端口延迟检测源码功能，并且支持缓冲和流式读取。

nodejs之setImmediate源码分析

       在lib/timer.js文件中，setImmediate函数创建了一个回调队列，等待调用者提供的回调函数执行。这个队列的处理由setImmediateCallback函数负责，该函数在timer_wrapper.cc文件中定义，接受processImmediate作为参数。在setImmediateCallback函数内部，回调信息被保存在环境env中。

       具体实现中，set_immediate_callback_function宏定义了在env中保存回调函数的函数。此函数在env.cc的CheckImmediate中执行，而CheckImmediate的执行时机是在Environment::Start阶段，由uv_check_start函数在libuv库中负责。

       uv_check_start函数将一个handle添加到loop的队列中，然后在uv_run循环中执行注册的CheckImmediate函数。此函数最终会调用nodejs的processImmediate函数，实现setImmediate的回调执行。

       需要注意的是，setImmediate与setTimeout的执行顺序并不确定。在uv_run中，定时器的代码比uvrun_check早执行，但在执行完定时器后，若在uv__run_check之前新增定时器和执行setImmediate，setImmediate的回调会优先执行。

nodejs .0.0源码分析之setImmediate

       深入解析Node.js .0.0中setImmediate的opencv blur函数源码实现机制

       从setImmediate函数的源码入手，我们首先构建一个Immediate对象。这个对象的主要任务分为两个方面。其一，生成一个节点并将其插入到链表中。其二，在链表中尚未插入节点时，将其插入到libuv的idle链表中。

       这一过程展示了setImmediate作为一个生产者的作用，负责将任务加入待执行队列。而消费者的角色则在Node.js初始化阶段由check阶段插入的节点和关联的回调函数承担。

       具体而言，当libuv执行check阶段时，CheckImmediate函数被触发。此函数随后执行immediate_callback_function，对immediate链表中的节点进行处理。我们关注immediate_callback_function的设置位置，理解其实际功能。

       最终，processImmediate函数成为处理immediate链表的核心，执行所有待处理任务。这就是setImmediate的执行原理，一个简洁高效的异步任务调度机制。

nodejs EventEmitter 源码分析

       EventEmitter 是 Node.js 中的事件管理器核心逻辑简单，主要聚焦于事件与函数或函数数组之间的关联。在 v..1 版本中，核心逻辑在实例的图像处理 源码学习 _events 属性上展开，该属性是一个对象，其键为事件名称，值为事件对应的函数或函数数组。所有方法均围绕 _events 展开。

       构造函数初始化 _events 属性，若实例本身未定义，则执行此操作。此操作涉及对实例原型的引用，通过 ObjectGetPrototypeOf 的使用来实现。函数 on 允许用户注册事件监听器，逻辑简单明了：判断同名事件是否已注册，无则注册；已有则将新监听器加入已有函数数组中。emit 方法触发事件，根据事件名称获取对应函数或函数数组，使用 ReflectApply 调用。此方法与 Function.prototype.apply 类似，但提供了更简洁的实现。

       off 方法与 on 方法相似，但逻辑相反。它获取事件监听器，若为函数，则直接删除；若为数组，则遍历删除指定监听器。此方法同样简洁，直接操作事件列表。

       Reflect API 的windows编译python源码使用在不同版本的 EventEmitter 中逐渐增多，例如将 Object.keys 替换为 Reflect.ownKeys，以更好地处理 Symbol 类型的事件名。反射方法，如 Reflect.apply，尽管在 V8 中源码显得复杂，但其执行逻辑与 Function.prototype.apply 相似，性能上并无显著提升，但提升了代码的可读性。

       在最新版本 v.5.0 中，EventEmitter 的实现中采用 Reflect.ownKeys 更为合理，因为此方法能有效避免返回数组中无 Symbol 的问题。EventEmitter 的构造函数与 Stream 的关系展示了如何利用继承来扩展功能。Stream 通过继承 EventEmitter，实现了更简洁的 class 写法，未来可能进一步简化。

       此外，文章还讨论了私有属性的使用，以及简易版 EventEmitter 的实现。简易版 EventEmitter 基本逻辑简洁，但不包含参数校验、异常处理和性能优化等生产环境所需的功能。实际生产环境中的 EventEmitter 实现则需额外处理这些复杂情况。

node-mon.setupOutgoing的实现；其次，stream的实现；最后，查看源码了解web-outgoing模块对代理响应的处理。setRedirectHostRewrite函数的代码实现也在这里。

       在websocket请求中，this.wsPasses任务队列包含四种处理函数：checkMethodAndHeader, XHeaders, stream。stream函数的处理流程同上。

       http-proxy-middleware和nokit-filter-proxy库都使用了node-http-proxy来实现服务器代理功能。http-proxy-middleware库的源码解读可以参考相关文章。nokit-filter-proxy库用于为nokit服务器添加代理功能，它是通过绑定onRequest事件函数来实现请求的拦截和转发的。

       这两篇文章都是在作者整理完proxy设计模式后整理的。由于作者水平有限，文章中可能存在错误或不足之处，欢迎读者批评指正。

nodejs原理&源码赏析（7）Node.js中的事件循环，定时器和process.nextTick

       事件循环是Node.js的核心机制，确保了其非阻塞I/O模型的实现。尽管JavaScript在Node.js中是单线程运行的，它却能利用系统内核的多线程特性处理并发任务。Node.js在开始执行时初始化事件循环，处理脚本文件或REPL环境中的异步调用。事件循环通过检查异步I/O、定时器和process.nextTick调用，然后进入各个阶段，处理回调函数。每个阶段维护一个先进先出的回调队列，处理与阶段相关操作后执行队列中的回调，直至队列为空或达到最大函数执行数量。系统操作回调、定时器和处理关闭回调的阶段各有功能。setImmediate()与setTimeout()相似，但执行顺序受调用上下文影响，setImmediate()在I/O周期中通常优先执行。process.nextTick()则在当前操作执行后立即执行回调，不受事件循环阶段限制，但需谨慎使用以防阻塞事件循环。

从 pm2 看 node 多进程管理(一)：进程创建

       pm2 是 Node 社区中领先的进程管理工具。本文基于 pm2 v4.5.0 的源码，聚焦于功能层面，深入探讨其模块结构和进程创建流程。

       pm2 的核心模块包含 API 类的实例，API 初始化时会设置默认配置、用户传入配置，并生成 Client 实例。pm2 多进程管理支持两种创建入口：脚本文件或 JSON 配置，依据用户输入自动选择。

       在系统中无 pm2 创建的守护进程时，使用 cluster 模式执行脚本后，pm2 将执行如下操作：确定进程创建入口、创建守护进程、建立与 rpc 服务的连接、启动工作进程和执行应用。

       确定进程创建入口时，pm2 会根据脚本文件或 JSON 配置选择启动方式。_startJson 方法作为入口，初始化配置并启动应用进程。

       创建守护进程前，pm2 调用 Client.executeRemote('getMonitorData') 方法获取系统存活进程信息。若无守护进程，pm2 优先创建守护进程，通过创建 rpc.Client 实例与 rpc.Server 连接，实现与 Daemon 模块交互。在 Daemon 初始化时，pm2 会根据传入参数判断是否直接启动或作为守护进程启动。

       pm2 使用 child_process.spawn 启动 Daemon 进程，之后绑定 PubEmitter 和 RepSocket socket，实现与 Client 和 God 模块的通信。一旦 socket 连接成功，pm2 会通知 Client 建立与 RepSocket server 的连接，供后续操作。

       建立好 Daemon 进程和 rpc 连接后，pm2 通过 Client.executeRemote('prepare') 方法创建新进程，实现与 God 模块的直接调用。

       pm2 支持 cluster 和 fork 模式启动应用进程，具体实现细节不在本文赘述。值得注意的是，pm2 提供了优雅启动功能，允许应用在依赖环境准备完成后才启动，只需在准备就绪后向 pm2 发送 'ready' 消息。

       pm2 从头创建进程的一般过程可总结为：确定入口、创建守护进程、建立 rpc 连接、启动应用进程。此流程确保了高效、灵活的进程管理。

node-pre-gyp以及node-gyp的源码简单解析（以安装sqlite3为例）

       在Node.js开发中，确保模块跨平台性至关重要，尤其当涉及到使用C/C++原生代码的模块，如SQLite3。让我们通过一个实例来理解安装这种原生模块的过程，以SQLite3为例。

       项目初始化

       首先，创建一个基础的Node.js项目，我们开始安装SQLite3。

       安装SQLite3

       执行安装命令后，你会看到命令行输出关键信息：

       node-pre-gyp的引入

       在安装过程中，你会遇到node-pre-gyp，这个工具与node-gyp和gyp紧密相关。gyp是一个用于生成项目文件的构建工具，它为Chromium项目生成IDE项目文件，如Visual Studio和Xcode。而node-gyp则是专为Node.js Addons（原生模块）编译设计的，它允许在本地编译C/C++代码。

       node-pre-gyp的作用

       为了简化每次安装时的平台编译工作，node-pre-gyp允许预先为常见平台生成二进制文件。当项目尝试安装时，它会优先查找预编译的二进制包，如果找不到，才会转而依赖node-gyp进行源码编译。

       安装流程

       当我们使用`npm install sqlite3`时，实际上执行了`node-pre-gyp install --fallback-to-build`。安装流程包括：

       检查node-pre-gyp是否已安装，如果没有，npm会自动安装。

       node-pre-gyp查找预编译二进制包，如果存在，则直接使用。

       如果没有找到，使用node-gyp进行源码编译。

       深入了解SQLite3安装

       查看sqlite3的package.json，`scripts`部分包含了`node-pre-gyp install`命令。npm会根据这个脚本执行安装过程。

       源码编译与node-gyp

       node-gyp的`build.js`负责执行编译任务，通过`gyp`工具生成特定平台的项目文件，如Windows的vcxproj，然后使用MSBuild编译。

       node-pre-gyp与node-gyp的交互

       node-pre-gyp的`do_build`模块调用node-gyp build，执行具体的编译操作，确保模块能在目标平台上正确工作。