0

我是 node.js 的新手(不到一小时)。

我正在尝试建立一个简单的 http 服务器,它将读取一个 mongodb 集合并将数据打印到浏览器窗口。

到目前为止,我有:

var http = require ("http")
var mongodb = require('mongodb');

http.createServer(function(request, response) {
    var server = new mongodb.Server("127.0.0.1", 27107, {});
    response.writeHead(200, {"Content-Type": "text/plain"});
    response.write('Collection Data:<br>')
    new mongodb.Db('testdb', server, {}).open(function (error, client) {
      if (error) throw error;
      var collection = new mongodb.Collection(client, 'test_coll');
      collection.find({}, {limit:100}).each(function(err, doc) {
        if (doc != null) {
            console.dir(doc.text);
            response.write(doc.text)
        }
      });
      response.write("some stuff")
      response.end();
    });
}).listen(8080)

这会将集合项的文本放在控制台上,而不是放在浏览器窗口上。我认为这是因为响应对象不在 .each 回调的范围内?我是否以错误的方式构建了这个?

4

2 回答 2

2

问题是response.end()在你的回调执行之前被调用。

你必须把它移到里面,像这样:

collection.find({}, {limit:100}).each(function(err, doc){
    if (doc != null) {
        console.dir(doc.text);
        response.write(doc.text)
    } else {
        // null signifies end of iterator
        response.write("some stuff");
        response.end();
    }
});
于 2012-07-23T17:03:54.560 回答
0

res.end 必须在回调内的 for 循环之后发生:

client.collection('test_coll', function(err, testColl) {
  testColl.find({}).each(function(err, doc) {
    if (err) {
        // handle errors
    } else if (doc) {
        res.write(doc._id + ' ')
    } else { // If there's no doc then it's the end of the loop
        res.end()
    }
  })
})
于 2012-07-24T04:11:35.973 回答