我似乎在调用 require 时得到 "new module instance"

I seem to get a "new module instance" when calling require

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

然而,当我稍后在另一个文件 routes/users.js 中需要文件 db/index.js 时,数据库引用它 returns 是 null,虽然我预计它是我在 app.js 中连接时获得的相同参考。 require 不总是 return 在第一次调用 require 时被 return 编辑的同一个模块实例吗?我做错了什么?

编辑:我知道因为调用 db.connect 是异步的,所以 users.jsdb 的值在理论上可能是连接函数 [=] 之前的 null 58=]秒。但是,我已经通过测试验证即使连接成功创建,当我对路径 /users[=48= 执行 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;

var db = require('./db'); 声明一个仅存在于该文件范围内的新变量。当您在 routes/user 文件中进行类似的声明时,您会创建一个全新的 db 变量,这意味着连接方法从来不是 运行 因此 state 属性 从未改变。

郑重声明,您没有收到 "new" 实例,以下解释将帮助您理解正在发生的事情。

请注意,在通过 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;

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