为什么我的firebase回调被多次触发？

Question

我有一个小型节点服务器，监听Firebase的变化并在特定条件下发送电子邮件。这里的代码：

var Firebase = require('firebase'); 
var ref = new Firebase(process.env.FIREBASE_URL); 
ref.authWithCustomToken(process.env.FIREBASE_SECRET, function (err) { 
    if (err) { 
     console.log(new Date().toString(), 'Firebase Authentication Failed!', err); 
     EmailService.send('Firebase authentication failed', '[email protected]', err); 
    } else { 
     ref.child('applicants').on('child_added', function (snapshot) { 
      var applicant = snapshot.val(); 
      if (!(applicant.alerts && applicant.alerts.apply)) { 
       console.log(new Date().toString(), 'New Applicant: ', applicant); 
       var body = applicant.firstName + ' ' + applicant.lastName + '\n' + applicant.email + '\n' + applicant.phoneNumber; 
       EmailService 
       .send('New Applicant', '[email protected]', body) 
       .then(function() {     
        ref.child('applicants').child(snapshot.key()).child('alerts').child('apply').set(true); 
       }) 
       .catch(function (err) { console.log(new Date().toString(), err); }); 
      } 
     }); 
    }                                      
}); 

但是，我不断收到重复的电子邮件。最奇怪的部分是，尽管发送了多封电子邮件，但日志仅显示每个申请人的单个“新申请人：...”声明。

任何想法是什么导致这种情况或如何解决它？

谢谢！

Answer 1

每次authWithCustomToken（）成功时，您的child_added事件都会被触发。每次页面重新加载或重新认证时，都会附加新的监听器，并且每个用户都将触发新的child_added事件，并重新发送电子邮件。

child_added事件通常用于检索Firebase中的 列表项。与返回 位置的全部内容的值不同，为每个现有子女 触发一次child_added ，然后每次将新的子项添加到指定的路径时触发一次。 事件回调会传递包含新子女的 数据的快照。

（重点煤矿）

如果您只想发送电子邮件一次，更好的方法是使用一个queue strategy，在那里你“排队”的活动（例如欢迎邮件），当用户被建造。

然后，您的服务可以读取队列并在成功完成后删除任务。这样，你就不会有蠢货了。

Answer 2

删除现有的监听器添加新监听器会解决这个问题

试试这个off()事件之前，前on()事件

ref.child('applicants').off(); // it will remove existing listener 

那么你的代码

ref.child('applicants').on('child_added', function(snapshot) { 
    var applicant = snapshot.val(); 
    if (!(applicant.alerts && applicant.alerts.apply)) { 
     console.log(new Date().toString(), 'New Applicant: ', applicant); 
     var body = applicant.firstName + ' ' + applicant.lastName + '\n' + applicant.email + '\n' + applicant.phoneNumber; 
     EmailService 
      .send('New Applicant', '[email protected]', body) 
      .then(function() { 
       ref.child('applicants').child(snapshot.key()).child('alerts').child('apply').set(true); 
      }) 
      .catch(function(err) { 
       console.log(new Date().toString(), err); 
      }); 
    } 
});