0

我有这个简单的 nodejs 应用程序，它为我的 Web 应用程序生成虚拟日期。它所做的只是：

  1. 删除虚拟数据库
  2. 填充库存集合
  3. 填充发票集合
  4. 填充 const 数据集合

当然，所有的动作都是异步的，我想一个接一个地顺序执行。对我来说，写一些东西来管理这种流更简单，但是，我想要一个主流的解决方案，它可以支持其他类型的流。例如，并行运行并在第一次失败时停止所有操作。

供您参考，请在骨架下方找到描述我的解决方案：

/*global require, console, process*/

var mongo, db, inventory, createChain;

function generateInventory(count) {
  // returns the generated inventory
}

function generateInvoices(count, inventory) {
  // returns the generated invoices
}

function generateConst() {
  // returns the generated const data
}

mongo = require('mongojs');
db = mongo.connect('dummy', ['invoices', 'const', 'inventory']);

createChain = function () {
  "use strict";
  var chain = [false], i = 0;

  return {
    add: function (action, errMsg, resultCallback) {
      chain[chain.length - 1] = {action: action, errMsg: errMsg, resultCallback: resultCallback};
      chain.push(false);
      return this;
    },
    invoke: function (exit) {
      var str, that = this;
      if (chain[i]) {
        chain[i].action(function (err, o) {
          if (err || !o) {
            str = chain[i].errMsg;
            if (err && err.message) {
              str = str + ": " + err.message;
            }
            console.log(str);
          } else {
            if (chain[i].resultCallback) {
              chain[i].resultCallback(o);
            }
            i += 1;
            that.invoke(exit);
          }
        });
      } else {
        console.log("done.");
        if (exit) {
          process.exit();
        }
      }
    }
  };
};

createChain()
  .add(function (callback) {
    "use strict";
    console.log("Dropping the dummy database.");
    db.dropDatabase(callback);
  }, "Failed to drop the dummy database")
  .add(function (callback) {
    "use strict";
    console.log("Populating the inventory.");
    db.inventory.insert(generateInventory(100), callback);
  }, "Failed to populate the inventory collection", function (res) {
    "use strict";
    inventory = res;
  })
  .add(function (callback) {
    "use strict";
    console.log("Populating the invoices.");
    db.invoices.insert(generateInvoices(10, inventory), callback);
  }, "Failed to populate the invoices collection")
  .add(function (callback) {
    "use strict";
    console.log("Populating the const.");
    db["const"].insert(generateConst(), callback);
  }, "Failed to populate the const collection")
  .invoke(true);

谁能推荐一个相关的nodejs包，它也很容易使用？

非常感谢你。

4

2 回答 2

2

使用该async模块提供您可能需要的几乎任何类型的流量控制。特别地，该series方法提供顺序流控制。

于 2012-09-02T04:27:36.890 回答
0

实际上，对于顺序流控制，您应该使用瀑布

举个例子：

async.waterfall([
  function(cb){
    cb(null,1);
  },
  function(r,cb){
    // r=1
    cb(null,2)
  },
  function(r,cb){
    // r=2
    cb(null,3)
  }
],function(e,r){
    // e=null
    // r=3
})

这将按顺序执行。如果你提前回调一个错误，（即cb("error")），那么它会直接进入最终的函数（e,r），其中e="error" 和r=undefined 注意function(r,cb)是如何{} 可以预先组合在 util 库中，以处理经常重复使用的块，并使未来的事情变得更容易。

于 2014-06-19T19:32:24.947 回答