Node.js 异步编程深度解析:回调函数、Promise 以及 async/await

2024-09-05 17:28

本文主要是介绍Node.js 异步编程深度解析:回调函数、Promise 以及 async/await,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Node.js 异步编程深度解析:回调函数、Promise 以及 async/await


目录

  1. 🔄 回调函数的基础与挑战
  2. 💬 Promise 的使用与链式调用
  3. 🚀 async/await 的简化与异常处理

🔄 回调函数的基础与挑战

回调函数的基本用法

回调函数是 Node.js 异步编程的基础,通过将函数作为参数传递给异步操作,可以在异步操作完成时执行特定的逻辑。回调函数的基本用法涉及到将一个函数传递给另一个函数,当异步操作完成时,该函数会被调用。这样的机制允许 Node.js 在处理 I/O 操作时保持高效的非阻塞性能。

例如,在读取文件时,Node.js 的 fs 模块提供了 fs.readFile() 方法,该方法接受一个回调函数,回调函数将在文件读取完成后被执行:

const fs = require('fs');// 异步读取文件内容
fs.readFile('example.txt', 'utf8', (err, data) => {if (err) {// 处理文件读取错误console.error('文件读取失败:', err);return;}// 输出文件内容console.log('文件内容:', data);
});

在这个例子中,fs.readFile() 方法接收三个参数:文件路径、字符编码和一个回调函数。当文件读取完成时,回调函数被调用。如果发生错误,错误对象 err 将被传递给回调函数;否则,文件内容将作为 data 参数传递。

回调地狱

回调地狱是指当多个异步操作依赖于彼此时,嵌套的回调函数可能会导致代码难以维护和阅读。这种情况通常发生在需要顺序执行多个异步操作时,嵌套的回调会导致代码变得复杂和难以理解。例如:

const fs = require('fs');// 读取多个文件并将内容合并
fs.readFile('file1.txt', 'utf8', (err, data1) => {if (err) throw err;fs.readFile('file2.txt', 'utf8', (err, data2) => {if (err) throw err;fs.readFile('file3.txt', 'utf8', (err, data3) => {if (err) throw err;console.log('合并后的内容:', data1 + data2 + data3);});});
});

上述代码中,每个异步操作都依赖于前一个操作的结果,使得代码嵌套越来越深。这种层层嵌套的回调函数使得代码变得冗长和难以维护,通常被称为回调地狱。为了克服这个问题,现代 JavaScript 提供了 Promiseasync/await 等异步编程解决方案,这些方案能够提供更清晰的代码结构。

改善方法

通过使用 Promise 和 async/await,可以有效地减少回调地狱的问题,使得异步操作的代码更加简洁和易于维护。例如,使用 Promise 可以将多个异步操作串联起来,从而避免深层嵌套的回调函数:

const fs = require('fs').promises;async function readFiles() {try {const data1 = await fs.readFile('file1.txt', 'utf8');const data2 = await fs.readFile('file2.txt', 'utf8');const data3 = await fs.readFile('file3.txt', 'utf8');console.log('合并后的内容:', data1 + data2 + data3);} catch (err) {console.error('文件读取失败:', err);}
}readFiles();

在这个例子中,使用 async/await 语法可以将异步操作写成类似于同步代码的形式,从而提高了代码的可读性和可维护性。


💬 Promise 的使用与链式调用

Promise 的基本用法

Promise 是 JavaScript 中处理异步操作的主要方式之一。Promise 对象代表一个异步操作的最终完成(或失败)及其结果值。Promise 的基本用法包括创建一个新的 Promise 对象并使用 .then().catch() 方法处理异步操作的结果。

const fs = require('fs').promises;// 创建一个 Promise 对象
const readFilePromise = fs.readFile('example.txt', 'utf8');// 使用 .then() 方法处理成功的结果
readFilePromise.then(data => {console.log('文件内容:', data);
}).catch(err => {// 使用 .catch() 方法处理错误console.error('文件读取失败:', err);
});

在这个例子中,fs.readFile() 方法返回一个 Promise 对象,该对象在文件读取完成时会被解决(fulfilled),或者在出现错误时会被拒绝(rejected)。通过调用 .then() 方法,可以处理成功的结果;通过调用 .catch() 方法,可以处理失败的结果。

链式调用

Promise 允许链式调用,通过 .then() 方法可以链式地处理多个异步操作。在链式调用中,每个 .then() 方法都会返回一个新的 Promise 对象,从而可以在后续的 .then() 方法中继续处理:

const fs = require('fs').promises;// 链式调用读取多个文件
fs.readFile('file1.txt', 'utf8').then(data1 => {return fs.readFile('file2.txt', 'utf8').then(data2 => {return data1 + data2;});}).then(combinedData => {console.log('合并后的内容:', combinedData);}).catch(err => {console.error('文件读取失败:', err);});

在这个例子中,通过链式调用将多个异步操作串联在一起,每个 .then() 方法都返回一个新的 Promise 对象,从而实现了顺序执行多个异步操作。

错误处理

在使用 Promise 时,错误处理可以通过 .catch() 方法实现。.catch() 方法用于捕获链式调用中的任何错误,从而避免程序崩溃并提供合适的错误处理逻辑:

const fs = require('fs').promises;// 链式调用和错误处理
fs.readFile('file1.txt', 'utf8').then(data1 => {return fs.readFile('file2.txt', 'utf8').then(data2 => {return data1 + data2;});}).then(combinedData => {console.log('合并后的内容:', combinedData);}).catch(err => {console.error('文件读取失败:', err);});

在这个例子中,任何在 .then() 方法中发生的错误都会被 .catch() 捕获,并进行相应的处理。这种错误处理机制使得代码更加健壮,并且能够处理异步操作中的各种错误情况。


🚀 async/await 的简化与异常处理

async 函数的定义

async 关键字用于定义异步函数,异步函数会自动返回一个 Promise 对象。通过使用 async 函数,可以将异步操作的代码写成类似于同步代码的形式,从而提高代码的可读性。

const fs = require('fs').promises;// 定义 async 函数
async function readFile() {try {const data = await fs.readFile('example.txt', 'utf8');console.log('文件内容:', data);} catch (err) {console.error('文件读取失败:', err);}
}readFile();

在这个例子中,readFile 函数被定义为 async 函数,并且使用 await 表达式等待异步操作完成。async 函数会自动将其返回值包装成一个 Promise 对象,并且可以使用 await 等待异步操作的结果。

await 表达式的使用

await 表达式用于等待异步操作完成,并获取其结果。await 必须在 async 函数内部使用,并且会暂停 async 函数的执行,直到异步操作完成。这样可以简化异步代码的逻辑,使其更接近同步代码的形式。

const fs = require('fs').promises;// 使用 async/await 读取文件
async function readFile() {try {const data = await fs.readFile('example.txt', 'utf8');console.log('文件内容:', data);} catch (err) {console.error('文件读取失败:', err);}
}readFile();

在这个例子中,await 表达式等待 fs.readFile() 方法返回的 Promise 完成,并获取文件内容。通过 try...catch 结构处理异步操作中的错误,使得代码逻辑更加清晰

异常处理

async 函数中,异常处理可以通过 try...catch 结构实现。通过 try...catch 结构可以捕获 await 表达式中抛出的异常,并进行相应的处理:

const fs = require('fs').promises;// 使用 async/await 读取文件并处理异常
async function readFile() {try {const data = await fs.readFile('example.txt', 'utf8');console.log('文件内容:', data);} catch (err) {console.error('文件读取失败:', err);}
}readFile();

在这个例子中,如果 fs.readFile() 方法抛出错误,catch 块将会捕获并处理这些错误。这种异常处理机制使得 async 函数能够处理异步操作中的各种错误情况,并保证代码的健壮性。

这篇关于Node.js 异步编程深度解析:回调函数、Promise 以及 async/await的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1139601

相关文章

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库,完全使用 Python 语言编写,它对 XPath表达式提供了良好的支 持,因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块,该模块专门用来解析 HTML/XML 文档,下面来介绍一下 lxml 库

JS常用组件收集

收集了一些平时遇到的前端比较优秀的组件,方便以后开发的时候查找!!! 函数工具: Lodash 页面固定: stickUp、jQuery.Pin 轮播: unslider、swiper 开关: switch 复选框: icheck 气泡: grumble 隐藏元素: Headroom

hdu1171(母函数或多重背包)

题意:把物品分成两份,使得价值最接近 可以用背包,或者是母函数来解,母函数(1 + x^v+x^2v+.....+x^num*v)(1 + x^v+x^2v+.....+x^num*v)(1 + x^v+x^2v+.....+x^num*v) 其中指数为价值,每一项的数目为(该物品数+1)个 代码如下: #include<iostream>#include<algorithm>

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码: 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口,https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如,在当前目录下创建一个名为 myenv 的虚拟环境: python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行: source myenv/bin/activate 3.与notebook连接 在虚拟环境中,使用 pip 安装 Jupyter 和 ipykernel: pip instal

在JS中的设计模式的单例模式、策略模式、代理模式、原型模式浅讲

1. 单例模式(Singleton Pattern) 确保一个类只有一个实例,并提供一个全局访问点。 示例代码: class Singleton {constructor() {if (Singleton.instance) {return Singleton.instance;}Singleton.instance = this;this.data = [];}addData(value)

Node.js学习记录(二)

目录 一、express 1、初识express 2、安装express 3、创建并启动web服务器 4、监听 GET&POST 请求、响应内容给客户端 5、获取URL中携带的查询参数 6、获取URL中动态参数 7、静态资源托管 二、工具nodemon 三、express路由 1、express中路由 2、路由的匹配 3、路由模块化 4、路由模块添加前缀 四、中间件

基于UE5和ROS2的激光雷达+深度RGBD相机小车的仿真指南(五):Blender锥桶建模

前言 本系列教程旨在使用UE5配置一个具备激光雷达+深度摄像机的仿真小车,并使用通过跨平台的方式进行ROS2和UE5仿真的通讯,达到小车自主导航的目的。本教程默认有ROS2导航及其gazebo仿真相关方面基础,Nav2相关的学习教程可以参考本人的其他博客Nav2代价地图实现和原理–Nav2源码解读之CostMap2D(上)-CSDN博客往期教程: 第一期:基于UE5和ROS2的激光雷达+深度RG

韦季李输入法_输入法和鼠标的深度融合

在数字化输入的新纪元,传统键盘输入方式正悄然进化。以往,面对实体键盘,我们常需目光游离于屏幕与键盘之间,以确认指尖下的精准位置。而屏幕键盘虽直观可见,却常因占据屏幕空间,迫使我们在操作与视野间做出妥协,频繁调整布局以兼顾输入与界面浏览。 幸而,韦季李输入法的横空出世,彻底颠覆了这一现状。它不仅对输入界面进行了革命性的重构,更巧妙地将鼠标这一传统外设融入其中,开创了一种前所未有的交互体验。 想象