如何將twitter4j與風暴一起使用

Question

我使用twitter4j查詢界面來過濾推文http://twitter4j.org/javadoc/twitter4j/Query.html。但https://github.com/nathanmarz/storm-starter/blob/master/src/jvm/storm/starter/spout/TwitterSampleSpout.java:43中的twitter噴口使用queue.offer（status）。我沒有提及狀態，我如何整合這些API來處理直播推文。

Answer 1

這是我們一直在使用它成功地過濾鳴叫：

public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) { 
    queue = new LinkedBlockingQueue<Status>(1000); 
    _collector = collector; 
    StatusListener listener = new StatusListener() { 

     public void onStatus(Status status) { 
      queue.offer(status); 
     } 

     public void onDeletionNotice(StatusDeletionNotice sdn) { 
     } 

     public void onTrackLimitationNotice(int i) { 
     } 

     public void onScrubGeo(long l, long l1) { 
     } 

     public void onException(Exception e) { 
     } 

    }; 
    TwitterStreamFactory fact = new TwitterStreamFactory(new ConfigurationBuilder().setUser(_username).setPassword(_pwd).build()); 
    _twitterStream = fact.getInstance(); 
    _twitterStream.addListener(listener); 
    _twitterStream.filter(new FilterQuery().track(TERMS_TO_TRACK).setIncludeEntities(true)); 
}