在 Node.js 中使用异步瀑布

我有两个异步运行的函数。我想使用瀑布模型来编写它们。问题是我不知道怎么办..

这是我的代码：

var fs = require('fs');
function updateJson(ticker, value) {
  //var stocksJson = JSON.parse(fs.readFileSync("stocktest.json"));
  fs.readFile('stocktest.json', function(error, file) {
    var stocksJson =  JSON.parse(file);

    if (stocksJson[ticker]!=null) {
      console.log(ticker+" price : " + stocksJson[ticker].price);
      console.log("changing the value...")
      stocksJson[ticker].price =  value;

      console.log("Price after the change has been made -- " + stocksJson[ticker].price);
      console.log("printing the the Json.stringify")
      console.log(JSON.stringify(stocksJson, null, 4));
      fs.writeFile('stocktest.json', JSON.stringify(stocksJson, null, 4), function(err) {  
        if(!err) {
          console.log("File successfully written");
        }
        if (err) {
          console.error(err);
        }
      }); //end of writeFile
    } else {
      console.log(ticker + " doesn't exist on the json");
    }
  });
} // end of updateJson 

知道如何使用瀑布来编写它，以便我能够控制它吗？请给我写一些例子，因为我是 node.js 的新手

首先确定步骤并将它们编写为异步函数（采用回调参数）

• 读取文件

  function readFile(readFileCallback) {
      fs.readFile('stocktest.json', function (error, file) {
          if (error) {
              readFileCallback(error);
          } else {
              readFileCallback(null, file);
          }
      });
  }
  

• 处理文件（我删除了示例中的大部分console.log）

  function processFile(file, processFileCallback) {
      var stocksJson = JSON.parse(file);
      if (stocksJson[ticker] != null) {
          stocksJson[ticker].price = value;
          fs.writeFile('stocktest.json', JSON.stringify(stocksJson, null, 4), function (error) {
              if (err) {
                  processFileCallback(error);
              } else {
                  console.log("File successfully written");
                  processFileCallback(null);
              }
          });
      }
      else {
          console.log(ticker + " doesn't exist on the json");
          processFileCallback(null); //callback should always be called once (and only one time)
      }
  }
  

请注意，我在这里没有进行特定的错误处理，我将利用 async.waterfall 将错误处理集中在同一位置。

另请注意，如果异步函数中有 (if/else/switch/...) 分支，它总是调用回调一次（且仅一次）。

使用 async.waterfall 插入所有内容

async.waterfall([
    readFile,
    processFile
], function (error) {
    if (error) {
        //handle readFile error or processFile error here
    }
});

干净的例子

之前的代码过于冗长，无法使解释更清晰。这是一个完整的清理示例：

async.waterfall([
    function readFile(readFileCallback) {
        fs.readFile('stocktest.json', readFileCallback);
    },
    function processFile(file, processFileCallback) {
        var stocksJson = JSON.parse(file);
        if (stocksJson[ticker] != null) {
            stocksJson[ticker].price = value;
            fs.writeFile('stocktest.json', JSON.stringify(stocksJson, null, 4), function (error) {
                if (!err) {
                    console.log("File successfully written");
                }
                processFileCallback(err);
            });
        }
        else {
            console.log(ticker + " doesn't exist on the json");
            processFileCallback(null);
        }
    }
], function (error) {
    if (error) {
        //handle readFile error or processFile error here
    }
});

我保留了函数名称，因为它有助于提高可读性并有助于使用 chrome 调试器等工具进行调试。

如果你使用下划线 http://underscorejs.org/ (on npm https://www.npmjs.org/package/underscore），您还可以将第一个函数替换为_.partial(fs.readFile, 'stocktest.json')