Meteor应用自定义Ping-Pong：如何实现单实例发布/避免重复定时器？

嘿，我来帮你搞定这个Meteor自定义Ping-Pong的问题！你的核心困扰是每个新订阅都会创建独立定时器，导致重复发送Pong，同时想知道有没有更合适的消息推送方式，下面一步步给你解决：

要实现全局唯一的定时器，我们可以在服务器端维护活跃订阅计数和单例定时器实例，确保只有第一个订阅启动时创建定时器，最后一个订阅断开时销毁它。修改后的代码如下：

const COLLECTION_NAME = 'ping-pong';
const POLL_INTERVAL = 5000;

// 全局变量：跟踪活跃订阅数和定时器实例
let activePingPongSubscriptions = 0;
let pingPongInterval = null;

function pingPong(credentials) {
  const publisher = this;
  
  // 每新增一个订阅，计数+1
  activePingPongSubscriptions++;

  // 第一个订阅建立时，才创建全局定时器
  if (!pingPongInterval) {
    const pongSender = () => {
      const id = _.uniqueId('pong-');
      const payload = { message: 'pong', time: Date.now() };
      // 给所有活跃订阅的客户端统一发送Pong
      Meteor.server.publish_handlers[COLLECTION_NAME].subscriptions.forEach(sub => {
        sub.added(COLLECTION_NAME, id, payload);
      });
    };

    // 立即发送一次初始Pong
    pongSender();
    pingPongInterval = Meteor.setInterval(pongSender, POLL_INTERVAL);
  }

  this.ready();

  this.onStop(() => {
    // 订阅断开时计数-1
    activePingPongSubscriptions--;

    // 最后一个订阅断开，销毁定时器
    if (activePingPongSubscriptions === 0 && pingPongInterval) {
      Meteor.clearInterval(pingPongInterval);
      pingPongInterval = null;
    }
  });
}

// 注册发布函数
Meteor.publish(COLLECTION_NAME, pingPong);

这里的关键是：通过遍历该发布的所有活跃订阅，让全局定时器给每个客户端都推送Pong，避免了每个订阅单独开定时器的问题。

除了借助Collection的added方法，Meteor还有更轻量化的自定义消息方案：

1. 发送自定义DDP消息 #

直接利用DDP协议发送自定义消息，不需要依赖假Collection，更适合心跳这类场景：

服务器端代码 #

function pingPong(credentials) {
  const publisher = this;
  
  const sendCustomPong = () => {
    publisher.connection.send({
      msg: 'custom',
      name: 'ping-pong', // 自定义消息标识，方便客户端识别
      payload: { message: 'pong', time: Date.now() }
    });
  };

  // 立即发送一次
  sendCustomPong();
  const interval = Meteor.setInterval(sendCustomPong, POLL_INTERVAL);

  this.onStop(() => Meteor.clearInterval(interval));
  this.ready();
}

客户端代码 #

// 监听DDP自定义消息
Meteor.connection.onMessage((message) => {
  if (message.msg === 'custom' && message.name === 'ping-pong') {
    console.log('收到Pong:', message.payload);
  }
});

2. 客户端主动拉取（Meteor Methods） #

如果不需要服务器主动推送，也可以让客户端定期调用服务器方法获取Pong，这是一种“拉”模式：

服务器端方法 #

Meteor.methods({
  'getPong'() {
    return { message: 'pong', time: Date.now() };
  }
});

客户端定时调用 #

setInterval(async () => {
  const pong = await Meteor.callAsync('getPong');
  console.log('收到Pong:', pong);
}, 5000);

如果你的Meteor是多服务器部署，全局变量的方式可能会导致每个服务器都有独立定时器，这种情况需要借助Redis之类的工具同步订阅状态；但单服务器部署的话，上面的方案完全够用。

内容的提问来源于stack exchange，提问作者Tainan Felipe