【问题标题】:Using node ddp-client to insert into a meteor collection from Node使用节点 ddp-client 从节点插入流星集合
【发布时间】:2013-01-16 09:01:18
【问题描述】:

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

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

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

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

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

【问题讨论】:

    标签: node.js meteor


    【解决方案1】:

    根据this screencast 可以简单地调用集合声明的meteor-methods。在您的情况下,代码如下所示:

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

    【讨论】:

    • 调用/counts/find 是不可能的,但是。你知道为什么吗?
    • 我猜你需要订阅。
    • 谢谢,看来你是对的。通过/collection/find 查找文档并不是 Meteor 的工作方式。在服务器上发布和在客户端订阅似乎是要走的路。
    【解决方案2】:

    好的,在仔细查看了一些代码并意识到我完全在想事情之后,我得到了它。该协议实际上非常简单,是 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 调用的直接副本,稍作调整以挂钩我们刚刚导出的新“push”方法:

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

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

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

    【讨论】:

    • 这正是我所需要的!感谢分享@mcauth。
    猜你喜欢
    • 2011-10-11
    • 1970-01-01
    • 1970-01-01
    • 2018-02-16
    • 1970-01-01
    • 1970-01-01
    • 2021-02-25
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多