是否可以（使用 Meteor）控制何时将发布推送给订阅的客户端？

Question

使用 Meteor 编程时，是否可以控制何时将发布（DDP 更新到本地 MiniMongo）推送到订阅的客户端。看起来默认行为是在对关联集合进行任何更改后立即推送更改。在我的应用程序中，这将非常低效并导致许多不必要的更新。

理想情况下，我想做的是延迟推送更改，直到我在另一个集合中有特定更改。

因此，例如，如果我有以下集合以及相关的出版物和订阅：

// Client and server
Scores = new Meteor.Collection('scores');
GameState = new Meteor.Collection('gameState');

Meteor.publish('scores', function(gameId) {
    return Scores.find({id: gameId});
});

Meteor.publish('gameState', function(gameId) {
    return GameState.find({id: gameId});
});

// Client only
Meteor.subscribe('scores');
Meteor.subscribe('gameState');

我想做的是延迟更新客户端的本地“分数”集合，直到游戏状态达到特定状态。

Answer 1

如果我对问题的理解正确，您可以结合使用autorun 和会话变量来触发订阅。像这样的：

Tracker.autorun(function() {
  var gameId = Session.get('currentGame');
  if (gameId && Session.get('excitingLevel')) {
    Meteor.subscribe('scores', gameId);
    Meteor.subscribe('gameState', gameId);
  }
});

这里我使用excitingLevel 和currentGame（难道没有游戏正在进行吗？）来激活订阅。另请注意，autorun 足够聪明，可以在不再满足条件时停止订阅。所以如果玩家离开游戏（Session.set('currentGame', undefined)）或者关卡不再精彩，订阅就会结束。

其他说明

• 如果游戏状态变化非常快，我可能值得评估streams，而不是使用集合作为游戏状态。
• 可能需要执行某种load testing 来确定最佳解决方案。

Answer 2

在服务器端代码中发布scores 或多或少像这样：

GameState = new Meteor.Collection('gameState')

/* Publish a custom Scores collection */
Meteor.publish("scores", function () {
  var self = this

  gameStateCursor = GameState.find();
  observerHandle = gameStateCursor.observe({
    added: function (document, index) {
      /* This is called whenever a new document is added to the game state. */

      if (/* gameState ready to publish to scores */)
        self.changed("scores", scoreId, scoreData)

      /* or use self.added() */
    },
    /* more functions as described in publish() */

  }
}

这不是一个完整的答案，而是一个粗略的大纲。这个observe() 框架非常强大，但是低级。几乎一切皆有可能。我可以想象用observe() 发布波浪数据的傅里叶变换，这太强大了。

请仔细阅读https://docs.meteor.com/#meteor_publish、https://docs.meteor.com/#publish_added及以下（添加、更改和删除）。