订阅RxJava Observable从春季背景

Question

我有一个RxJava Observable，我想在我的web应用程序的后台处理。这样服务可以对消息队列中的事件作出反应。是否有一个Spring配置可以让我直接订阅这个Observable？

就像Spring的TaskExector，这将允许后台线程处理Observable事件。但有些更复杂的地方，我不必活着的线程。

Answer 1

我们所做的是有一个Spring服务，它创建Observable并在@PostConstruct方法中订阅它，并在@PreDestroy中取消订阅。这允许通过JMX公开诸如计数器和并行性控件之类的东西，甚至可以通过JMX或通过服务方法来停止/重新启动observable。