Firebase云函数重复向同一设备发送相同通知问题求助

嘿，我来帮你排查这个重复推送通知的问题！这种情况在Firebase云函数里挺常见的，主要集中在触发条件、异步处理和数据重复这几个点上，咱们一步步来分析：

1. 触发事件选错了，导致多次触发 #

如果你的云函数用的是onWrite或者onUpdate，而不是onCreate，那麻烦就来了——不仅新增emergency记录会触发函数，后续对这条记录的任何修改（比如更新事件状态）都会再次触发，自然会重复推送。

修复方案：把触发方式改成onCreate，只在新记录创建时执行一次：

// 错误示例：onWrite会在创建、更新、删除时都触发
exports.sendEmergencyNotification = functions.database.ref('/emergency/{emergencyId}')
  .onWrite((change, context) => {
    // ...你的原有代码
  });

// 正确示例：onCreate仅在新记录添加时触发
exports.sendEmergencyNotification = functions.database.ref('/emergency/{emergencyId}')
  .onCreate((snapshot, context) => {
    // ...你的原有代码
  });

2. 异步操作没处理好，Firebase误以为执行失败重试 #

Firebase云函数要求你返回一个Promise来标记执行完成，如果你的代码里有异步操作（比如查询设备、调用FCM推送）但没正确返回Promise，Firebase会觉得函数执行崩了，自动重试好几次，这就导致了重复推送。

修复方案：把所有异步操作串成完整的Promise链，最后返回这个链：

// 错误示例：没返回Promise，函数提前结束，Firebase重试
exports.sendEmergencyNotification = functions.database.ref('/emergency/{emergencyId}')
  .onCreate((snapshot, context) => {
    const emergencyData = snapshot.val();
    // 查询设备但没返回Promise
    admin.database().ref('/devices').orderByChild('distance').limitToFirst(5).once('value')
      .then(devicesSnapshot => {
        return admin.messaging().sendToDevice(tokens, payload);
      });
    // 这里直接结束，Firebase以为执行失败
  });

// 正确示例：返回完整的Promise链
exports.sendEmergencyNotification = functions.database.ref('/emergency/{emergencyId}')
  .onCreate((snapshot, context) => {
    const emergencyData = snapshot.val();
    // 把整个异步流程作为Promise返回
    return admin.database().ref('/devices').orderByChild('distance').limitToFirst(5).once('value')
      .then(devicesSnapshot => {
        const tokens = [];
        devicesSnapshot.forEach(device => {
          // 这里加个去重，避免同一设备多个Token重复推送
          const token = device.val().fcmToken;
          if (token && !tokens.includes(token)) {
            tokens.push(token);
          }
        });
        const payload = {
          notification: {
            title: '紧急事件提醒',
            body: `附近发生紧急事件：${emergencyData.description}`
          }
        };
        // 返回推送操作的Promise
        return admin.messaging().sendToDevice(tokens, payload);
      })
      .catch(error => {
        console.error('推送失败:', error);
        throw error; // 抛出错误让Firebase记录失败原因
      });
  });

3. 设备Token重复，同一设备收到多次通知 #

用户登录/登出时，可能会生成新的FCM Token，但旧Token没从数据库里删掉，导致查询到的设备列表里有重复Token，推送时同一设备就会收到好几条一样的通知。

修复方案：

• 用户登录时，检查数据库中该用户的旧Token，有就删掉，只保留最新的。
• 在云函数里对查询到的Token做去重处理（就像上面代码里的!tokens.includes(token)判断那样）。

4. 函数分支没正确终止，导致重复执行 #

如果你的函数里有条件判断分支，某些分支没返回Promise或者没提前终止，也可能让Firebase误以为执行异常而重试。比如判断emergency记录无效时，没返回一个空的Promise结束函数。

修复方案：确保所有代码路径都返回Promise：

exports.sendEmergencyNotification = functions.database.ref('/emergency/{emergencyId}')
  .onCreate((snapshot, context) => {
    const emergencyData = snapshot.val();
    // 如果数据无效，返回resolved的Promise直接终止
    if (!emergencyData || !emergencyData.description) {
      console.log('无效的紧急事件数据，终止执行');
      return Promise.resolve();
    }
    // 后续正常逻辑...
  });

最后建议你去Firebase控制台的函数日志里看看，函数是不是被多次触发，每次触发的原因是什么（是新创建、更新还是重试），这能帮你更快定位问题。

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