javascript - 如何使用 ntwitter 停止和重新启动 Twitter 流

Question

我是 node.js 的新手，所以请原谅这个简单的问题。我正在写一些标准的东西:一个使用 ntwitter 进入 twitter 并将内容保存在 mysql 上的 rest API。我遇到的问题是使用 ntwitter 断开连接并重新连接到 Twitter。

我检查了一个与我的有点相似的问题，但仍然没有答案:Restarting nodejs ntwitter twitter stream with different track keywords

问题有两个:

1) 如何检查 twit.stream 是否存活
2) 如何杀死它/手动断开与 twitter 的连接

我正在使用 destroy 但这似乎不起作用。代码的相关部分是:

if (values[0] == 'newStatusAdded') {
  console.log('Need to stop twitter listener');
  //check if twitter stream is running
  if (twit.stream) {
    twit.stream.destroy;
    debugger;
    console.log('Stopped twitter listener');
  }

谢谢....

Answer 1

我认为您的代码中某处有这样的设置:

twit.stream('statuses/sample', function(stream) {
  stream.on('data', function (data) {
    console.log(data);
  });
});

从回调中保存流变量，例如在 stream.on() 之后:

  twit.currentTwitStream = stream;

这只是一个建议。也许您有一个中央配置对象，它更适合放置当前流对象。使用 currentTwitStream 你可以这样做:

1. currentTwitStream.readable 在错误或关闭后为 false。
2. currentTwitStream.destroy() 销毁流。