感谢您促使我写出更清晰的解释。这是我的评论的更完整示例。我已经清理了一些错误和不一致的地方。下一个文档版本将使用它。
Meteor.publish
很灵活。它不仅限于向客户端发布现有的 MongoDB 集合:我们可以发布任何我们想要的东西。具体来说,Meteor.publish
定义了一组客户端可以订阅的文档。每个文档都属于某个集合名称(一个字符串),有一个唯一的_id
字段,然后有一些 JSON 属性集。当集合中的文档发生变化时,服务器会将更改发送给每个订阅的客户端,使客户端保持最新状态。
我们将在此处定义一个名为 的文档集"counts-by-room"
,它包含名为 的集合中的单个文档"counts"
。该文档将有两个字段:一个roomId
带有房间 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.");