node.js - 为什么 mongoose.model.create 的回调不是从 Express 3.x HTTP 请求处理程序中执行(实际上 connect-mongodb 是原因)

Question

将问题直接写在代码中:

expressApp.get('/', function requestHandler(req, res) {
  userMongooseModel.create(userPropertiesDict, NEVER_CALLED_CALLBACK);
  console.log('This is printed just fine but browser awaits response forever.');
}

Express 是 3.x，Mongoose 是 3.x。
初始化的重要细节:

mongoose.connect(mongourl);
var mongoStore = require('connect-mongodb'); // Not 'connect-mongo', sic!
var store = new mongoStore({db: mongoose.connection.db}, resultHandler);

您可以在GitHub查看完整代码.
这是主脚本的缩小版本:

var express = require('express'),
    mongoose = require('mongoose')
    mongoStore = require('connect-mongodb');

var app = express();
var mongourl = 'mongodb://localhost/problem_users';
var port = 9001;

console.log('Connecting to MongoDB...');
mongoose.connect(mongourl);

Schema = mongoose.Schema;

attributes = {
  email: {
    type: String,
    required: true,
    unique: true
  }
};

schema = new Schema(attributes, {
  strict: true
});

var User = mongoose.model('User', schema);

app.configure(function() {

  app.use(express.cookieParser());

  app.use(express.session({
    secret: 'What bad can happen if I share this secret?',
    maxAge: new Date(Date.now() + 60*60*1000),
    store: new mongoStore({
      db: mongoose.connection.db
    }, function(err) {
      return console.log(err || 'connect-mongodb setup ok');
    })
  }));

  return app;
});

app.get('/', function(req, res) {
  console.log('Ready to register a new user...');

  var userPropertiesDict = {
    email: 'some.email@example.com',
  }

  console.log('Calling User.create...');
  User.create(userPropertiesDict, function(err, doc) {

    console.log('WHY IS THIS MESSAGE NOT PRINTED AT ALL?');
    var done = process.stdout.write('Are we stuck at flushing?');
    if (!done) { // Is stdout blocked?
      process.stdout.on('drain', _)
    }

  });
  console.log('RESPONSE IS OVER. THIS MESSAGE IS PRINTED AT THE END AND WE HANG AFTERWARDS.');
});

app.listen(port);
console.log("Listening on port ", port);
console.log("MongoDB url ", mongourl);
console.log('Navigate your browser to http://localhost:%d', port);

Answer 1

请注意，此问题包括 connect-mongodb，而不是 connect-mongo。从 connect-mongodb 切换到 connect-mongo 可以以更优雅的方式解决该问题，因此您应该先尝试一下。以下内容仅与 connect-mongodb 相关。

我发现这个问题根本不涉及express。实际上，它处理 mongoose 连接和 connect-mongodb session 初始化的顺序。

当connect-mongodb session 初始化时，数据库必须已经连接。由于 mongoose.connect 是异步执行的，因此在连接完成之前初始化 session 时，您很容易遇到问题(就像我所做的那样)。

可悲的一面是，由于某种原因 connect-mongodb 不会抛出或传递错误。

您可以在下面的代码中看到 mongoose 和 connect-mongodb 初始化的正确和错误方式。

var mongoose = require('mongoose')
    mongoStore = require('connect-mongodb');

var mongourl = 'mongodb://localhost/problem_users';

console.log("MongoDB: url ", mongourl);
console.log('MongoDB: connecting...');

/*
// THE WRONG WAY OF USING mongoose WITH connect-mongodb.
// The source below was the source of the problem.

mongoose.connect(mongourl, function(err) {
  console.log('THIS IS NOT PRINTED.');
  if (err) {
    console.log('THIS IS NOT PRINTED EITHER.');
    throw err;
  }
});

new mongoStore({
  db: mongoose.connection.db
}, function(err) {
  // The line below usually prints 2.
  console.log('MongoDB: readyState %d (2 = connecting, 1 = connected)', mongoose.connection.readyState);
  return console.log(err || 'connect-mongodb setup ok');
})
*/

// THE RIGHT WAY OF USING mongoose WITH connect-mongodb.
mongoose.connect(mongourl, {auto_reconnect: true, native_parser: true}, function(err) {
  new mongoStore({
    db: mongoose.connection.db
  }, function(err) {
    // The line below usuall prints 1.
    console.log('MongoDB: readyState %d (2 = connecting, 1 = connected)', mongoose.connection.readyState);
    return console.log(err || 'connect-mongodb setup ok');
  });
});

console.log('MongoDB: connected.')

Schema = mongoose.Schema;

attributes = {
  email: {
    type: String,
    required: true,
    unique: true
  }
};

var schema = new Schema(attributes);

var User = mongoose.model('User', schema);

function createUser(callback) {

  var userPropertiesDict = {
    email: 'some.email@example.com',
  }

  console.log('Calling User.create...');
  User.create(userPropertiesDict, callback);
}

function NEVER_CALLED_CALLBACK(err, doc) {

    console.log('WHY IS THIS MESSAGE NOT PRINTED AT ALL?');
    var done = process.stdout.write('Are we stuck at flushing?');
    if (!done) { // Is stdout blocked?
      process.stdout.on('drain', _)
    }
}

createUser(NEVER_CALLED_CALLBACK); // This either creates new User or logs an error that it already exists.

另请参阅this article这帮助我以正确的方式解决问题。