当前位置: 软件>java软件
Streaming API 的 Java 客户端 hbc
本文导语: hbc (Hosebird Client)是Twitter Streaming API 的 Java 客户端开发包。 主要特性: 支持GZip、OAuth和分块(partitioning); 自动重新连接,并进行适当的backfill计数; 访问原始字节的有效负载; 适时重新分配,并进行相关统计。 包含...
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();
您可能感兴趣的文章:
本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术,将尽最大努力为读者提供更好的信息聚合和浏览方式。
本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。
本站(WWW.)站内文章除注明原创外,均为转载、整理或搜集自网络。欢迎任何形式的转载,转载请注明出处。