twitter에서 원하는 단어 크롤링

 

TwitterListener.java 

package com.sist.mapred;

import twitter4j.StallWarning;
import twitter4j.Status;
import twitter4j.StatusDeletionNotice;
import twitter4j.StatusListener;

public class TwitterListener implements StatusListener{

    @Override
    public void onException(Exception ex) {
        // TODO Auto-generated method stub
        System.out.println( “에러 : ” + ex.getMessage() );
        ex.printStackTrace();
    }

    @Override
    public void onDeletionNotice(StatusDeletionNotice arg0) {
        // TODO Auto-generated method stub
        
    }

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

    @Overridepackage com.sist.mapred;

import twitter4j.FilterQuery;
import twitter4j.TwitterStream;
import twitter4j.TwitterStreamFactory;

public class MainClass {

    public static void main(String[] args) throws Exception {
        TwitterStream tws = new TwitterStreamFactory().getInstance();
       
        String[] names = {“문재인”,”안철수”,”반기문”,”김무성”,”안희정”,”정의화”,”유승민”,”박지원”,”김부겸”,”박원순”};
       
        FilterQuery fq = new FilterQuery();
       
        TwitterListener listen = new TwitterListener();
        tws.addListener( listen );
       
        fq.track( names );
        tws.filter( fq );
       
    }

}

    public void onStallWarning(StallWarning arg0) {
        // TODO Auto-generated method stub
        
    }

    @Override
    public void onStatus(Status status) {
        // TODO Auto-generated method stub
        System.out.println( status.getUser().getScreenName() + “:” + status.getText() );
    }

    @Override
    public void onTrackLimitationNotice(int arg0) {
        // TODO Auto-generated method stub
        
    }
    
}

MainClass.java

package com.sist.mapred;

import twitter4j.FilterQuery;
import twitter4j.TwitterStream;
import twitter4j.TwitterStreamFactory;

public class MainClass {

    public static void main(String[] args) throws Exception {
        TwitterStream tws = new TwitterStreamFactory().getInstance();
       
        String[] names = {“문재인”,”안철수”,”반기문”,”김무성”,”안희정”,”정의화”,”유승민”,”박지원”,”김부겸”,”박원순”};
       
        FilterQuery fq = new FilterQuery();
       
        TwitterListener listen = new TwitterListener();
        tws.addListener( listen );
       
        fq.track( names );
        tws.filter( fq );
       
    }

}