Meteor 文档中的消息计数示例如何工作?

IT技术 javascript mongodb meteor publish-subscribe
2021-02-01 22:40:19

无法从文档中完全理解这个示例......我尝试以多种不同的方式运行它,以便观察它是如何工作的,等等。

你如何订阅这个?我们可以包含使这项工作所需的客户端代码吗?

有叫的集合messages-count吗?Room消息的集合吗?我们可以在示例中包含集合定义吗?

任何关于这方面的提示都会很棒!

注意:这是最初发布此问题时(2012 年 5 月)出现的代码。现在更简单了。

// server: publish the current size of a collection
Meteor.publish("messages-count", function (roomId) {
  var self = this;
  var uuid = Meteor.uuid();
  var count = 0;

  handle = Room.find({room_id: roomId}).observe({
    added: function (doc, idx) {
      count++;
      self.set("messages-count", uuid, "count", count);
      self.flush();
    },
    removed: function (doc, idx) {
      count--;
      self.set("messages-count", uuid, "count", count);
      self.flush();
    }
    // don't care about moved or changed
  });

  // remove data and turn off observe when client unsubs
  self.onStop(function () {
    handle.stop();
    self.unset("messages-count", uuid, "count");
    self.flush();
  });
});
3个回答

感谢您促使我写出更清晰的解释。这是我的评论的更完整示例。我已经清理了一些错误和不一致的地方。下一个文档版本将使用它。

Meteor.publish很灵活。它不仅限于向客户端发布现有的 MongoDB 集合:我们可以发布任何我们想要的东西。具体来说,Meteor.publish定义了一客户端可以订阅的文档每个文档都属于某个集合名称(一个字符串),有一个唯一的_id字段,然后有一些 JSON 属性集。当集合中的文档发生变化时,服务器会将更改发送给每个订阅的客户端,使客户端保持最新状态。

我们将在此处定义一个名为 的文档集"counts-by-room",它包含名为 的集合中的单个文档"counts"该文档将有两个字段:一个roomId带有房间 ID 的字段,以及count:该房间中消息的总数。没有真正的 MongoDB 集合名为counts. 这只是我们的 Meteor 服务器将向下发送到客户端的集合的名称,并存储在名为客户端集合中counts

为此,我们的发布函数采用一个roomId来自客户端参数,并观察该房间中所有消息(在别处定义)的查询。我们可以在observeChanges这里使用更有效的观察查询形式,因为我们不需要完整的文档,只需要添加或删除新文档的知识。每当添加了roomId我们感兴趣的新消息时,我们的回调都会增加内部计数,然后使用更新后的总数向客户端发布新文档。当一条消息被删除时,它会减少计数并向客户端发送更新。

当我们第一次调用 时observeChangesadded对于每个已经存在的消息,一定数量的回调会立即运行。然后,无论何时添加或删除消息,都会触发未来的更改。

我们的发布函数还会注册一个onStop处理程序,以便在客户端取消订阅(手动或断开连接时)时进行清理。此处理程序从客户端删除属性并拆除正在运行的observeChanges.

每次新客户端订阅时都会运行一个发布函数"counts-by-room",因此每个客户端都将observeChanges代表它运行一个

// server: publish the current size of a collection
Meteor.publish("counts-by-room", function (roomId) {
  var self = this;
  var count = 0;
  var initializing = true;

  var handle = Messages.find({room_id: roomId}).observeChanges({
    added: function (doc, idx) {
      count++;
      if (!initializing)
        self.changed("counts", roomId, {count: count});  // "counts" is the published collection name
    },
    removed: function (doc, idx) {
      count--;
      self.changed("counts", roomId, {count: count});  // same published collection, "counts"
    }
    // don't care about moved or changed
  });

  initializing = false;

  // publish the initial count. `observeChanges` guaranteed not to return
  // until the initial set of `added` callbacks have run, so the `count`
  // variable is up to date.
  self.added("counts", roomId, {count: count});

  // and signal that the initial document set is now available on the client
  self.ready();

  // turn off observe when client unsubscribes
  self.onStop(function () {
    handle.stop();
  });
});

现在,在客户端,我们可以将其视为典型的 Meteor 订阅。首先,我们需要一个Mongo.Collection将保存我们计算的计数文档。由于服务器正在发布到名为 的集合中"counts",我们将其"counts"作为参数传递Mongo.Collection构造函数。

