总结分享了解nodejs的几个关键节点

总结分享了解nodejs的几个关键节点

本文是个人在实际开发和学习中对nodejs的一些理解,现整理出来方便日后查阅,如果能给您启发将不胜荣幸。

非阻塞I/O

I/O:即 Input / Output,一个系统的输入和输出。

一个系统可以理解为一个个体,比如说一个人,你说话就是输出,你听就是输入。

阻塞 I/O 与非阻塞 I/O 的区别就在于系统接收输入再到输出期间,能不能接收其他输入

下面以两个例子来说明什么是阻塞 I/O 和非阻塞 I/O:

1、打饭

1.png

首先我们要确定一个系统的范围,在这个例子中食堂阿姨和餐厅的服务生看成是一个系统,输入就是点菜,输出就是端菜

那么在点菜和端菜之间能不能接受其他人的点菜,就可以判断是阻塞I/O还是非阻塞I/O。

对于食堂阿姨,他在点菜的时候,是不能帮其他同学点菜的,只有这个同学点完菜端菜走了之后,才能接受下一个同学的点菜,所以食堂阿姨是阻塞I/O。

对于餐厅服务员,他可以在点完菜以后,这个客人端菜之前是可以服务下一位客人的,所以服务员是非阻塞I/O。

2、做家务

2.png

在洗衣服的时候,是不需要等着洗衣机旁边的,这个时候可以去扫地和整理书桌,当整理完书桌后衣服也洗好了,这个时候去晾衣服,那么总共只需要25分钟。

洗衣服其实就是一个非阻塞I/O,在把衣服扔进洗衣机和洗完衣服期间,你是可以干其他事情的。

非阻塞I/O之所以能提升性能,是因为它可以把不必要的等待给节省掉。

理解非阻塞I/O的要点在于

确定一个进行I/O的系统边界。这非常关键,如果把系统扩大,上面餐厅的例子,如果把系统扩大到整个餐厅,那么厨师肯定是一个阻塞 I/O。在 I/O 过程中,能不能进行其他 I/O。

nodejs的非阻塞 I/O

nodejs的非阻塞 I/O 是怎么体现的呢?前面说过理解非阻塞 I/O 的一个重要点是先确定一个系统边界,node的系统边界就是主线程

如果下面的架构图按照线程的维护划分,左边虚线部分是nodejs线程,右边虚线部分是c++线程。

3.png

现在 nodejs 线程需要去查询数据库,这是一个典型的 I/O 操作,它不会等待 I/O 的结果,而且继续处理其他的操作,它会把大量的计算能力分发到其他的c++线程去计算。

等到结果出来后返回给nodejs线程,在获得结果之前nodejs 线程还能进行其他的I/O操作,所以是非阻塞的。

nodejs 线程 相当于左边部分是服务员,c++ 线程是厨师。

所以,node的非阻塞I/O是通过调用c++的worker threads来完成的。

那当 c++ 线程获取结果后怎么通知 nodejs 线程呢?答案是事件驱动

事件驱动

阻塞:I/O时进程休眠,等待I/O完成后进行下一步; 

非阻塞:I/O时函数立即返回,进程不等待I/O完成。

那怎么知道返回的结果,就需要用到事件驱动

所谓事件驱动可以理解为跟前端点击事件一样,我首先写一个点击事件,但是我不知道什么时候触发,只有触发的时候就去让主线程执行事件驱动函数。

这种模式也是一种观察者模式,就是我首先先监听这个事件,等触发时我就去执行。

那怎么实现事件驱动呢?答案是异步编程

BibiGPT-哔哔终结者 BibiGPT-哔哔终结者

B站视频总结器-一键总结 音视频内容

BibiGPT-哔哔终结者 28 查看详情 BibiGPT-哔哔终结者

异步编程

上面说过nodejs有大量的非阻塞I/O,那么非阻塞I/O的结果是需要通过回调函数来获取的,这种通过回调函数的方式,就是异步编程。比如下面的代码是通过回调函数获取结果的:

