node.js - 如何防止每条新推文触发 Twitter 流中的回调？

Question

我的应用程序在 Twitter 流中筛选匹配的字符串。当它找到匹配时，它应该增加一个计数器并通过 socket.io 将新的计数发送给客户端。不幸的是，socket.io 会在每条推文中发出信号，而不是在每条匹配中发出信号。它的发射频率超出必要范围，呈指数级增长，导致浏览器出现问题。如何防止 Twitter 流中的每个新事件调用回调？

这是我的 Twitter 流代码:

// Compares watchList (NYT Keywords) to Twitter stream, counts every mention
exports.keywordStream = function(callback) {
  exports.initializeFeed().then(function(watchList) {

  // enter the stream
    t.stream('statuses/filter', { track: watchKeywords }, function(stream) {

    // read twitter firehose ('data') for incoming tweets.
      stream.on('data', function(tweet) {
        var tweetText = tweet.text.toLowerCase();

        // compare the text of each tweet to each NYT keyword in the watchList
        _.each(watchKeywords, function(e) {

          // if the keyword exists in the tweet, += 1
          if (tweetText.indexOf(e.toLowerCase()) !== -1) {
            watchList.keywords[e] += 1;
            watchList.total += 1;
          }

        });
        callback(watchList);
      });
    });
  });
 };

这是我在 app.js 中的代码。我希望只要有匹配的推文就发出此消息。

io.sockets.on('connection', function(socket) {
  // console.log("client connected");
});

firehose.keywordStream(function(watchList) {
  // STREAMING . . .
  setInterval(function() {
    io.sockets.emit('watchUpdate', {'watchList': watchList});
  }, 1000/60);
});

这只是我的 View 文件中的一个片段:

<script>
 var socket = io.connect(window.location.hostname);
 console.log('hello world')
   socket.on('watchUpdate', function(data) {
   console.log('chirp')

大约 20 秒后，我的浏览器被锁定。它看起来像这样:

写完这个问题后，我意识到处理更新的 watchList 的回调函数位于 twitter 流内部。无论推文是否命中 IF 语句，回调似乎都会在每条推文中调用。如果我将回调放在 IF 语句内，则每条推文仍会调用该回调。

为 Node.js 中回调的性质提供任何见解、提示或评论，欢呼吧。

Answer 1

我的问题是我将发出嵌套在 setInterval 中。 setInterval 与每个回调一起堆叠。如果删除 setInterval()，io.sockets.emit 将按预期执行。

// app.js
io.sockets.on('connection', function(socket) {
  // console.log("client connected");
});

firehose.keywordStream(function(watchList) {
  io.sockets.emit('watchUpdate', {'watchList': watchList});
});

最后一步是将我的回调放在 IF 语句中，以确保它仅在匹配的关键字上触发。

 // twitter firehose
 exports.keywordStream = function(callback) {
   exports.initializeFeed().then(function(watchList) {

     // enter the stream
     t.stream('statuses/filter', { track: watchKeywords }, function(stream) {

       // read twitter firehose ('data') for incoming tweets.
       stream.on('data', function(tweet) {
         var tweetText = tweet.text.toLowerCase();

         // compare the text of each tweet to each NYT keyword in the watchList
         _.each(watchKeywords, function(e) {

           // if the keyword exists in the tweet, += 1
           if (tweetText.indexOf(e.toLowerCase()) !== -1) {
             watchList.keywords[e] += 1;
             watchList.total += 1;
             callback(watchList);
           }
         });
       });
     });
   });
 };

完成这两项调整后，浏览器会收到匹配推文的实时更新。