16

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

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

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

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

有什么例子或指导吗？我将不胜感激 - 作为 node 和 Meteor 的新手，我很快就达到了我的极限。

4

2 回答 2

32

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

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

如果你通过 DDP，你会得到所有你已经了解并喜欢 Meteor 的实时（ish）优点 :)

为了后代，并希望帮助推动其他一些人使用有趣的用例，这里是设置。

用例

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

所有这些都运行良好，但是因为我是在Meteor之外插入 Mongo ，所以客户端必须每 10 秒进行一次轮询。在另一篇 SO 帖子中， @TimDog 建议我为此查看 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 调用的直接副本，稍作调整以挂钩我们刚刚导出的新“push”方法：

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

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

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

于 2013-02-01T20:46:29.617 回答
7

根据这个截屏视频，可以简单地调用集合声明的流星方法。在您的情况下，代码如下所示：

ddpclient.call('/counts/insert', [{hits: 1111}], function(err, result) {
    console.log('called function, result: ' + result);
})
于 2013-09-14T11:00:32.373 回答