glob(__dirname+'/**/*', (err, res) => {    result = res    console.log('get result')})

回调函数格式规范

nodejs的回调函数第一个参数是error,后面的参数才是结果。为什么要这么做呢?

try {  interview(function () {       console.log('smile')  })} catch(err) {    console.log('cry', err)}function interview(callback) {    setTimeout(() => {        if(Math.random() < 0.1) {            callback('success')        } else {            throw new Error('fail')        }    }, 500)}

执行之后,没有被捕获,错误被扔到了全局,导致整个nodejs程序崩溃了。

4.png

没有被try catch捕获是因为setTimeout重新开启了事件循环,每开启一个事件循环就重新生一个调用栈context,try catch是属于上一个事件循环的调用栈的,setTimeout的回调函数执行的时候,调用栈都不一样了,在这个新的调用栈中是没有try catch,所以这个错误被扔到全局,无法捕获。具体可以参考这一篇文章异步队列进行try catch时的问题。

那么怎么办呢?把错误也作为一个参数:

function interview(callback) {    setTimeout(() => {        if(Math.random() < 0.5) {            callback('success')        } else {            callback(new Error('fail'))        }    }, 500)}interview(function (res) {    if (res instanceof Error) {        console.log('cry')        return    }     console.log('smile')})

但是这样就比较麻烦,在回调中还要判断,所以就产生一种约定成熟的规定,第一个参数是err,如果不存在表示执行成功。

function interview(callback) {    setTimeout(() => {        if(Math.random() < 0.5) {            callback(null, 'success')        } else {            callback(new Error('fail'))        }    }, 500)}interview(function (res) {    if (res) {        return    }     console.log('smile')})

异步流程控制

nodejs的回调写法,不仅会带来回调地域,还会带来异步流程控制的问题。

异步流程控制主要是指当并发的时候,怎么来处理并发的逻辑。还是上面的例子,如果你同事面试两家公司,只有当成功面试两家的时候,才可以不面试第三家,那么怎么写这个逻辑呢?需要全局顶一个一个变量count:

