欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

詳解Node.js串行化流程控制

 更新時間:2017年05月04日 08:27:51   作者:ZhangCui  
這篇文章主要介紹了詳解Node.js串行化流程控制 ,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧

串行任務(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用戶密碼淺析

    Node.js命令行/批處理中如何更改Linux用戶密碼淺析

    這篇文章主要給大家介紹了關(guān)于Node.js命令行/批處理中如何更改Linux用戶密碼的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2018-07-07
  • Node中解決接口跨域問題詳解

    Node中解決接口跨域問題詳解

    在 Node 中編寫接口時,我們常常會遇到跨域問題,通過本篇文章,我們來聊聊如何解決 Node 中接口的跨域問題,文中代碼示例介紹了非常詳細,需要的朋友可以借鑒一下
    2023-04-04
  • Windows系統(tǒng)下Node.js安裝以及環(huán)境配置的完美教程

    Windows系統(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-06
  • NodeJS基礎(chǔ)API搭建服務(wù)器詳細過程記錄

    NodeJS基礎(chǔ)API搭建服務(wù)器詳細過程記錄

    本文將以一個超小型web項目,來詳細介紹如何使用NodeJS基礎(chǔ)的http, fs, path, url等模塊提供的API來搭建一個簡單的web服務(wù)器。具有很好的參考價值。下面跟著小編一起來看下吧
    2017-04-04
  • NodeJS?基于?Dapr?構(gòu)建云原生微服務(wù)應(yīng)用快速入門教程

    NodeJS?基于?Dapr?構(gòu)建云原生微服務(wù)應(yīng)用快速入門教程

    Dapr?是一個可移植的、事件驅(qū)動的運行時,它使任何開發(fā)人員能夠輕松構(gòu)建出彈性的、無狀態(tài)和有狀態(tài)的應(yīng)用程序,并可運行在云平臺或邊緣計算中,它同時也支持多種編程語言和開發(fā)框架,本文重點介紹NodeJS云原生微服務(wù)應(yīng)用,感興趣的朋友一起看看吧
    2022-07-07
  • Node.js之如何創(chuàng)建TCP服務(wù)器端

    Node.js之如何創(chuàng)建TCP服務(wù)器端

    這篇文章主要介紹了Node.js之如何創(chuàng)建TCP服務(wù)器端問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-09-09
  • 利用node.js爬取指定排名網(wǎng)站的JS引用庫詳解

    利用node.js爬取指定排名網(wǎng)站的JS引用庫詳解

    最近在學(xué)習(xí)node.js爬蟲,由于 nodejs 強大的異步特性,讓我們可以輕松以異步高并發(fā)去爬取網(wǎng)站,下面這篇文章主要給大家介紹了關(guān)于利用node.js爬取指定排名網(wǎng)站的JS引用庫的相關(guān)資料,需要的朋友可以參考下。
    2017-07-07
  • node?puppeteer爬蟲爬取電影網(wǎng)站及生成pdf文檔示例

    node?puppeteer爬蟲爬取電影網(wǎng)站及生成pdf文檔示例

    這篇文章主要介紹了node?puppeteer爬蟲爬取電影網(wǎng)站及生成pdf文檔使用示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-07-07
  • 如何利用node轉(zhuǎn)發(fā)請求詳解

    如何利用node轉(zhuǎn)發(fā)請求詳解

    這篇文章主要給大家介紹了關(guān)于利用node轉(zhuǎn)發(fā)請求的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-09-09
  • 前端之npm運行時配置文件.npmrc的方法(可用于配置npm淘寶源)

    前端之npm運行時配置文件.npmrc的方法(可用于配置npm淘寶源)

    這篇文章主要給大家介紹了關(guān)于前端之npm運行時配置文件.npmrc(可用于配置npm淘寶源)的相關(guān)資料,.npmrc 文件是用于配置 npm(Node.js 包管理器)行為的配置文件,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
    2024-07-07

最新評論