调用 require 时我似乎得到了一个“新模块实例”

Question

我正在尝试让 MongoDB 与 Express.js 一起使用。我关注了this 文章并创建了一个文件db/index.js，它提供了创建数据库连接和返回连接实例的功能。在app.js我先需要那个文件，然后调用它的函数connect，成功连接到数据库。

但是，当我稍后在另一个文件routes/users.js 中需要文件db/index.js 时，它返回的数据库引用是null，尽管我希望它与我在app.js 中连接时得到的引用相同. require 不是总是返回第一次调用 require 时返回的模块实例吗？我做错了什么？

编辑：我知道因为调用db.connect 是异步的，所以在连接函数返回之前，users.js 中的db 的值理论上可能是null。但是，我通过测试验证，即使成功创建连接，当我向路径 /users 发出 POST 请求时，db 仍然是 null。

这是 3 个相关文件。

app.js（从这里开始执行）

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

// configuration  environment based on process.env.NODE_ENV environment variable
var config = require('./config');
var db = require('./db');

var app = express();

var routes = require('./routes/index');
var users = require('./routes/users');
app.use('/', routes);
app.use('/users', users);

// Connect to Mongo on start
db.connect(config.dbUrl, function (err) {
    if (err) {
        console.log('Unable to connect to ' + config.dbUrl);
        process.exit(1);
    } else {
        console.log('Connected to ' + config.dbUrl);
    }
});

// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'jade');

// uncomment after placing your favicon in /public
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: false}));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use('/tests', express.static(__dirname + '/test'));
app.use('/lib/jasmine-core', express.static(__dirname + '/node_modules/jasmine-core/lib/jasmine-core'));

// catch 404 and forward to error handler
app.use(function (req, res, next) {
    var err = new Error('Not Found');
    err.status = 404;
    next(err);
});

// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
    app.use(function (err, req, res, next) {
        res.status(err.status || 500);
        res.render('error', {
            message: err.message,
            error: err
        });
    });
}

// production error handler
// no stacktraces leaked to user
app.use(function (err, req, res, next) {
    res.status(err.status || 500);
    res.render('error', {
        message: err.message,
        error: {}
    });
});


module.exports = app;

db/index.js

var MongoClient = require('mongodb').MongoClient;

var state = {
    db: null
};

exports.connect = function (url, done) {
    if (state.db)
        return done();

    MongoClient.connect(url, function (err, db) {
        if (err)
            return done(err);
        state.db = db;
        done();
    })
}

exports.get = function () {
    return state.db;
}

exports.close = function (done) {
    console.log('db close');
    if (state.db) {
        state.db.close(function (err, result) {
            state.db = null;
            done(err);
        })
    }
}

exports.createIndexes = function () {
    if (state.db) {
        state.db.collection('events').createIndex(
                {'id': 1},
        {unique: true});
    }
}

routes/users.js

var express = require('express');
var router = express.Router();
var db = require('../db').get();

router.post('/', function (req, res, next) {
    //
    // Problem: Every time this function is called, db is null!
    //
    var users = db.collection('users');
    var userToAdd = req.body;

    users.findOne({username: userToAdd.username}).then(function (foundUser) {
        if (foundUser.length === 0) {
            res.status(400).json({error: 'Username is already in use'});
        } else {
            // TODO: ADD USER
            res.json(foundUser);
        }
    })
    .catch(function (err) {
        console.log(err);
        res.status(500).json({error: 'Database error.'});
    });
});

module.exports = router;

Answer 1

作为记录，您没有收到“新”实例，以下解释将帮助您了解正在发生的事情。

请注意，在通过 db.connect 连接到数据库之前，您需要路由。即

//Called before db.connect is called.
//so at this point in time, your db.get will return null, make sense?
//because in your users.js your are directly calling var db = require('../db').get();
var routes = require('./routes/index');
var users = require('./routes/users');
app.use('/', routes);
app.use('/users', users); 

// Connect to Mongo on start
db.connect(config.dbUrl, function (err) {
    if (err) {
        console.log('Unable to connect to ' + config.dbUrl);
        process.exit(1);
    } else {
        //after this point in execution, calling db.get will return actual db and not null.
        console.log('Connected to ' + config.dbUrl);
    }
});

您的问题有两种解决方案。

1.

像这样重构您的 app.js 代码将解决您的问题。

// Connect to Mongo on start
db.connect(config.dbUrl, function (err) {
    if (err) {
        console.log('Unable to connect to ' + config.dbUrl);
        process.exit(1);
    } else {
        //As now we have db initialised, lets load routes.
        var routes = require('./routes/index');
        var users = require('./routes/users');
        app.use('/', routes);
        app.use('/users', users);
        console.log('Connected to ' + config.dbUrl);
    }
});

2

保留您的 app.js 并更改您的路线，例如 users.js 使用 db 如下，

var express = require('express');
var router = express.Router();
var dbFetcher = require('../db');

router.post('/', function (req, res, next) {
    //
    // Problem: Every time this function is called, db is null!

    var db = dbFetcher.get();
    var users = db.collection('users');
    var userToAdd = req.body;

    users.findOne({username: userToAdd.username}).then(function (foundUser) {
        if (foundUser.length === 0) {
            res.status(400).json({error: 'Username is already in use'});
        } else {
            // TODO: ADD USER
            res.json(foundUser);
        }
    })
    .catch(function (err) {
        console.log(err);
        res.status(500).json({error: 'Database error.'});
    });
});

module.exports = router;

我希望它有意义并有所帮助！

Answer 2

线 var db = require('./db'); 声明一个仅存在于该文件范围内的新变量。当您在您的路由/用户文件中进行类似声明时，您会创建一个全新的 db 变量，这意味着永远不会运行连接方法，因此永远不会更改 state 属性。