stoppen Sie den Twitter-stream und zurückgeben der Liste der status mit twitter4j

Mit dem code-Beispiel von Twitter4j, möchte ich t-stop, die stream nach einer Liste der 1.000-status erhoben wurden, und wieder in dieser Liste. Wie kann ich das tun?

public class Stream {
    public List<Status> execute throws TwitterException {

    List<Status> statuses = new ArrayList();

    ConfigurationBuilder cb = new ConfigurationBuilder();
    cb.setDebugEnabled(true);
    cb.setOAuthConsumerKey("bbb");
    cb.setOAuthConsumerSecret("bbb");
    cb.setOAuthAccessToken("bbb");
    cb.setOAuthAccessTokenSecret("bbb");

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

    StatusListener listener = new StatusListener() {

        public void onStatus(Status status) {
            statuses.add(status);
            if (statuses.size>1000){
              //return statuses. Obviously that's not the correct place for a return statement...
            }
        }

        public void onDeletionNotice(StatusDeletionNotice statusDeletionNotice) {
            System.out.println("Got a status deletion notice id:" + statusDeletionNotice.getStatusId());
        }

        public void onTrackLimitationNotice(int numberOfLimitedStatuses) {
            System.out.println("Got track limitation notice:" + numberOfLimitedStatuses);
        }

        public void onScrubGeo(long userId, long upToStatusId) {
            System.out.println("Got scrub_geo event userId:" + userId + " upToStatusId:" + upToStatusId);
        }

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

    FilterQuery fq = new FilterQuery();
    String keywords[] = {"Keyword 1", "Keyword 2"};

    fq.track(keywords);

    twitterStream.addListener(listener);
    twitterStream.filter(fq);

}
  • Hast u bekommen, eine Lösung?
  • Nein... immer noch Interesse an einer Antwort!
InformationsquelleAutor seinecle | 2013-08-02
  1. 4

    Ist es nicht eine gute Idee, um eine asynchrone code in den synchronen Modus schaltet. Bitte sehen https://stackoverflow.com/a/5934656/276263
    Sehen Sie, wenn Sie können überarbeiten Sie Ihre Logik.

    Jedoch, der code unten funktioniert, wie pro Ihre Anforderung. 

    public class Stream {

  public static void main(String[] args) throws TwitterException {
    Stream stream = new Stream();
    stream.execute();
  }

  private final Object lock = new Object();
  public List<Status> execute() throws TwitterException {

    final List<Status> statuses = new ArrayList();

    ConfigurationBuilder cb = new ConfigurationBuilder();
    cb.setDebugEnabled(true);
    cb.setOAuthConsumerKey("bbb");
    cb.setOAuthConsumerSecret("bbb");
    cb.setOAuthAccessToken("bbb");
    cb.setOAuthAccessTokenSecret("bbb");

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

    StatusListener listener = new StatusListener() {

      public void onStatus(Status status) {
        statuses.add(status);
        System.out.println(statuses.size() + ":" + status.getText());
        if (statuses.size() > 100) {
          synchronized (lock) {
            lock.notify();
          }
          System.out.println("unlocked");
        }
      }

      public void onDeletionNotice(
          StatusDeletionNotice statusDeletionNotice) {
        System.out.println("Got a status deletion notice id:"
            + statusDeletionNotice.getStatusId());
      }

      public void onTrackLimitationNotice(int numberOfLimitedStatuses) {
        System.out.println("Got track limitation notice:"
            + numberOfLimitedStatuses);
      }

      public void onScrubGeo(long userId, long upToStatusId) {
        System.out.println("Got scrub_geo event userId:" + userId
            + " upToStatusId:" + upToStatusId);
      }

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

      @Override
      public void onStallWarning(StallWarning sw) {
        System.out.println(sw.getMessage());

      }
    };

    FilterQuery fq = new FilterQuery();
    String keywords[] = { "federer", "nadal", "#Salute" };

    fq.track(keywords);


    twitterStream.addListener(listener);
    twitterStream.filter(fq);

    try {
      synchronized (lock) {
        lock.wait();
      }
    } catch (InterruptedException e) {
      //TODO Auto-generated catch block
      e.printStackTrace();
    }
    System.out.println("returning statuses");
    twitterStream.shutdown();
    return statuses;
  }
}
    • Ich am Ende zu akzeptieren diese Antwort, weil das ist die, die ich umgesetzt und es funktioniert gut. Thx.
    InformationsquelleAutor krishnakumarp
  2. 6

    Erwägen Sie die Verwendung einer BlockingQueue als Vermittler, der mithilfe der listener hinzu, die Status Objekte an.

    Nachdem der stream gestartet wurde können Sie mit der Einnahme beginnen Statuses aus der Warteschlange, bis Sie die tausend, die Sie benötigen.

    Als Ausgangspunkt, würde es wie folgt Aussehen:

    public class Stream {
    private static final int TOTAL_TWEETS = 1000;

    public List<Status> execute() throws TwitterException {
        //skipped for brevity...

        //TODO: You may have to tweak the capacity of the queue, depends on the filter query
        final BlockingQueue<Status> statuses = new LinkedBlockingQueue<Status>(10000); 
        final StatusListener listener = new StatusListener() {

            public void onStatus(Status status) {
                statuses.offer(status); //Add received status to the queue
            }

            //etc...
        };

        final FilterQuery fq = new FilterQuery();
        final String keywords[] = {"Keyword 1", "Keyword 2"};
        fq.track(keywords);

        twitterStream.addListener(listener);
        twitterStream.filter(fq);

        //Collect the 1000 statues
        final List<Status> collected = new ArrayList<Status>(TOTAL_TWEETS);
        while (collected.size() < TOTAL_TWEETS) {
            //TODO: Handle InterruptedException
            final Status status = statuses.poll(10, TimeUnit.SECONDS); 

            if (status == null) {
                //TODO: Consider hitting this too often could indicate no further Tweets
                continue;
            }
            collected.add(status);
        }
        twitterStream.shutdown();

        return collected;
    }
}
    • Hallo, ich versuche, schließen Sie den twitter-stream, aber ich bekomme immer eine ganze Reihe von Warnungen/Fehlern. Ich habe eine Methode, die cals die Bereinigung und shutdon. und ich bekomme: (bitte siehe meine "Antwort von unten"). Wissen Sie, warum dies geschieht?
    InformationsquelleAutor Jonathan
  3. 0

    Gibt es zwei Möglichkeiten:

    Wenn Sie nur brauchen, um zu beenden den thread, verbraucht Strom (das ist der thread, der fordert, Ihr Hörer), können Sie sich twitterStream.cleanUp();. Diese werden ordnungsgemäß beenden Sie den thread. Sie möchten möglicherweise verwenden Sie eine boolean stopped variable in Ihrem status-listener so zu ignorieren, die Anrufe, die Sie erhalten, nachdem dieses Ereignis.

    Schließen Sie die Strom verbrauchen-thread zusammen mit dem dispatcher-thread (das ist ein deamon-thread) durch den Aufruf twitterStream.shutdown(); dies ist Jedoch ein brutaler Ansatz, endet die Kommunikation mit der twitter API. Obwohl es funktioniert, wenn Sie rufen Sie diese aus dem inneren der Zuhörer, ich würde lieber den Ansatz vorgeschlagen, durch @krishnakumarp

    InformationsquelleAutor c.s.
Schreibe einen Kommentar