Node.js 和 Twitter 流媒体 API答案

【问题标题】：Node.js & Twitter Streaming APINode.js 和 Twitter 流媒体 API
【发布时间】：2013-04-05 14:34:20
【问题描述】：

我目前正在尝试在同一连接上同时流式传输两个轨道，我遇到的问题是为第二个流打开了一个新连接，其中 Twitter 拒绝并出现错误代码 7，这是 Twitter 抛出最旧的连接为最新的连接让路，我可以通过编程方式做些什么来防止这种情况发生吗？

这是我正在使用的代码

var request = oa.get("https://stream.twitter.com/1.1/statuses/filter.json?track=tweet1", access_token, access_token_secret );

request.addListener('response', function (response) {

    response.setEncoding('utf8');

    response.addListener('data', function (chunk) {
        var theTweets = JSON.parse(chunk);
        console.log(theTweets);
        MongoClient.connect("mongodb://localhost:27017/db", function(error, database) {  
            var collection = database.collection('coll'); 
            collection.insert(theTweets, function(err, result) {});
        });    
    });

    response.addListener('end', function () {
        console.log('--- END ---');
    });

});


var requestTweet2 = oa.get("https://stream.twitter.com/1.1/statuses/filter.json?track=tweet2", access_token, access_token_secret );

requestTweet2.addListener('response', function (response) {

    response.setEncoding('utf8');

    response.addListener('data', function (chunk) {
        var theTweets = JSON.parse(chunk);

        MongoClient.connect("mongodb://localhost:27017/db", function(error, database) {  
            var collection = database.collection('coll'); 
            collection.insert(theTweets, function(err, result) {});
        });    
    });

    response.addListener('end', function () {
        console.log('--- END ---');
    });

});
requestTweet2.end();
request.end();

【问题讨论】：

标签： node.js mongodb twitter

【解决方案1】：

Twitter 公共流将只接受每个 IP 地址的一个连接。你可以找到这个documented here。

每个帐户只能与公众建立一个长期联系端点，并使用相同的帐户凭据将导致最旧的连接断开连接。

作为替代方案，您可以使用user stream，它将传入的推文限制为经过身份验证的用户的帐户。

【讨论】：