は、最初のホストに障害が発生した後にrxnettyを使用してセカンダリホストにフェイルオーバーすることが可能です。

rxnettyに初心者です。私はretryWhenによってエラーを処理しようとしていますが、私は接続されている/私の最初のホストに接続する元の観測可能性に立ち往生しています。セカンダリホストにフェールオーバーする方法はありますか？は、最初のホストに障害が発生した後にrxnettyを使用してセカンダリホストにフェイルオーバーすることが可能です。

出典

2016-09-04 Tim Waite

0.5.xを使用している場合は、ロードバランサ抽象化を使用してこれを実現できます。例えば、以下の（）それは（繰り返しを使用しています）が、あなたはretryWhen（とそれを置き換えることができます）、それを行う方法を示してい

https://github.com/ReactiveX/RxNetty/tree/0.5.x/rxnetty-examples/src/main/java/io/reactivex/netty/examples/http/loadbalancing

あなたはの上に、この自分自身を構築する必要が0.4.xを使用している場合RxNetty。

出典

2016-09-04 18:01:28

ありがとうございます。 VIP v1に接続する観察可能なo1を作成し、オブザーバーob1をサブスクライブした後、接続試行が失敗した場合、再試行したいが、別のVIP v2に接続して、同じオブザーバーによって観察されている場合ob1。ここで私が今試したことがあります。（a）retryWhenに渡されたFunc1において、私は新しい観測可能なo2を作成してVIP v2に接続し、ob1をo2に登録します。（b）は、空の観測値（フラットマップObservable <？extends Throwable>）を返して、o1の再試行がないようにします。しかし、私はまだonErrorになります、どのようにro resovle？ありがとう –

上記に従います。ここに結果があります（1）、すべてが正しい、2つの書き込み、1が受信されました。（2）オブザーバーはonNextとOnCompletedの通知を受け取ります。これはGOODです（3）私のオブザーバーはまだBADである例外を伴うonError呼び出しを受け取ります。例外を発生させるにはどうすればよいですか？ありがとうございました –

私は別の方法を試みましたリフトでは、より良い（1）子供のオブザーバー（2）に渡す前にonErrorのIO例外を処理するリフトで別のVIPを再試行しましたオブザーバーは、別の観察可能にする。副作用が何であるか分かりませんが、助言はありますか？ありがとう。 –

は、最初のホストに障害が発生した後にrxnettyを使用してセカンダリホストにフェイルオーバーすることが可能です。

答えて

関連する問題