如何撤消"Meteor.publish",并撤消"new Meteor.Collection"

Question

我看到,在发布时,collection._connection.publish_handlers填充了collection._connection.method_handlers,其他区域也是如此.

我想基本上通过删除对该集合的引用来清理内存,并完全放弃它.

基本上,应用程序的每个用户都有该用户的集合列表.有一个发布函数,用户可以获取它们的集合列表:

Meteor.publish('users_collections', function() {
  var self = this;
  var handle = UsersCollections.find({ownerId: self.userId}).observeChanges({
    added: function(id, collectionInfo) {
      UsersCollectionManager.addUsersCollection(self.userId, collectionInfo.name);
    }
  });
});

发布该用户的集合列表(以及任何连接的用户获取其列表).

一旦用户获得他们的列表,每个集合都会被新的Meteor.Collection反应,然后发布.

UsersCollectionManager.addUsersCollection = function(userId, collectionName) {
  if (self.collections[userId].collections[collectionName] === undefined) {
    self.collections[userId].collections[collectionName] = new Meteor.Collection(collectionName);

    Meteor.publish(collectionName, function() {
      return self.collections[userId].collections[collectionName].find();
    });
  }
};

一旦用户断开连接,我就有了一个运行的功能.

如果该用户没有打开任何连接(例如:如果他们打开了多个窗口并关闭了所有连接"所有窗口关闭"),那么它将启动30秒超时:

• 清理所有这些发布调用和新的Meteor.Collection调用"以节省内存

由于应用程序的其他用户不需要此用户的集合.

我不确定如何从记忆中清理那些.

我没有在Meteor API中看到"取消发布"或"Collection.stop"类型的方法.

我该如何进行清理？

Answer 1

您需要分两步完成此操作.首先,停止并删除发布,然后从Meteor中删除该集合.

第一步相当容易.它要求您存储每个订阅的句柄:

var handles = [];

Meteor.publish('some data', function() {
  //Do stuff, send cursors, this.ready(), ...
  handles.push(this);
});

及时,停止它们:

var handle;
while(handle = handles.shift()) {
  handle.stop();
}

您的所有出版物都已停止.现在删除发布处理程序.它不太标准:

delete Meteor.default_server.publish_handlers['some data'];
delete Meteor.server.publish_handlers['some data'];

您基本上必须烧毁对处理程序的引用.这就是它不太标准的原因.

对于集合,您首先需要删除所有文档,然后您必须删除该引用.幸运的是,删除所有文档非常简单:

someCollection.remove({}, {multi : true}); //kaboom

删除对集合的引用比较棘手.如果它是一个没有name(new Mongo.Collection(null);)声明的集合,那么你可以删除变量(delete someCollection),据我所知,它不存储在其他任何地方.
如果它是一个命名集合,那么它存在于Mongo数据库中,这意味着你必须告诉Mongo删除它.我现在不知道该怎么做.也许Mongo驱动程序可以做到这一点,但它需要在DDP连接上进行一些接管.

Answer 2

你可以打电话subscriptionHandle.stop();给客户。如果用户已断开连接，则发布无论如何都会停止。