1

#testtwitter4j を使用して、特定のハッシュタグ (たとえば ) を持つすべての新しいツイートで Java アプリを更新する必要があります。Twitter REST API での継続的なポーリングを避けるため、Twitter Stream API を使用します。

このコードを実行すると、次のことが期待されます。

  1. コードを実行する
  2. ブラウザーを開き、Twitter にアクセスして、次の内容を含むツイートを投稿します。#test
  3. 特定のハッシュコードを含むツイートのみ、アプリでプリントを表示する

しかし..アプリには何も表示されません..（編集を参照）

誰かアドバイスをくれませんか？

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

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

StatusListener listener = new StatusListener() {
    @Override
    public void onStatus(Status status) {
        System.out.println("@" + status.getUser().getScreenName() + " - " + status.getUser().getId() + " - " + status.getText());
    }
    @Override
    public void onDeletionNotice(StatusDeletionNotice statusDeletionNotice) {
        System.out.println("Post Deletado:" + statusDeletionNotice.getStatusId());
    }
    @Override
    public void onTrackLimitationNotice(int numberOfLimitedStatuses) {
        System.err.println("Limitação:" + numberOfLimitedStatuses);
    }
    @Override
    public void onScrubGeo(long userId, long upToStatusId) {
        System.out.println("Got scrub_geo event userId:" + userId + " upToStatusId:" + upToStatusId);
    }
    @Override
    public void onStallWarning(StallWarning warning) {
        System.out.println("Got stall warning:" + warning);
    }
    @Override
    public void onException(Exception ex) {
        ex.printStackTrace();
    }
};

List<String> queries = new ArrayList<String>();
queries.add("#test");

twitterStream.addListener(listener);
twitterStream.firehose(20);

String[] trackQueries = (String[]) queries.toArray(new String[queries.size()]);

FilterQuery filterQuery = new FilterQuery();
twitterStream.filter(filterQuery.track(trackQueries));

編集：

いくつかのエラーが修正された後、私はsys.outで何かを読んでいますが..いくつかのエラーの後にランダムなもののようです:

[Tue Jul 02 14:58:30 CEST 2013]Establishing connection.
[Tue Jul 02 14:58:30 CEST 2013]Establishing connection.
[Tue Jul 02 14:58:31 CEST 2013]Connection established.
[Tue Jul 02 14:58:31 CEST 2013]Receiving status stream.
[Tue Jul 02 14:58:31 CEST 2013]Connection established.
[Tue Jul 02 14:58:31 CEST 2013]Receiving status stream.
[Tue Jul 02 14:58:31 CEST 2013]Stream closed.
[Tue Jul 02 14:58:31 CEST 2013]Stream closed.
[Tue Jul 02 14:58:31 CEST 2013]Waiting for 250 milliseconds
Stream closed.
Relevant discussions can be found on the Internet at:
    http://www.google.co.jp/search?q=a8fd061d or
    http://www.google.co.jp/search?q=00070a0c
TwitterException{exceptionCode=[a8fd061d-00070a0c a8fd061d-0007099d], statusCode=-1, message=null, code=-1, retryAfter=-1, rateLimitStatus=null, version=3.0.3}
    at twitter4j.StatusStreamBase.handleNextElement(StatusStreamBase.java:199)
    at twitter4j.StatusStreamImpl.next(StatusStreamImpl.java:57)
    at twitter4j.TwitterStreamImpl$TwitterStreamConsumer.run(TwitterStreamImpl.java:478)
Caused by: java.io.IOException: the end of the stream has been reached
    at twitter4j.StatusStreamBase.handleNextElement(StatusStreamBase.java:88)
    ... 2 more
Stream closed.
Relevant discussions can be found on the Internet at:
    http://www.google.co.jp/search?q=a8fd061d or
    http://www.google.co.jp/search?q=00070a0c
TwitterException{exceptionCode=[a8fd061d-00070a0c a8fd061d-0007099d], statusCode=-1, message=null, code=-1, retryAfter=-1, rateLimitStatus=null, version=3.0.3}
    at twitter4j.StatusStreamBase.handleNextElement(StatusStreamBase.java:199)
    at twitter4j.StatusStreamImpl.next(StatusStreamImpl.java:57)
    at twitter4j.TwitterStreamImpl$TwitterStreamConsumer.run(TwitterStreamImpl.java:478)
Caused by: java.io.IOException: the end of the stream has been reached
    at twitter4j.StatusStreamBase.handleNextElement(StatusStreamBase.java:88)
    ... 2 more
[Tue Jul 02 14:58:31 CEST 2013]Unhandled event: {"disconnect":{"code":7,"stream_name":"urbanspirit5-statuses1734930","reason":"admin logout"}}
[Tue Jul 02 14:58:32 CEST 2013]Establishing connection.
[Tue Jul 02 14:58:33 CEST 2013]Connection established.
[Tue Jul 02 14:58:33 CEST 2013]Receiving status stream.

そして、次のようなランダムなツイートがいくつかあります。

@markinhos_jm - 300044892 - CRAZY PARTY AGUARDEM!!!
@bindibba7 - 511548205 - ??????? .. ??????? = ?? ??? ????
@Tamirmdty - 1521605059 - Salah ngetik
@PAOLOves_you - 222755754 - Hirap ah. Text, Chat FB at Tweet? SIYET! #MedyoAZARitu
@agokichi_mmmm - 793252368 - ???DVD??????
4

1 に答える 1

0

Twitter Firehose へのアクセスは、再販業者を介して選択された企業にのみ付与されます。したがって、あなたがそれらの会社の 1 つでない限り、sample()代わりにを使用する必要がありfirehoseます。ただし、いくつかのログが表示されるはずです。ロガーが正しく設定されていますか?

編集:ドキュメントのこのセクションを 読み、有効な twitter4j.properties ファイルを追加してください。アクセス トークンを取得するには、Twitter にサインアップする必要があることに注意してください。トークンを取得して構成ファイルに入力したら、それをクラスパスに含めることができます。

于 2013-07-02T12:02:05.230 に答える