Java – How to Get Users Tweets using Twitter HBC Http Client

• Key Steps in Retrieving the Users Tweets
• Code Sample – Get User Tweets

Key Steps in Retrieving the Users Tweets

Following are key steps required to be taken to retrieve users tweets:

• Get consumer key and access tokens details
• Determine userId for users for whom you want to get the tweets as they appear. For test purpose, you could get the UserIds from GetTwitterId.com
• Use the above details in the code such as below to retrieve the data.

Code Sample – Get User Tweets

Pay attention to some of the following facts:

• You are required to get details such as following to get going. These details could be obtained from twitter developers website.
  • Consumer Key
  • Consumer Secret
  • Access Token
  • Access Token Secret
• Get userId for users for whom you want to get the tweets as they appear. For test purpose, you could get the UserIds from GetTwitterId.com
• The class given below consists of a main method which is used to invoke
• StatusesFilterEndpoint class is used to get the user tweets. It has this API “public StatusesFilterEndpoint followings(List<Long> userIds)” which makes it happen.
• A ClientBuilder is used to create a Client object using following information:
  • OAuth object created using consumer and access token details
  • Host information
  • Endpoint information
  • Queue object which would be used to deliver message to this program

public class FilterStreamExample {

 public static final String CONSUMER_KEY = "Your_consumer_key";
 public static final String CONSUMER_SECRET = "Your_consumer_secret";
 public static final String ACCESS_TOKEN = "Your_access_token";
 public static final String ACCESS_TOKEN_SECRET = "Your_access_token_secret";

 public static void process(String consumerKey, String consumerSecret,
   String token, String secret) throws InterruptedException {
  //
  // Create queue which would be used to get message
  //
  BlockingQueue queue = new LinkedBlockingQueue(10000);
  //
  // Create an endpoint of type StatusesFilterEndpoint; It has APIs to retrieve 
  // users tweets or treats related with mention or hashtags
  //
  StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();
  //
  // Add one or more users to follow the tweets; 
  // 
  endpoint.followings(Lists.newArrayList( 136976940L));
  //
  // Create OAuth object using consumer keys/secret and access token/secret
  //
  Authentication auth = new OAuth1(consumerKey, consumerSecret, token,
    secret);  
  //
  // Create a new BasicClient. By default gzip is enabled.
  //
  Client client = new ClientBuilder().hosts(Constants.STREAM_HOST)
    .endpoint(endpoint).authentication(auth)
    .processor(new StringDelimitedProcessor(queue)).build();
  //
  // Establish a connection
  //
  client.connect();
  //
  // Code below would extract message as it appears on Twitter
  // Do whatever needs to be done with messages; In the code below,
  // the message is printed; In real world, the message could be stored 
  // in Hadoop storage
  //
  for (int msgRead = 0; msgRead < 1000; msgRead++) {
   String msg = queue.take();
   System.out.println(msg);
  }
  client.stop();
 }

 public static void main(String[] args) {
  try {
   FilterStreamExample.process(CONSUMER_KEY, CONSUMER_SECRET,
     ACCESS_TOKEN, ACCESS_TOKEN_SECRET);
  } catch (InterruptedException e) {
   System.out.println(e);
  }
 }
}