微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

hbc Streaming API 的 Java 客户端

程序名称:hbc

授权协议: Apache

操作系统: 跨平台

开发语言: Java

hbc 介绍

hbc (Hosebird Client)是Twitter Streaming API 的 Java 客户端开发包。

主要特性:

  • 支持GZip、OAuth和分块(partitioning);

  • 自动重新连接,并进行适当的backfill计数;

  • 访问原始字节的有效负载

  • 适时重新分配,并进行相关统计

包含了2个主要模块:

  • hbc-core:该模块使用了一个简单的消息队列,用户可以轮询消息。

  • hbc-twitter4j:该模块允许开发者在消息队列中使用Twitter4J项目和它的数据模型,以提供一个分析层。

示例代码

ClientBuilder builder = new ClientBuilder()
  .name("Hosebird-Client-01")                              // optional: mainly for the logs
  .hosts(hosebirdHosts)
  .authentication(hosebirdAuth)
  .endpoint(hosebirdEndpoint)
  .processor(new StringDelimitedProcessor(msgQueue))
  .eventMessageQueue(eventQueue);                          // optional: use this if you want to process client events

Client hosebirdClient = builder.build();
// Attempts to establish a connection.
hosebirdClient.connect();

// on a different thread, or multiple different threads....
while (!client.isDone()) {
  String msg = msgQueue.take();
  something(msg);
  profit();
}

hosebirdClient.shutdown();

hbc 官网

https://github.com/twitter/hbc

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