詳解Node.js串行化流程控制
串行任務(wù):需要一個接著一個坐的任務(wù)叫做串行任務(wù)。
可以使用回調(diào)的方式讓幾個異步任務(wù)按順序執(zhí)行,但如果任務(wù)過多,必須組織一下,否則過多的回調(diào)嵌套會把代碼搞得很亂。
為了用串行化流程控制讓幾個異步任務(wù)按順序執(zhí)行,需要先把這些任務(wù)按預(yù)期的執(zhí)行順序放到一個數(shù)組中,這個數(shù)組將起到隊列的作用:完成一個任務(wù)后按順序從數(shù)組中取出下一個。
數(shù)組中的每個任務(wù)都是一個函數(shù)。任務(wù)完成后應(yīng)該調(diào)用一個處理器函數(shù),告訴它錯誤狀態(tài)和結(jié)果。
為了演示如何實現(xiàn)串行化流程控制,我們準(zhǔn)備做個小程序,讓它從一個隨機選擇的RSS預(yù)定源中獲取一篇文章的標(biāo)題和URL,并顯示出來。
需要從npm存儲苦衷下載兩個輔助模塊,在命令行中(以mac系統(tǒng)為例)輸入以下命令:
mkdir random_story cd random_story npm install request npm install htmlparser
request模塊是個簡化的HTTP客戶端,可以獲取RSS數(shù)據(jù)。htmlparser模塊能夠把原始的RSS數(shù)據(jù)轉(zhuǎn)換成JavaScript數(shù)據(jù)結(jié)構(gòu)。
在新目錄下創(chuàng)建一個random_story.js文件,包含以下代碼:
var fs = require('fs'); var request = require('request'); var htmlparser = require('htmlparser'); var configFilename = './rss_feeds.txt'; //確保包含RSS訂閱列表的文件存在 function checkForRSSFile() { fs.exists(configFilename, function(exists) { if (!exists) { return next(new Error('Missing RSS file: ' + configFilename)); } next(null, configFilename); }); } //讀取并解析包含RSS訂閱列表的文件 function readRSSFile(configFilename) { fs.readFile(configFilename, function(err, feedList) { if (err) { return next(err); } feedList = feedList.toString().replace(/^\s+|\s+$/g, '').split("\n"); var random = Math.floor(Math.random()*feedList.length); next(null, feedList[random]); }); } //向預(yù)定源發(fā)送HTTP請求以獲取數(shù)據(jù) function downloadRSSFeed(feedUrl) { request({uri: feedUrl}, function(err, res, body) { if (err) { return next(err); } if (res.statusCode !== 200) { return next(new Error('Abnormal response status code')); } next(null, body); }); } //解析到一個條目數(shù)組中 function parseRSSFeed(rss) { var handler = new htmlparser.RssHandler(); var parser = new htmlparser.Parser(handler); parser.parseComplete(rss); if (!handler.dom.items.length) { return next(new Error('No RSS items found.')); } var item = handler.dom.items.shift(); console.log(item.title); console.log(item.link); } var tasks = [ checkForRSSFile, readRSSFile, downloadRSSFeed, parseRSSFeed ]; function next(err, result) { if (err) { throw err; } var currentTask = tasks.shift(); if (currentTask) { currentTask(result); } } //開始執(zhí)行串行化任務(wù) next();
在試用這個程序之前,現(xiàn)在程序腳本所在的目錄下創(chuàng)建一個rss_feeds.txt文件。這里只包含了一條預(yù)定源信息:
http://dave.smallpict.com/rss.xml
之后執(zhí)行腳本:
node random_story.js
返回信息如上圖。成功實現(xiàn)了一個串行化流程控制。
[async/await形式的串行化流程控制]
之后將源代碼改寫了一下,改寫成ES7的async/await形式。水平有限,如有錯誤請指出!
let fs = require('fs'); let request = require('request'); let htmlparser = require('htmlparser'); let configFilename = './rss_feeds.txt'; function checkForRSSFile() { return new Promise((resolve, reject) => { fs.exists(configFilename, (exists) => { if (!exists) { reject(new Error('Missing RSS file: ' + configFilename)); } resolve(); }); }); } function readRSSFile(configFilename) { return new Promise((resolve, reject) => { fs.readFile(configFilename, (err, feedList) => { if (err) { reject(err); } feedList = feedList.toString().replace(/^\s+|\s+$/g, '').split("\n"); let random = Math.floor(Math.random()*feedList.length); resolve(feedList[random]); }); }); } function downloadRSSFeed(feedUrl) { return new Promise((resolve, reject) => { request({uri: feedUrl}, (err, res, body) => { if (err) { reject(err); } if (res.statusCode !== 200) { reject(new Error('Abnormal response status code')); } resolve(body); }); }); } function parseRSSFeed(rss) { let handler = new htmlparser.RssHandler(); let parser = new htmlparser.Parser(handler); parser.parseComplete(rss); if (!handler.dom.items.length) { throw new Error('No RSS items found.'); } let item = handler.dom.items.shift(); console.log(item.title); console.log(item.link); } async function getRSSFeed() { await checkForRSSFile(); let url = await readRSSFile(configFilename); let rss = await downloadRSSFeed(url); return rss; } getRSSFeed().then(rss => parseRSSFeed(rss), e => console.log(e));
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Node.js命令行/批處理中如何更改Linux用戶密碼淺析
這篇文章主要給大家介紹了關(guān)于Node.js命令行/批處理中如何更改Linux用戶密碼的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2018-07-07Windows系統(tǒng)下Node.js安裝以及環(huán)境配置的完美教程
相信對于很多關(guān)注javascript發(fā)展的同學(xué)來說,nodejs已經(jīng)不是一個陌生的詞眼,下面這篇文章主要給大家介紹了關(guān)于Windows系統(tǒng)下Node.js安裝以及環(huán)境配置的完美教程,需要的朋友可以參考下2022-06-06NodeJS基礎(chǔ)API搭建服務(wù)器詳細過程記錄
本文將以一個超小型web項目,來詳細介紹如何使用NodeJS基礎(chǔ)的http, fs, path, url等模塊提供的API來搭建一個簡單的web服務(wù)器。具有很好的參考價值。下面跟著小編一起來看下吧2017-04-04NodeJS?基于?Dapr?構(gòu)建云原生微服務(wù)應(yīng)用快速入門教程
Dapr?是一個可移植的、事件驅(qū)動的運行時,它使任何開發(fā)人員能夠輕松構(gòu)建出彈性的、無狀態(tài)和有狀態(tài)的應(yīng)用程序,并可運行在云平臺或邊緣計算中,它同時也支持多種編程語言和開發(fā)框架,本文重點介紹NodeJS云原生微服務(wù)應(yīng)用,感興趣的朋友一起看看吧2022-07-07Node.js之如何創(chuàng)建TCP服務(wù)器端
這篇文章主要介紹了Node.js之如何創(chuàng)建TCP服務(wù)器端問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-09-09利用node.js爬取指定排名網(wǎng)站的JS引用庫詳解
最近在學(xué)習(xí)node.js爬蟲,由于 nodejs 強大的異步特性,讓我們可以輕松以異步高并發(fā)去爬取網(wǎng)站,下面這篇文章主要給大家介紹了關(guān)于利用node.js爬取指定排名網(wǎng)站的JS引用庫的相關(guān)資料,需要的朋友可以參考下。2017-07-07node?puppeteer爬蟲爬取電影網(wǎng)站及生成pdf文檔示例
這篇文章主要介紹了node?puppeteer爬蟲爬取電影網(wǎng)站及生成pdf文檔使用示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-07-07前端之npm運行時配置文件.npmrc的方法(可用于配置npm淘寶源)
這篇文章主要給大家介紹了關(guān)于前端之npm運行時配置文件.npmrc(可用于配置npm淘寶源)的相關(guān)資料,.npmrc 文件是用于配置 npm(Node.js 包管理器)行為的配置文件,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2024-07-07