使用节点ddp-client从Node插入流星集合

Question

我正在尝试通过node.js将一些syslog数据流式传输到Meteor集合中.它工作正常,但Meteor客户端轮询周期〜10秒对于我的口味来说太长了一个周期 - 我希望它是~1秒.

通过控制台插入客户端集合非常快,所有客户端都可以立即更新,因为它使用的是DDP.但是来自服务器端的直接MongoDB插入受客户端的轮询周期的影响.

所以看来现在我已经降级为使用DDP从我的节点守护进程插入更新.

在DDP-client包例子,我能看到我已经订阅了邮件,但我看不出实际发送新的经DDP和node.js的消息到流星的收集,从而更新的所有客户端立刻...

任何例子或指导？我非常感谢 - 作为节点和流星的新手,我很快就达到了极限.

Answer 1

好吧,我仔细查看了一些代码并意识到我完全过度思考了问题后才开始工作.该协议实际上非常简单,RPC ish的东西.

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

如果你通过DDP,你将得到你已经了解并喜欢Meteor的所有实时(ish)善良:)

对于后代而言,希望能帮助其他人了解有趣的用例,这就是设置.

用例

我将一些自定义syslog数据假脱机到node.js守护进程中.然后,该守护进程解析并将数据插入Mongo.我的想法是为我的第一个Meteor实验提出一个基于浏览器的实时报告项目.

所有这些都运行良好,但因为我正在Meteor 之外插入Mongo ,客户必须每隔约10秒进行轮询.在另一篇SO帖子@TimDog建议我看看DDP,他的建议看起来完美无缺.

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

设置 这里的基本思想是使用DDP"调用"方法.它需要一个参数列表.在Meteor服务器端,您导出Meteor方法以使用它们并执行MongoDB插入.它实际上非常简单:

第1步:npm install 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服务器插入,这反过来立即更新连接到我们的客户端:)

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

Answer 2

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

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