node.js - 使用 Node ddp-client 从 Node 插入 meteor 集合

Question

我正在尝试通过 node.js 将一些系统日志数据流式传输到 Meteor 集合中。它工作正常，但是 ~10 秒的 Meteor 客户端轮询周期对我来说太长了——我希望它是 ~1 秒。

通过控制台的客户端集合插入速度很快，并且所有客户端都会立即更新，因为它使用 DDP。但是从服务器端直接插入 MongoDB 取决于客户端的轮询周期。

因此，目前看来，我只能使用 DDP 从我的 Node 守护程序插入更新。

在 ddp-client 包示例中，我可以看到我订阅的消息，但我看不到如何通过 DDP 将 new 消息实际发送到 Meteor 集合和node.js，从而一次更新所有客户端...

有任何示例或指导吗？我将不胜感激 - 作为 node 和 Meteor 的新手，我很快就会达到我的极限。

Answer 1

好的，在仔细查看了一些代码并意识到我完全在想事情之后，我得到了它。该协议(protocol)实际上非常简单，是 RPC 之类的东西。

我很高兴地报告它绝对可以解决服务器端插入延迟(手动 Mongo 插入需要几秒钟来轮询/更新客户端)。

如果您通过 DDP，您将获得所有实时(ish)优点，这些优点是您通过 Meteor 了解和喜爱的 :)

为了后代，并希望能帮助其他人找到有趣的用例，这里是设置。

用例

我正在将一些自定义系统日志数据假脱机到 node.js 守护程序中。然后这个守护进程解析数据并将其插入 Mongo。我的想法是为我的第一个 Meteor 实验提出一个基于浏览器的实时报告项目。

所有这些都运行良好，但是因为我在 Meteor 本身 外部 插入 Mongo，客户端必须每 ~10 秒 轮询。在另一个 SO 帖子 @TimDog suggested我为此查看了 DDP，他的建议看起来效果很好。

我已经在我的系统上对其进行了测试，现在我可以通过 node.js 异步应用程序立即更新所有 Meteor 客户端。

设置这里的基本思想是使用DDP“调用”方法。它需要一个参数列表。在 Meteor 服务器端，您导出一个 Meteor 方法来使用这些方法并执行您的 MongoDB 插入。其实很简单:

第 1 步:npm 安装 ddp

第 2 步:转到您的 Meteor 服务器代码并在 Meteor.methods 内部执行类似的操作:

Meteor.methods({

'push': function(k,v) { // k,v will be passed in from the DDP client.
    console.log("got a push request")
    var d = {};
    d[k] = parseInt(v);
    Counts.insert(d, function(err,result){ // Now, simply use your Collection object to insert.
        if(!err){ 
            return result
            }else{
            return(err)
            }
        });
     }
  });

现在我们需要做的就是使用客户端库从我们的 node.js 服务器调用这个远程方法。这是一个示例调用，它本质上是 example.js 调用的直接副本，稍作调整以 Hook 我们刚刚导出的新“push”方法:

ddpclient.call('push', ['hits', '1111'], function(err, result) {
console.log('called function, result: ' + result);
})

通过 Meteor 服务器运行此代码插入，这反过来会立即更新连接到我们的客户端 :)

我确定我上面的代码并不完美，所以请提出建议。我对整个生态系统很陌生，所以在这里有很多学习的机会。但我确实希望这有助于为一些人节省一些时间。现在，回到专注于让我的模板与所有这些实时数据一起闪耀 :)