【发布时间】:2017-06-12 21:44:57
【问题描述】:
我有一个 RxJava Observable,我想在我的 Web 应用程序的后台处理它。这样服务可以对消息队列上的事件做出反应。是否有允许我直接订阅此 Observable 的 Spring 配置?
类似于 Spring TaskExector 的东西,它允许后台线程处理 Observable 事件。但是有些更复杂的东西,我不必让线程保持活动状态。
【问题讨论】:
我有一个 RxJava Observable,我想在我的 Web 应用程序的后台处理它。这样服务可以对消息队列上的事件做出反应。是否有允许我直接订阅此 Observable 的 Spring 配置?
类似于 Spring TaskExector 的东西,它允许后台线程处理 Observable 事件。但是有些更复杂的东西,我不必让线程保持活动状态。
【问题讨论】:
我们所做的是有一个 Spring 服务,它创建 Observable 并在 @PostConstruct 方法中订阅它,并在 @PreDestroy 中取消订阅。这允许通过 JMX 公开诸如计数器和并行控制之类的东西,甚至可以通过 JMX 或通过服务方法停止/重新启动 observable。
【讨论】: