H5W3
当前位置:H5W3 > 其他技术问题 > 正文

twitter hbc 调用streaming api 获取不到响应数据

1.按照github上的示例代码写的
https://github.com/twitter/hb…
2.代码入下

    public class FilterStreamExample {
    public static void main(String[] args) throws InterruptedException {
        run("consumerKey", "consumerSecret", "token", "secret");
    }

    public static void run(String consumerKey, String consumerSecret, String token, String secret) throws InterruptedException {
        BlockingQueue<String> queue = new LinkedBlockingQueue<String>(10000);
        StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();
        endpoint.trackTerms(Lists.newArrayList("twitterapi", "#yolo"));
        Authentication auth = new OAuth1(consumerKey, consumerSecret, token, secret);
        Client client = new ClientBuilder()
                .hosts(Constants.STREAM_HOST)
                .endpoint(endpoint)
                .authentication(auth)
                .processor(new StringDelimitedProcessor(queue))
                .build();
        client.connect();
        for (int msgRead = 0; msgRead < 1000; msgRead++) {
            String msg = queue.take();
            System.out.println(msg);
        }
        client.stop();
    }
}

本文地址:H5W3 » twitter hbc 调用streaming api 获取不到响应数据

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址