串行任務(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)備做個小程序，讓它從一個隨機(jī)選擇的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ù)定源信息：

之后執(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));