Twitter4j TwitterStream 无法获取所有推文

Question

我试图通过 twitter4j TwitterStream 对象获取 twitter 上的所有推文。我不确定我是否收到了所有推文。为了测试流 API 返回推文的延迟，我从我的 Twitter 帐户中发布了一条推文。但过了很长一段时间我都没有收到那条推文。

twitter4j 是否捕获 Twitter 上发布的每一条推文，还是丢失了很大比例的推文？或者我在这里做错了什么？ 这是我用来获取推文的代码：

        StatusListener listener = new StatusListener(){
        int countTweets = 0;    // Count to implement batch processing

        public void onStatus(Status status) {
            countTweets ++;
            StatusDto statusDto = new StatusDto(status);
            session.saveOrUpdate(statusDto);

            // Save 1 round of tweets to the database
            if (countTweets == BATCH_SIZE) {
                countTweets = 0;
                session.flush();
                session.clear();
            }
        }

        public void onDeletionNotice(StatusDeletionNotice statusDeletionNotice) {}

        public void onTrackLimitationNotice(int numberOfLimitedStatuses) {}

        public void onException(Exception ex) {
            ex.printStackTrace();
        }

        public void onScrubGeo(long arg0, long arg1) {
            // TODO Auto-generated method stub
        }           
    };

    ConfigurationBuilder cb = new ConfigurationBuilder();
    cb.setDebugEnabled(true)
      .setOAuthConsumerKey(Twitter4jProperties.CONSUMER_KEY)
      .setOAuthConsumerSecret(Twitter4jProperties.CONSUMER_SECRET)
      .setOAuthAccessToken(Twitter4jProperties.ACCESS_TOKEN)
      .setOAuthAccessTokenSecret(Twitter4jProperties.ACCESS_TOKEN_SECRET);

    TwitterStream twitterStream = new TwitterStreamFactory(cb.build()).getInstance();
    twitterStream.addListener(listener);

    session = HibernateUtil.getSessionFactory().getCurrentSession();
    transaction = session.beginTransaction();

    // sample() method internally creates a thread which manipulates TwitterStream and calls these adequate listener methods continuously.
    twitterStream.sample();

Answer 1

我对此持开放态度，但我相信它的工作原理是这样的......

Streaming API 只为非合作伙伴提供推文样本。它是“花园软管”，而不是一些 Twitter 合作伙伴所获得的“消防软管”。但您可以申请完全访问权限。

.sample() 给出了这个“花园软管”。你的 Twitter 帐户将无法访问 Firehose，尽管我认为如果你确实有访问权限的话，Firehose 会有一个 twitterStream。

在此页面上搜索“statuses/sample”以了解具体信息：https://dev.twitter.com/docs/流式API/方法