感谢您促使我写一个更清晰的解释。这是我评论的更完整示例。我已经清理了一些错误和不一致之处。下一个文档版本将使用它。
Meteor.publish相当灵活。它不仅限于向客户端发布现有的 MongoDB 集合：我们可以发布任何我们想要的内容。具体来说，Meteor.publish定义了一组客户端可以订阅的文档。每个文档都属于某个集合名称（一个字符串），有一个唯一的_id字段，然后有一些 JSON 属性。随着集合中的文档发生更改，服务器会将更改发送到每个订阅的客户端，使客户端保持最新。
我们将在此处定义一个名为 的文档集"counts-by-room"，其中包含名为 的集合中的单个文档"counts"。该文档将有两个字段：aroomId带有房间的 ID，以及count：该房间中的消息总数。没有真正的 MongoDB 集合名为counts. 这只是我们的 Meteor 服务器将向下发送到客户端的集合的名称，并存储在名为 的客户端集合counts中。
为此，我们的发布函数采用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"，它有一个参数：当前房间的 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.");