我有一个小型 Spring 应用程序,它使用 Spring 社交 twitter 从 Twitter 的公共(public) API 流式传输数据。
代码非常简单。我有一个配置类,它公开了 twitter 模板类型的 bean。
@Bean
Twitter getTwitterTemplate() {
Twitter twitter = new TwitterTemplate(consumerKey, consumerSecret, accessToken, accessTokenSecret);
return twitter;
}
我有另一个服务类,它使用 twitter 模板 bean 来根据一些主题标签过滤流。我在服务 bean 的 postContruct 中启动流处理过程。
@Autowired
Twitter twitter;
@Value("${app.hashtags}")
String[] hashtags;
@PostConstruct
private void startStream() {
FilterStreamParameters parameters = new FilterStreamParameters();
for (String hashtag : hashtags) {
parameters.track(hashtag);
}
twitter.streamingOperations().filter(parameters, tweetStreamListeners);
}
应用程序启动后,流媒体就会开始,一切正常。
我的问题是如何根据某些操作停止流式传输?例如,应用程序将在调用时提供一个端点,它应该停止流处理。
最佳答案
Stream接口(interface)有一个 close() 方法,所以你可以这样做:
...
private Stream myStream;
...
@PostConstruct
private void startStream() {
this.myStream = twitter.streamingOperations().filter(parameters, tweetStreamListeners);
private void closeStream() {
this.myStream.close();
}
关于java - Spring 社交推特停止流媒体操作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52756342/