問題タブ [netflix]

NetflixのHystrixをセットアップしています。ただし、ファイアウォールが原因で、Hystrix タービンはサーバー プールをポーリングできません。ただし、サーバー プール内のノードは、イベント データをタービンにプッシュできます。単純な方法は、個々のノードがプッシュする中間サーバーをセットアップし、タービンがこのサーバーをポーリングすることです。個々のノードがイベント データをタービンにプッシュするためのより良い方法はありますか?

私は、Netflix のオープン ソース プロジェクトの大ファンです。彼らは本当にクールなものを作りました。

Zuul をセットアップしましたが、正常に動作しています。あらゆる種類のフィルタを作成し、それらを動的にロードして実行します。

私が今やろうとしているのは、フィルター内で Hystrix を使用することです。私が見ているのは、すべてがうまくいっていれば、すべてうまくいくということです。しかし、run() メソッド内で例外が発生すると、Hystrix ではなく Zuul が例外をキャッチします。したがって、 getFallback() は呼び出されません。

コードGithubを共有しました。

Hystrix が Zuul の代わりに例外をキャッチする方法を知っている人はいますか?

プライベートにホストされる成長中のマイクロサービス アーキテクチャで使用する優れた検出サービスを探しています。

Netflix の Eurekaは有望に見えます。「主に AWS クラウドでサービスの検索に使用される」とありますが、AWS 以外で使用できるかどうかはわかりません。POM をざっと見てみると、プロジェクトに AWS の依存関係が含まれていることがわかりました。

Eureka (またはその有用なサブセット) を AWS の外部で検出サービスとして使用できますか?

レトロフィットの RxJava サポートを使用してオブザーバブルを連鎖させることに問題があります。私はおそらくそれを使用する方法を誤解しています, そうでなければ、それは改造のバグかもしれません. ここの誰かが何が起こっているのかを理解するのを手伝ってくれることを願っています。編集:私はこれらの応答に MockRestAdapter を使用しています - RxSupport の実装がわずかに異なるため、これは関連している可能性があります。

これは偽の銀行アプリです。送金を行おうとしています。送金が完了したら、アカウントの値を更新するためにアカウント リクエストを実行する必要があります。これは基本的に、flatMap を試してみる言い訳にすぎません。残念ながら、次のコードは機能しません。サブスクライバーに通知されることはありません。

ケース 1: 改造によって生成された 2 つのオブザーバブルを連鎖させる

転送サービス (注: レトロフィットで生成されたオブザーバブルを返します):

アカウント サービス (注: レトロフィットで生成されたオブザーバブルを返します):

改造によって生成された 2 つのオブザーバブルを連結します。

ケース 2: 独自のオブザーバブルを作成し、レトロフィットで生成されたものとチェーンする

「フラット マップ」呼び出しに対する Retrofit の組み込み Rx サポートを無視すると、完全に機能します。すべてのサブスクライバーに通知が届きます。下記参照：

新しいアカウント サービス (注: オブザーバブルは生成されません):

独自のオブザーバブルを作成し、アイテムを自分で発行します。

どんな助けでも大歓迎です！

そのため、サービスのスクリプトまたはプラグインを作成することにより、netflix で再生されているビデオを変更する方法があるかどうかを知りたいと思います。

例: 22 分間のショー。最初の 2 分間をスキップして、そこからビデオを続けたいとしましょう。つまり、これを行うには何らかの方法が必要です。

if(video.play) then video.play(timestamp)

または何かのような if(colorcode) then skip.frame();もの。

非常に具体的な方法でオブザーバブルを観察しているとしましょう。

filter と take のような 2 つの定義済み演算子を組み合わせたカスタム 演算子を作成したいと思います。次のように動作するように

また...

これまでのところ、これを実行できる非常に特殊な演算子を書くことに満足しています。そして、私はそのオペレーターを持ち上げることができます。

しかし、rx Java に関する現在の限られた知識を考えると、カスタム オペレータで使用する必要があるたびにテイクとフィルタの機能を書き直す必要があります。

これを行うことは問題ありませんが、オープン ソース コミュニティによって維持されている既存のオペレーターを再利用したり、作成したオペレーターをリサイクルしたりしたいと考えています。

また、オペレーターとサブスクライバーに関する十分な知識が不足していることもわかります。

rx-java のドキュメントではないチュートリアルを誰かが推薦できますか?
私がこれを言うのは、ドキュメントは一般的な概念を説明していますが、RX Java のより堅牢なアプリケーションを刺激する例を残さずに、その機能の概念と一般的なコンテキストを分離しているからです。

だから本質的に

カスタムデータフローを代表的な演算子にカプセル化しようとしています。この機能は存在しますか?

現在、Netflix のFlux Capacitorを調査して、マイクロサービス アーキテクチャの実装を研究しています。現時点では、サービス登録と動的ルックアップ機能に関心があります。

コード、サンプル、および構成をブラウズしますが、何かが明確ではありません。サービスのバージョン管理。eurekaが発見サービスを提供し、リボンが eureka ベースの REST クライアントである場合、クライアントはどのようにして service 1.2of serviceが必要だと言うのfooBarでしょうか? クライアントはそのバージョン番号をどこに保存/取得しますか。このようなローカル構成ファイルから、またはarchaiusを介して動的に取得されますか?

AutoHotKey を使用して、Netflix メトロが既に実行されていて最小化されているときに最大化しようとしています。今まで運がなかった。

これが私が試したスクリプトです：

AHK Window Spy は、Netflix メトロ アプリについて次のように述べています。