詳解Node.js串行化流程控制
串行任務:需要一個接著一個坐的任務叫做串行任務。
可以使用回調的方式讓幾個異步任務按順序執(zhí)行,但如果任務過多,必須組織一下,否則過多的回調嵌套會把代碼搞得很亂。
為了用串行化流程控制讓幾個異步任務按順序執(zhí)行,需要先把這些任務按預期的執(zhí)行順序放到一個數(shù)組中,這個數(shù)組將起到隊列的作用:完成一個任務后按順序從數(shù)組中取出下一個。
數(shù)組中的每個任務都是一個函數(shù)。任務完成后應該調用一個處理器函數(shù),告訴它錯誤狀態(tài)和結果。
為了演示如何實現(xiàn)串行化流程控制,我們準備做個小程序,讓它從一個隨機選擇的RSS預定源中獲取一篇文章的標題和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ù)轉換成JavaScript數(shù)據(jù)結構。
在新目錄下創(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]); }); } //向預定源發(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í)行串行化任務 next();
在試用這個程序之前,現(xiàn)在程序腳本所在的目錄下創(chuàng)建一個rss_feeds.txt文件。這里只包含了一條預定源信息:
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)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
Node.js命令行/批處理中如何更改Linux用戶密碼淺析
這篇文章主要給大家介紹了關于Node.js命令行/批處理中如何更改Linux用戶密碼的相關資料,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2018-07-07Windows系統(tǒng)下Node.js安裝以及環(huán)境配置的完美教程
相信對于很多關注javascript發(fā)展的同學來說,nodejs已經(jīng)不是一個陌生的詞眼,下面這篇文章主要給大家介紹了關于Windows系統(tǒng)下Node.js安裝以及環(huán)境配置的完美教程,需要的朋友可以參考下2022-06-06NodeJS?基于?Dapr?構建云原生微服務應用快速入門教程
Dapr?是一個可移植的、事件驅動的運行時,它使任何開發(fā)人員能夠輕松構建出彈性的、無狀態(tài)和有狀態(tài)的應用程序,并可運行在云平臺或邊緣計算中,它同時也支持多種編程語言和開發(fā)框架,本文重點介紹NodeJS云原生微服務應用,感興趣的朋友一起看看吧2022-07-07利用node.js爬取指定排名網(wǎng)站的JS引用庫詳解
最近在學習node.js爬蟲,由于 nodejs 強大的異步特性,讓我們可以輕松以異步高并發(fā)去爬取網(wǎng)站,下面這篇文章主要給大家介紹了關于利用node.js爬取指定排名網(wǎng)站的JS引用庫的相關資料,需要的朋友可以參考下。2017-07-07node?puppeteer爬蟲爬取電影網(wǎng)站及生成pdf文檔示例
這篇文章主要介紹了node?puppeteer爬蟲爬取電影網(wǎng)站及生成pdf文檔使用示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-07-07前端之npm運行時配置文件.npmrc的方法(可用于配置npm淘寶源)
這篇文章主要給大家介紹了關于前端之npm運行時配置文件.npmrc(可用于配置npm淘寶源)的相關資料,.npmrc 文件是用于配置 npm(Node.js 包管理器)行為的配置文件,文中通過代碼介紹的非常詳細,需要的朋友可以參考下2024-07-07