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

Posted 2023-02-16

【中文标题】Meteor 文档中的消息计数示例如何工作？

【英文标题】：How does the messages-count example in Meteor docs work?

【发布时间】：2012-05-20 21:27:23

【问题描述】：

无法完全理解来自 the docs 的这个示例...我尝试了多种不同的方式运行它，以便观察它是如何工作的，等等。

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

是否有一个名为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();
  );
);

【参考方案1】：

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

Meteor.publish 非常灵活。它不仅限于向客户端发布现有的 MongoDB 集合：我们可以发布任何我们想要的内容。具体来说，Meteor.publish 定义了客户端可以订阅的文档集。每个文档都属于某个集合名称（一个字符串），有一个唯一的 _id 字段，然后有一些 JSON 属性集。随着集合中的文档发生更改，服务器会将更改发送到每个订阅的客户端，使客户端保持最新。

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

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

当我们第一次调用observeChanges 时，一些added 回调将立即运行，对于每条已经存在的消息。然后，无论何时添加或删除消息，都会触发未来的更改。

我们的发布函数还注册了一个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"，它有一个参数：当前房间的身份证。我已经将它封装在 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.");

【讨论】：

清清楚楚！非常感谢您花时间为我澄清这一点！

请注意，added 中的self.flush(); 将在填充集合时将该订阅推送到客户端。假设您在那个“room_id”中有 1,000,000 条“消息”。您将收到从计数 1 开始到计数 1,000,000 的 1,000,000 个订阅。这将锁定您的浏览器很长一段时间！更不用说通过网络传输的数据量......

@matb33，有没有更好的flush问题解决方案？

作为临时修复，您可以使用setTimeout 技巧限制对added 内self.flush(); 的调用，例如： clearTimeout(t); t = setTimeout(function () self.flush(); , 10);

没关系，刚刚看到你的代码如下！看来你已经明白了

【参考方案2】：

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

这是我的反应式解决方案

集合：

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

仅供参考，这是 Meteor 0.6 之前的代码。请参阅上面@debergalis 的更新答案。

【参考方案3】：

刚刚找到解决 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 提供提示。

【讨论】：

这个解决方案的缺点是meteor将整个集合下载到服务器中，所以如果你使用相对较慢的远程连接到你的mongoDB，你的应用程序启动后会有明显的延迟（在至少如果您像我一样在数据库中有 10k 文档）。