node.js - mongoDB + NodeJS : can't keep a stream cursor open

Question

对于日志查看器，我必须将更新写入 sockJS 套接字上的 mongoDB 集合中。

基于this post ，我使用 native NodeJS 驱动程序的流游标来执行此操作，但它仅适用于我创建流时集合中存在的内容。没有写任何进一步的更新。

这是我的代码:

var server = new mongodb.Server(config.db_host, config.db_port, {});
var DB = new mongodb.Db('myLogs', server, {w:0}).open(function (error, database) {
    if (error) throw error;
    db.logs = database.collection('logs');
});

var stream = db.logs.find({user: sID}, {sort: [['_id', 'asc']]}).stream();

stream.on('error', function (err) {
    socket.write(JSON.stringify({'action': 'log','param': 'log db streaming error'}));
});
stream.on('data', function (doc) {
    socket.write(JSON.stringify({'action': 'log','param': doc.log}));
});

我做错了什么？这可以吗？

Answer 1

如果您有上限集合，则可以使用 TailableCursor ，它可以满足您的需求。标准CursorStream仅返回调用 find 时匹配的结果(如您所见)。

尽管如此，在 Node.JS 中并没有大量的信息来实现这一点。 Here是指向正确方向的指针。

虽然我还没有测试过这段代码，但它应该如下所示。关键是使用上限集合并将 tailable 和 awaitdata 选项设置为 true。

var stream = db.logs.find({user: sID}, {
    tailable: true,
    awaitdata: true 
    /* other options */
}).stream();

stream.on('data', function (doc) {
    socket.write(JSON.stringify({'action': 'log','param': doc.log}));
});