0

私はそれについて読んでチュートリアルをオンラインで確認した後、反応性プログラミングRxJavaにかなり興奮しています。私は私のプロジェクトでそれを適用したい。外部システムへのリアクションテクニックの適用Javaとのインターフェース

私のプロジェクト(Xと言う)は、何らかのリクエストがJMSを介してシステムYに送信され、レスポンスが受信されるまで(設定可能な時間内に)プロセスは停止します。さて、伝統的には、応答が到着したかどうかを確認するために一定の間隔でポーリングを保持する時間監視システムがあります。しかし同時に、Yは応答を返すことができ、Xもそれを処理する必要があります。

ここには競合状態があり、CRUDトランザクションには多数の本の保守と関連するオブジェクトの更新が含まれるため、並行性の問題が多くあります。

Observables(XとYの間)とObservers(X)を明確に適用することで、RxJavaに完全に適合しますが、YはYからの応答を待たないように、永遠に応答が遅れて、それを待つ必要がなくなり、遅れた応答などを保ついくつかの本をやります。

RxJavaは要求と応答の時間を計るメカニズムを提供していますか? あなたはRxJavaが私のUCに合っていると思っていますか、あなたにはより良い提案がありますか?

私の主な関心事は、このシステムは、応答を並行して処理し、オブジェクトを更新する際に多くの問題を抱えているため、並行処理を扱うことです。 RxJavaは、イベントのシーケンス(到着時の応答)を許可することで並行性が低下するため、有望視されていますが、間違った前提ですか?

注:これはここで話しているモバイルアプリケーションではありません。

答えて

0

確かに、RxJavaはあなたがここでやりたいことに非常に適しています。 Observable.timeoutは、期間内にアイテムが放出されない場合にエラーを発する。 (これは、ダウンストリームとしてエラーとして、アップストリームはサブスクリプションとして伝播するので、ソースで適切な処理を実行できます)。

関連する問題