我正在编写这个迷你RESTful应用程序,它将请求发送到不同的URL。为此,我使用的是nodejs,并表示要设置不同的路径。作为数据库,我计划使用monogoDB(christkv的node-mongodb-native)。

我的代码(不包括mongo尝试)如下所示:

app.js

/**
 * Module dependencies.
 */
var express = require('express')
    , routes = require('./routes')
var app = module.exports = express.createServer();

var Db = require('mongodb').Db;
var Server = require('mongodb').Server;
var client = new Db('test', new Server('127.0.0.1', 27017, {}));

// Configuration

app.configure(function() {
    app.set('views', __dirname + '/views');
    app.use(express.bodyParser());
    app.use(express.methodOverride());
    app.use(app.router);
    app.use(express.static(__dirname + '/public'));
});

app.configure('development', function() {
    app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
});

app.configure('production', function() {
    app.use(express.errorHandler());
});

var insertData = function(err, collection) {
    collection.insert({name: "Kristiono Setyadi"});
    collection.insert({name: "Meghan Gill"});
    collection.insert({name: "Spiderman"});
}



// Routes
app.post('/', routes.syncServiceIndex);

app.post('/syncService', routes.synchServicePost);
app.get('/syncService/:syncServiceUser/sync', routes.synchServiceSync);
app.post('/syncService/:syncServiceUser/push', routes.synchServicePush);
app.del('/syncService/:syncServiceUser', routes.synchServiceDel);

app.post('/syncService/:syncServiceUser/contacts/push', routes.synchServiceContactsPush);
app.get('/syncService/:syncServiceUser/contacts/sync', routes.synchServiceContactsSync);

app.post('/syncService/:syncServiceUser/contacts/', routes.synchServiceContactsPost);
app.get('/syncService/:syncServiceUser/contacts/:contactId', routes.synchServiceContactsGet);
app.put('/syncService/:syncServiceUser/contacts/:contactId', routes.synchServiceContactsPut);
app.del('/syncService/:syncServiceUser/contacts/:contactId', routes.synchServiceContactsDel);

app.listen(3000);



console.log("Express server listening on port %d in %s mode", app.address().port, app.settings.env);


为了将不同的组件保留在不同的文件中,这是我的文件,其中包含每个URL的代码:

index.js

//var ObjectID = db.bson_serializer.ObjectID;
exports.syncServiceIndex = function(req, res) {
    console.log('syncServiceIndex');
    //console.log("BODY:" + JSON.stringify(req.body));

    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServicePost = function(req, res) {
    console.log('synchServicePost');
    console.log("BODY:" + JSON.stringify(req.body));
    var jsonObject = JSON.parse(JSON.stringify(req.body));
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceSync = function(req, res) {
    console.log('synchServiceSync');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServicePush = function(req, res) {
    console.log('synchServicePush');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceDel = function(req, res) {
    console.log('synchServiceDel');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceDel = function(req, res) {
    console.log('synchServiceDel');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceContactsPush = function(req, res) {
    console.log('synchServiceContactsPush');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceContactsSync = function(req, res) {
    console.log('synchServiceContactsSync');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceContactsPost = function(req, res) {
    console.log('synchServiceContactsPost');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceContactsGet = function(req, res) {
    console.log('synchServiceContactsGet');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceContactsPut = function(req, res) {
    console.log('synchServiceContactsPut');
    res.statusCode = 200;
    res.send("OK\n");
};

exports.synchServiceContactsDel = function(req, res) {
    console.log('synchServiceContactsDel');
    res.statusCode = 200;
    res.send("OK\n");
};


从我已经检查过的一些示例代码中所看到的,我应该只真正使用一个打开的连接,也就是说,我应该将所有代码都放在

client.open(function(err, pClient) {

});


呼叫。我遇到的问题是,我不确定如何传递客户端或集合,以便可以使用index.js文件中的数据库。有什么方法可以在当前布局中做到这一点,还是我必须移动一些东西?

最佳答案

您可以将所有路由包装到回调中,并在中间件中设置req.mongoClient = pClient,例如:

client.open(function(err, pClient) {
  clientMiddleware = function (req, res, next) {
    req.mongoClient = pClient;
    next();
  }
  // your routes here, with clientMiddleware
  app.post('/', clientMiddleware, routes.syncServiceIndex);
  app.post('/syncService', clientMiddleware, routes.synchServicePost);
  app.get('/syncService/:syncServiceUser/sync', clientMiddleware, routes.synchServiceSync);
  // etc.
});


现在,您可以在所有路由中使用req.mongoClient来获取客户端。

关于mongodb - 带有Express和MongoDB的NodeJS应用,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/8511038/

10-11 22:36
查看更多