如何解决这个 MongoDB/Node 异步问题？

Question

我有以下代码：

// Retrieve
var MongoClient = require("mongodb").MongoClient;
var accounts = null;
var characters = null;

// Connect to the db
MongoClient.connect("mongodb://localhost:27017/bq", function(err, db) {
   if(err) { return console.dir(err); }

    db.createCollection('accounts', function(err, collection) {
        if(err) { return console.dir(err); }
        else { accounts = collection; }

        createAccount("bob","bob");
        createAccount("bob","bob");
        createAccount("bob","bob");
        createAccount("bob","bob");
    });
});


function createAccount(email, password)
{
    accounts.findOne({"email":email}, function(err, item) {
        if(err) { console.dir(err); }
        else {
            if(item === null) {
                accounts.insert({"email":email, "password":password}, function(err, result) {
                    if(err) { console.dir(err); }
                    else { console.dir("Account " + email + " created."); }
                });
            }
            else {
                console.dir("Account already exists.")
            }

        }
    });
}

当我第一次运行脚本时，我最终得到了 bob 的 4 个帐户。当我第二次运行它时，我收到 4 条帐户已经存在的消息。

我很确定我知道为什么会这样，我想出的解决方案是使用某种队列来处理数据库的每次读/写。我想知道的是，这是否是正确的做法，一般的最佳做法是什么？

Answer 1

一些语言提供了一种特殊的语言结构来处理这个问题。例如，C# 有 async/await 关键字，让您可以像调用同步 API 一样编写代码。

JavaScript 没有，您必须将 createAccount 调用与回调链接起来。

有些人开发了可以帮助您组织此代码的库。例如async、step、node-promise 和Q

您还可以使用 fibers 库，这是一个使用纤程/协程扩展 JavaScript 运行时的本机库。

有些人用类似于async/await 的结构扩展了语言：streamline.js、IcedCoffeeScript 或wind.js。例如，streamline.js（我是作者，所以我显然有偏见）使用_ 作为特殊的回调占位符，并让您将示例编写为：

var db = MongoClient.connect("mongodb://localhost:27017/bq", _):
var accounts = db.createCollection('accounts', _);
createAccount("bob","bob", _);
createAccount("bob","bob", _);
createAccount("bob","bob", _);
createAccount("bob","bob", _);

function createAccount(email, password, _) {
    var item = accounts.findOne({"email":email}, _);
    if (item === null) {
        accounts.insert({"email":email, "password":password}, _);
        console.log("Account " + email + " created."); }
    } else {
        console.log("Account already exists.")
    }
}

最后但并非最不重要的一点是，generators 和 deferred functions 等新的语言特性正在讨论用于 JavaScript 的未来版本（生成器很可能登陆 ES6，延迟函数似乎有点停滞不前）。

所以你有很多选择：

• 坚持回调
• 使用帮助库
• 使用纤程运行时扩展
• 使用语言扩展
• 等待 ES6

Answer 2

为电子邮件添加唯一约束，您将不必再检查用户是否存在！

Answer 3

JavaScript 是异步的。 accounts.findOne 立即返回，所以基本上你所有的 4 个语句都会一起执行。

accounts.findOne 所做的是，它说找到一个{"email":email}，当你找到它时，运行第二个参数中的函数。然后它返回函数并继续下一个 CreateAccount 语句。同时，当从硬盘返回结果时（这比执行这些语句花费的时间要长得多），它进入函数，并且由于没有用户，所以它添加了一个。有意义吗？

更新这是在 JavaScript 中执行此操作的正确方法。

MongoClient.connect("mongodb://localhost:27017/bq", function(err, db) {
   if(err) { return console.dir(err); }

    db.createCollection('accounts', function(err, collection) {
        if(err) { return console.dir(err); }
        else { accounts = collection; }

        createAccount("bob","bob", function() {
            createAccount("bob","bob", function() {
                createAccount("bob","bob", function() {
                    createAccount("bob","bob", function() {
                     });
                });
            });
        });
    });
});


function createAccount(email, password, fn)
{
    accounts.findOne({"email":email}, function(err, item) {
        if(err) { console.dir(err); }
        else {
            if(item === null) {
                accounts.insert({"email":email, "password":password}, function(err, result) {
                    if(err) { console.dir(err); }
                    else { console.dir("Account " + email + " created."); }
                    fn();
                });
            }
            else {
                console.dir("Account already exists.")
                fn();
            }

        }
    });
}