感谢您提示我写一个更清晰的解释。这是带有我的评论的完整示例。我已经清理了一些错误和不一致之处。下一个文档版本将使用此功能。
Meteor.publish非常灵活。它不仅限于将现有的MongoDB集合发布到客户端：我们可以发布任何我们想要的东西。具体来说，
Meteor.publish定义客户可以订阅的一
组文档
。每个文档都属于某个集合名称（一个字符串），具有一个唯一的
_id字段，然后具有一组JSON属性。当集合中的文档发生更改时，服务器会将更改向下发送给每个订阅的客户端，以使客户端保持最新状态。
我们将在此处定义一个名为的文档集，该文档集
"counts-by-room"包含一个名为的集合中的单个文档
"counts"。该文档将具有两个字段：一个
roomId具有房间ID的字段，以及
count：该房间中消息的总数。没有名为的实际MongoDB集合
counts。这只是Meteor服务器将向下发送给客户_端的_ 集合的名称，并存储在名为的 客户端 集合中
counts。
为此，我们的publish函数采用一个
roomId来自客户端的参数，并观察对该房间中所有Messages（在其他位置定义）的查询。我们可以在
observeChanges这里使用更高效的观察查询形式，因为我们不需要完整的文档，而只是知道添加或删除了一个新文档。每当添加新消息并添加
roomId我们感兴趣的消息时，我们的回调都会增加内部计数，然后将具有更新后总数的新文档发布到客户端。当删除一条消息时，它将减少计数并向客户端发送更新。
首次调用时
observeChanges，
added对于每个已存在的消息，将立即运行一些回调。然后，无论何时添加或删除邮件，将来的更改都会触发。
我们的发布功能还注册了一个
onStop处理程序，以在客户端退订（手动或断开连接）时进行清理。该处理程序从客户端删除属性，并取消运行
observeChanges。
每次新客户端订阅时
"counts-by-room"，都会运行publish函数，因此每个客户端都将
observeChanges代表其运行。
// server: publish the current size of a collectionMeteor.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 objectCounts = new Mongo.Collection("counts");然后我们可以订阅。（实际上，您可以在声明集合之前进行订阅：Meteor会将传入的更新排队，直到有放置它们的位置为止。） 订阅 的名称为
"counts-by-room"，它带有一个参数：当前房间的ID。我将其包装在内部，
Deps.autorun以便进行
Session.get('roomId')更改时，客户端将自动取消订阅旧房间的计数，然后重新订阅新房间的计数。// client: autosubscribe to the count for the current roomTracker.autorun(function () { Meteor.subscribe("counts-by-room", Session.get("roomId"));});最后，我们已经获得了文档，
Counts并且可以像客户端上的任何其他Mongo集合一样使用它。每当服务器发送新计数时，任何引用此数据的模板都将自动重绘。
// client: use the new collectionconsole.log("Current room has " + Counts.findOne().count + " messages.");
