在阅读并在线检查一些教程后，我对反应性编程Rxjava感到非常兴奋。我想将其应用于我的项目。
我的项目（例如X）与外部系统接口的方式是将某些请求发送到System Y 通过JMS，直到收到响应（在可配置的持续时间）中，该过程停止了。现在，传统上，我们有一个时间监视器系统，该系统不断进行固定间隔进行轮询以检查响应是否到达，并且是否不信息X和X采取了一些措施。但是在同时，y可以回复，X也必须照顾好响应。
这里涉及种族状况，还有很多并发问题，因为它涉及大量的书籍保存和有关对象的更新。
通过应用可观察结果（X和Y之间）和观察者（X）清楚地应用于我的用例，这完全适合我的用例但是要通知响应被延迟，您不再需要等待它，再加上一些关于延迟响应等的书等。
RXJAVA是否提供了一些机制来计时请求和响应持续时间？您是否认为RXJAVA适合我的UC，或者您有一些更好的建议。
我的主要关注点是处理并发，因为该系统在并行处理响应和更新对象时会遇到很多问题。虽然RXJAVA听起来很有希望，因为它会通过允许事件序列（到达时响应）来减少并发性，但这是错误的假设吗？
注意：这不是我们在这里谈论的移动应用程序。
当然，rxjava非常适合您在这里要做的事情。如果在一个时间跨度内没有输出项目，则Observable.timeout将发出错误。（这将下游传播为一个错误，并作为未取消标准上游，因此您可以在源上执行适当的处理）。