我正在尝试通过node.js将一些系统日志数据流式传输到Meteor集合中。它工作正常，但 ~10 秒的 Meteor 客户端轮询周期对于我的口味来说太长了 - 我希望它是 ~1 秒。
通过控制台插入客户端集合速度很快，所有客户端都会立即更新，因为它使用的是 DDP。但是从服务器端直接插入MongoDB受客户端轮询周期的影响。
因此，现在看来我只能使用 DDP 从我的节点守护程序插入更新。
在 ddp 客户端包示例中，我能够看到我订阅的消息，但我看不到如何通过 DDP 和 node.js 实际将新消息发送到 Meteor 集合中，从而一次更新所有客户端......
任何示例或指导？我将不胜感激 - 作为节点和流星的新手，我很快就会达到我的极限。
好的，在仔细查看了一些代码并意识到我完全过度思考之后，我让它工作了。该协议实际上非常简单，RPC之类的东西。
我很高兴地报告它绝对可以解决服务器端插入延迟（手动 Mongo 插入需要几秒钟来轮询/更新客户端）。
如果您通过DDP，您将获得您通过流星:)了解和喜爱的所有实时（ish）好处
为了后代并希望帮助推动其他人使用有趣的用例，这里是设置。
用例
我正在将一些自定义系统日志数据假脱机到节点.js守护程序中。然后，此守护程序解析数据并将其插入 Mongo。我的想法是为我的第一个流星实验想出一个基于浏览器的实时报告项目。
所有这些都运行良好，但由于我在 Meteor 之外插入 Mongo，客户端必须每 ~10 秒轮询一次。在另一篇SO帖子中，@TimDog建议我为此查看DDP，他的建议看起来效果很好。
我已经在我的系统上对其进行了测试，现在我可以通过节点异步应用程序立即更新所有 Meteor 客户端.js。
设置这里的基本思想是使用 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)
}
});
}
});
现在我们需要做的就是使用客户端库从我们的节点.js服务器调用这个远程方法。下面是一个示例调用，它本质上是示例调用的直接副本.js进行了一些调整以挂钩我们刚刚导出的新"push"方法：
ddpclient.call('push', ['hits', '1111'], function(err, result) {
console.log('called function, result: ' + result);
})
运行此代码通过 Meteor 服务器插入，该服务器反过来会立即更新连接到我们的客户端:)
我确定我上面的代码并不完美，所以请提出建议。我对整个生态系统很陌生，所以这里有很多学习的机会。但我确实希望这有助于为一些人节省一些时间。现在，回到专注于让我的模板在所有这些实时数据:)中大放异彩
根据此截屏视频，可以简单地调用集合声明的流星方法。在您的情况下，代码将如下所示：
ddpclient.call('/counts/insert', [{hits: 1111}], function(err, result) {
console.log('called function, result: ' + result);
})