var count = 0interview((err) => {    if (err) {        return    }    count++    if (count >= 2) {        // 处理逻辑    }})interview((err) => {    if (err) {        return    }    count++    if (count >= 2) {        // 处理逻辑    }})

像上面这种写法就非常麻烦,且难看。所以,后来就出现了promise,async/await的写法。

promise

当前事件循环得不到的结果,但未来的事件循环会给你结果。很像一个渣男说的话。

promise不仅是一个渣男,还是一个状态机:

pendingfulfilled/resolvedrejectd

const pro = new Promise((resolve, reject) => {    setTimeout(() => {        resolve('2')    }, 200)})console.log(pro) // 打印:Promise {  }

then & .catch

resolved 状态的 promise 会调用后面的第一个 thenrejected 状态的 promise 会调用后面的第一个 catch任何一个 reject 状态且后面没有 .catch 的 promise,都会造成浏览器或者 node 环境的全局错误。uncaught 表示未捕获的错误。

5.png

执行then或者catch会返回一个新的promise,该promise最终状态根据then和catch的回调函数的执行结果决定:

如果回调函数始终是throw new Error,该promise是rejected状态如果回调函数始终是return,该promise是resolved状态但如果回调函数始终是return一个promise,该promise会和回调函数return的promise状态保持一致

function interview() {    return new Promise((resolve, reject) => {        setTimeout(() => {            if (Math.random() > 0.5) {                resolve('success')            } else {                reject(new Error('fail'))            }        })    })}var promise = interview()var promise1 = promise.then(() => {    return new Promise((resolve, reject) => {        setTimeout(() => {            resolve('accept')        }, 400)    })})

promise1的状态是由return里面的promise的状态决定的,也就是return里面的promise执行完后的状态就是promise1的状态。这样有什么好处呢?这样可以解决回调地狱的问题

var promise = interview()    .then(() => {        return interview()    })    .then(() => {        return interview()    })    .then(() => {        return interview()    })    .catch(e => {        console.log(e)    })

then如果返回的promise的状态是rejected,那么会调用后面第一个catch,后面的then就不会在调用了。记住:rejected调用后面的第一个catch,resolved调用后面的第一个then。

promise解决异步流程控制

如果promise仅仅是为了解决地狱回调,太小看promise了,promise最主要的作用是解决异步流程控制问题。下面如果要同时面试两家公司:

function interview() {    return new Promise((resolve, reject) => {        setTimeout(() => {            if (Math.random() > 0.5) {                resolve('success')            } else {                reject(new Error('fail'))            }        })    })}promise    .all([interview(), interview()])    .then(() => {        console.log('smile')    })    // 如果有一家公司rejected,就catch    .catch(() => {        console.log('cry')    })

async/await

sync/await到底是什么:

console.log(async function() {    return 4})console.log(function() {    return new Promise((resolve, reject) => {        resolve(4)    })})

打印的结果一样,也就是async/await是promse的语法糖而已。

我们知道try catch捕获错误是依赖调用栈的,只能捕获到调用栈以上的错误。但是如果使用await后能捕捉到调用栈所有函数的错误。即便这个错误是在另一个事件循环的调用栈抛出的,比如setTimeout。

改造面试代码,可以看到代码精简了很多。

try {    await interview(1)    await interview(2)    await interview(2)} catch(e => {    console.log(e)})

如果是并行任务呢?

await Promise.all([interview(1), interview(2)])

事件循环

因为nodejs的非阻塞 I/0, 所以需要利用事件驱动的方式获取 I/O 的结果,实现事件驱动拿到结果必须使用异步编程,比如回调函数。那么如何来有序的执行这些回调函数来获取结果呢?那就需要使用事件循环。

事件循环是实现 nodejs 非阻塞 I/O 功能的关键基础,非阻塞I/O和事件循环都是属于 libuv 这个c++库提供的能力。

6.png

代码演示:

const eventloop = {    queue: [],    loop() {        while(this.queue.length) {            const callback = this.queue.shift()            callback()        }        setTimeout(this.loop.bind(this), 50)    },    add(callback) {        this.queue.push(callback)    }}eventloop.loop()setTimeout(() => {    eventloop.add(() => {        console.log('1')    })}, 500)setTimeout(() => {eventloop.add(() => {console.log('2')})}, 800)

setTimeout(this.loop.bind(this), 50)保证了50ms就会去看队列中是否有回调,如果有就去执行。这样就形成了一个事件循环。

当然实际的事件要复杂的多,队列也不止一个,比如有一个文件操作对列,一个时间对列。

const eventloop = {    queue: [],    fsQueue: [],    timerQueue: [],    loop() {        while(this.queue.length) {            const callback = this.queue.shift()            callback()        }        this.fsQueue.forEach(callback => {            if (done) {                callback()            }        })        setTimeout(this.loop.bind(this), 50)    },    add(callback) {        this.queue.push(callback)    }}

总结

首先我们弄清楚了什么是非阻塞I/O,即遇到I/O立刻跳过执行后面的任务,不会等待I/O的结果。当I/O处理好了之后就会调用我们注册的事件处理函数,这就叫事件驱动。实现事件驱动就必须要用异步编程,异步编程是nodejs中最重要的环节,它从回调函数到promise,最后到async/await(使用同步的方法写异步逻辑)。

更多node相关知识,请访问:nodejs 教程!

以上就是总结分享了解nodejs的几个关键节点的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/549626.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年11月9日 19:21:46
下一篇 2025年11月9日 19:22:35

相关推荐

  • Debian下Swagger与Kubernetes如何集成

    在Debian操作系统中将Swagger与Kubernetes进行整合,可按照如下流程操作: Debian系统安装Swagger步骤 更新软件包列表并升级已安装的包: sudo apt update && sudo apt upgrade -y 安装Node.js和npm(若尚未安装…

    2025年12月15日
    000
  • Swagger在Debian环境中的性能如何

    OpenAPI规范(即原Swagger)在Debian系统下的运行效率受多种因素影响,包括服务器硬件配置、网络条件、UI与接口的实现方式以及系统的整体优化水平。以下内容将帮助你更好地了解并提升其在Debian平台上的表现: 安装与设置流程 在Debian平台上部署Swagger通常需要先安装Node…

    2025年12月15日
    000
  • Debian系统上Swagger文档如何更新

    在Debian操作系统中对Swagger文档进行更新,通常需要升级Swagger UI或Swagger Editor组件。以下是具体的操作流程: 升级Swagger UI 安装Swagger UI(若尚未完成安装): sudo apt update sudo apt install nodejs n…

    2025年12月15日
    000
  • Debian系统JS依赖如何管理

    本文介绍如何在Debian系统中高效管理JavaScript (JS) 依赖。主要方法是利用Node.js的包管理器npm或Yarn。 方法一:使用npm 安装Node.js和npm: 在终端执行以下命令安装: sudo apt updatesudo apt install nodejs 验证安装:…

    2025年12月15日
    000
  • 如何利用JS日志进行Debian故障排查

    在Debian系统中,JavaScript(JS)日志并非系统故障诊断的首选工具,因为JS主要用于前端Web开发。然而,对于基于Node.js的应用,JS日志能有效帮助定位问题。 以下步骤指导您如何利用JS日志排查Debian系统中Node.js应用的故障: 定位应用: 首先,找到您的Node.js…

    2025年12月15日
    000
  • 如何查看 Debian Node.js 日志

    本文介绍几种在 Debian 系统上查看 Node.js 日志的实用方法。 方法一:利用 systemd 的 journalctl 命令 如果你的 Node.js 应用由 systemd 管理,可以使用 journalctl 命令查看日志。 假设你的 Node.js 服务名称为 my-nodejs-…

    2025年12月15日
    000
  • Debian Node.js 日志中如何查看请求记录

    在 Debian 系统中查找 Node.js 应用的请求日志,需要根据运行环境的不同采取不同的方法: 1. 本地开发环境: 日志通常位于应用的工作目录下,通常是一个名为 logs 的文件夹,包含了应用的日志文件(例如 app.log)。你可以使用文本编辑器或命令行工具 cat 来查看: cat /p…

    2025年12月15日
    000
  • Python 环境如何与 Node.js 并存

    Python 和 Node.js 可在同一台机器上共存,因二者运行时和包管理独立。1. 分别从官方渠道安装 Python 和 Node.js,确保 PATH 正确;2. 使用 pyenv 和 nvm 管理多版本切换,互不干扰;3. 通过 venv 和 node_modules 隔离项目依赖,避免冲突…

    2025年12月14日
    000
  • Node.js版本升级后node-gyp构建错误及解决方案

    本文旨在解决node.js版本升级至20.9.0后,执行`npm install`时遇到的`node-gyp`构建错误,特别是涉及`fetcherror`导致无法下载node.js头文件的问题。文章将分析错误根源,并提供使用yarn作为有效替代方案,同时探讨其他通用的`node-gyp`故障排除策略…

    2025年12月14日
    000
  • Node.js 版本升级中 node-gyp 错误排查与 Yarn 解决方案

    在将 Node.js 版本升级至 20.9.0 等新版本时,开发者常遇到 `node-gyp` 编译原生模块的错误,尤其表现为 Python 环境配置不当或网络下载 Node.js 头文件失败。本文将深入分析这些错误的原因,提供 Python 和构建工具的排查方法,并重点介绍如何通过切换到 Yarn…

    2025年12月14日
    000
  • Node.js版本升级中Node-gyp错误解析与解决方案

    针对node.js版本升级(特别是node 20.9.0)过程中常见的node-gyp编译错误,本教程深入分析了其潜在原因,包括网络连接问题、tls证书验证失败以及python环境配置不当。文章重点推荐使用yarn作为解决依赖冲突和构建问题的有效策略,并提供了其他针对性排查和修复建议,旨在帮助开发者…

    2025年12月14日
    000
  • Stack Exchange API:轻松获取问题正文内容的教程

    本文详细介绍了如何使用Stack Exchange API高效地检索问题正文内容。针对API默认仅返回问题标题的常见困惑,教程阐明了通过在API请求中添加filter=’withbody’参数即可直接获取包含HTML格式的正文,无需进行额外的请求或复杂的解析。通过具体的Pyt…

    2025年12月14日 好文分享
    000
  • 解决Shaka Player编译时Node.js依赖路径缺失问题

    在编译Shaka Player时,用户可能遇到Node.js依赖缺失的错误,即使Node.js已正确安装。本文揭示了该问题通常并非Node.js本身的问题,而是项目目录路径过长或位于特殊位置(如下载文件夹)导致构建工具无法正确解析依赖。解决方案简单直接:将Shaka Player项目文件夹移动到一个…

    2025年12月14日
    000
  • 解决Shaka Player编译失败:Node.js依赖缺失与项目路径优化

    本教程旨在解决Shaka Player编译时遇到的Node.js依赖缺失错误。该问题常因项目目录位于用户特定路径(如Downloads)引起。核心解决方案是将Shaka Player项目移动到更简洁的根目录,从而规避潜在的权限或路径解析问题,确保编译过程顺利进行。 引言:Shaka Player编译…

    2025年12月14日
    000
  • 解决Shaka Player编译错误:Node.js依赖路径问题

    本教程旨在解决Shaka Player编译过程中常见的“Node.js依赖缺失”错误,即使Node.js已正确安装。该问题通常并非Node.js本身的问题,而是由Shaka Player项目文件夹位于过长、包含特殊字符或权限受限的路径(如Downloads文件夹)所导致。通过将项目移动到更简洁的根目…

    2025年12月14日
    000
  • GAE跨服务任务提交策略:从Python服务调度Node.js任务

    本文详细阐述了在Google App Engine (GAE) 环境中,如何实现从一个服务(如Python)提交任务,并由另一个服务(如Node.js)执行的策略。核心方法包括:利用dispatch.yaml配置基于URL路径的任务路由,使relative_uri直接指向目标服务;或采用间接方式,通…

    2025年12月14日
    000
  • Google App Engine 跨服务任务调度策略与实践

    在Google App Engine (GAE) 中,当您使用任务队列(Task Queues)提交异步任务时,默认情况下,这些任务通常由提交任务的服务自身来执行。然而,在多服务架构中,我们可能需要从一个服务(例如Python服务)提交任务,并指定由另一个服务(例如Node.js服务)来处理和执行。…

    2025年12月14日
    000
  • GAE 任务跨服务执行:Python 到 NodeJS 的任务调度

    本文旨在解决 Google App Engine (GAE) 应用中,任务需要在不同服务之间调度执行的问题。假设你有一个使用 Python3 编写的默认服务和一个使用 NodeJS18 编写的服务。现在需要从 Python3 服务提交一个任务,并让 NodeJS18 服务来执行这个任务。 在使用 g…

    2025年12月14日
    000
  • 使用Nodejs,Python,Sveltekit和Tailwindcss构建AI驱动的财务数据分析仪 – 第0部分

    打造AI驱动的财务数据分析仪:系统架构与技术选型 在软件工程领域,紧跟技术潮流至关重要。最近,我重新学习了node.js(express.js)并着手一个新项目,目标是结合ai技术,打造一个强大的财务数据分析工具。本文将介绍该项目的整体架构和技术选型,后续文章将深入探讨具体实现细节。 该系统由前端、…

    2025年12月13日
    000
  • (Odoo 系列)- Ubuntu 桌面上的#Simple Odoo 开发

    致敬社区开发者! Odoo(前身为OpenERP)已成为全球最受欢迎的企业资源规划(ERP)系统之一,拥有超过700万用户,为各种规模和类型的组织提供全面、灵活的集成业务解决方案。Odoo是由比利时公司Odoo S.A.开发的开源ERP平台,自2005年推出以来,已从简单的业务管理系统发展成为涵盖企…

    2025年12月13日 好文分享
    000

发表回复

登录后才能评论
关注微信