我正在做一个项目,我必须从社交网络(Twitter、Facebook 等)收集用户的实时流。我想使用Twitter Users Streams Api从注册用户那里获取实时推文更新,分析这些更新,然后将结果存储在数据库中。
我正在使用 spring 框架来注册用户,并且我想注册一个线程监听器来获取实时推文。使用spring框架可以做到这一点吗?如果是这样,我该怎么做,我无法通过 Google 搜索找到有用的信息。如果没有,最好的方法是什么?
我正在做一个项目,我必须从社交网络(Twitter、Facebook 等)收集用户的实时流。我想使用Twitter Users Streams Api从注册用户那里获取实时推文更新,分析这些更新,然后将结果存储在数据库中。
我正在使用 spring 框架来注册用户,并且我想注册一个线程监听器来获取实时推文。使用spring框架可以做到这一点吗?如果是这样,我该怎么做,我无法通过 Google 搜索找到有用的信息。如果没有,最好的方法是什么?
有可能的。您首先需要获得连接。代码看起来像这样:
StreamListener listener = new StreamListener() {
@Override
public void onTweet(Tweet tweet) {
logger.info("new tweet coming in");
}
@Override
public void onDelete(StreamDeleteEvent deleteEvent) {
logger.debug("delete event called on stream"););
}
@Override
public void onLimit(int numberOfLimitedTweets) {
logger.debug("stream is being track limited");
}
@Override
public void onWarning(StreamWarningEvent warningEvent) {
logger.debug("warning from twitter");
}
}
};
Connection<Twitter> connection = getCurrentConnection();
// this will open the stream
Stream stream = connection.getApi().streamingOperations()
.filter("filter", Arrays.asList(listener));