// client: declare collection to hold count object
Counts = new Mongo.Collection("counts");

然后我们就可以订阅了。(您实际上可以在声明集合之前订阅:Meteor 会将传入的更新排入队列,直到有地方放置它们。)订阅的名称"counts-by-room",它需要一个参数:当前房间的 ID。我把它包在里面,Deps.autorun这样随着Session.get('roomId')变化,客户端会自动取消订阅旧房间的数量并重新订阅新房间的数量。

// client: autosubscribe to the count for the current room
Tracker.autorun(function () {
  Meteor.subscribe("counts-by-room", Session.get("roomId"));
});

最后,我们已经获得了文档Counts,我们可以像客户端上的任何其他 Mongo 集合一样使用它。每当服务器发送新计数时,任何引用此数据的模板都将自动重绘。

// client: use the new collection
console.log("Current room has " + Counts.findOne().count + " messages.");
作为一个临时的解决,则可以节流调用self.flush();added使用setTimeout特技,如定时器:clearTimeout(T); t = setTimeout(function () { self.flush(); }, 10);
2021-03-20 22:40:19
没关系,刚刚在下面看到了您的代码!看起来你已经想通了
2021-03-27 22:40:19
请注意,当集合被填充时self.flush();added会将订阅推送到客户端。想象一下,“room_id”中有 1,000,000 条“消息”。您将收到 1,000,000 个订阅,从计数 1 开始到计数 1,000,000。这将锁定您的浏览器很长一段时间!更不用说通过电线传输的数据量了......
2021-03-28 22:40:19
@matb33,是否有更好的解决冲洗问题的方法?
2021-04-01 22:40:19
清晰如钟!非常感谢您花时间为我澄清这一点!
2021-04-11 22:40:19

正如Leonhardt Wille 所说,这个解决方案的缺点是meteor 从Mongo 服务器下载整个项目集合只是为了计算它们。他在gist.github.com/3925008上的解决方案 更好,但是当插入新项目时计数器不会更新。

这是我的react式解决方案

收藏:

Players = new Meteor.Collection("players");
PlayersCounts = new Meteor.Collection("players_counts")

服务器:

Meteor.publish("players_counts", function(){
    var uuid = Meteor.uuid()
    var self = this;

    var unthrottled_setCount = function(){
        cnt = Players.find({}).count()
        self.set("players_counts", uuid, {count: cnt})
        self.flush()
    }

    var setCount = _.throttle(unthrottled_setCount, 50)

    var handle = Meteor._InvalidationCrossbar.listen({collection: "players"}, function(notification, complete){
        setCount();
        complete();
    })

    setCount();
    self.complete()
    self.flush()

    self.onStop(function(){
        handle.stop();
        self.unset("players_counts", uuid, ["count"]);
        self.flush();
    });
});

客户:

Meteor.subscribe("players_counts")

Template.leaderboard.total = function(){
    var cnt = PlayersCounts.findOne({})
    if(cnt) {
        return cnt.count;
    } else {
        return null;
    }
}
从 Meteor 0.6.6.3(可能更早)开始,这段代码失败了: Exception from sub CfuTiQGacmWo5xMsb TypeError: Cannot call method 'listen' of undefined
2021-03-23 22:40:19
仅供参考,这是 Meteor 0.6 之前的代码。请参阅上面@debergalis 的更新答案。
2021-03-24 22:40:19

刚刚找到了 self.flush() 向客户端发送数千个更新的问题的解决方案 - 计数时只需使用 _.debounce :

count = 0
throttled_subscription = _.debounce =>
  @set 'items-count', uuid, count: count
  @flush()
, 10
handle = Items.find(selector).observe
  added: =>
    count++
    throttled_subscription()
  removed: =>
    count--
    throttled_subscription()

这只会在 10 毫秒没有变化后设置计数并刷新订阅。

感谢#meteor 上的@possibilities 的提示。

这个解决方案的缺点是流星将整个集合下载到服务器,所以如果你使用相对较慢的远程连接到你的 mongoDB,你的应用程序启动后会有一个明显的延迟(至少如果你有 10k 文档在你的像我这样的数据库)。
2021-04-02 22:40:19