春季社交推特停止流媒体操作

Question

我有一个小型的Spring应用程序，它使用Spring social twitter从twitter的公共API流式传输数据。

代码非常简单。我有一个配置类，它公开了一个类型的推特模板的 bean。

@Bean
Twitter getTwitterTemplate() {
Twitter twitter = new TwitterTemplate(consumerKey, consumerSecret, accessToken, accessTokenSecret);
return twitter;
}

我还有另一个服务类，它使用 Twitter 模板 bean 根据一些主题标签过滤流。我在服务 Bean 的构造后启动流式处理过程。

@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);
}

应用程序启动后，流式传输将开始，一切正常。

我的问题是如何根据某些操作停止流式传输？例如，假设应用程序将在调用时提供一个端点，它应该停止流式处理过程。

Answer 1

Stream 接口有一个 close(( 方法，所以你可以执行以下操作：

...
private Stream myStream;
... 
@PostConstruct
private void startStream() {
this.myStream = twitter.streamingOperations().filter(parameters, tweetStreamListeners);
private void closeStream() {
this.myStream.close();
}