問題タブ [hystrix]

私は次のようなことをしようとしています:

もう少し背景として、私はSpring Bootを使用しており、 RestTemplateEHCacheを使用するように設定しています:

だから私の考えは同じリクエストEHCacheを使用することでしたが、キャッシュがキャッシュ制御ヘッダーに基づいていることを考えると、それが適切な解決策であるかどうかはわかりません。有効期限が切れているかどうか。

もう 1 つの考えは、別の EHCache キャッシュを構成し、応答を自分で保存することでした。そうすれば、キーと値の形式を設定することで、より簡単にアクセスできるようになります。

この道をたどる前に、Hystrix にこの状況を処理するものが既に組み込まれているかどうか、または他に推奨されるアプローチがあるかどうかを確認したいと思います。

Eureka を介して実行中のサービスを検出できるタービンの実装があります。

Hystrix は、クライアント アプリ ポリシー サービスで実行されています。そのストリームを表示して、hystrix ダッシュボードで確認できます。

問題は、Turbine ストリームを表示すると、次のようになることです。

URI を使用して Hystrix ダッシュボードで表示すると、http://localhost:8095/turbine.stream?cluster=DEV「読み込み中...」と表示されます。

この投稿に記載されているすべてのことを試しましたが、役に立ちませんでした。

これが私のタービン サービスの application.yml です。

clusterConfig と clusterNameExpression なしでこれを試しました。

ここに私のbootstrap.ymlがあります：

そして、ここに私の情報源があります：

ブラウザでタービン ストリームにアクセスすると、ログに次のように表示されます。

タービン ストリームがポリシー サービスに接続されていて、hystrix ストリームが正常に動作しているのに、タービン ストリームに何も表示されないのはなぜですか?

この例を使用してサンプル アプリケーションを構成しています: http://projects.spring.io/spring-cloud/spring-cloud.html#spring-cloud-feign-inheritance。このセクションhttp://projects.spring.io/spring-cloud/spring-cloud.html#spring-cloud-ribbonでは、次のように述べられています。

Feign はすでにリボンを使用しているため、@FeignClient を使用している場合は、このセクションも適用されます。

@FeignClient も Hystrix を使用しているということですか? クライアントを偽装する呼び出しは、hystrix コマンド内で実行されますか? もしそうなら、hystrix 構成を渡す適切な方法は何ですか?

@HystrixCommand を使用して偽装クライアントへの呼び出しをラップするサンプルがあります。正しい方法ですか？

Spring Cloud と @EnableZuulProxy を使用しています /hystrix.stream 経由で hystrix を使用して、application.yml で構成されたすべてのルートを監視することは可能ですか? 以下の例では、下流の製品サービスに対するすべてのリクエストを簡単に監視したいと考えています。製品サービス自体でこれを行うことができることは理解していますが、Zuul リクエストを監視することは可能ですか。これは、所有されておらず (サード パーティ)、@HystrixCommand で注釈を付けることができないダウン ストリーム サービスに役立ちます。

zuul: routes: item: serviceId: product path: /product/**

自分で実装しなくても、X回連続して失敗した後にサーキットブレーカーをトリップするように構成する方法はありますか?

特定の時間内の失敗の割合について見つけることができたのはすべてです。

Turbine と Hystrix のセットアップが機能していましたが、複数のサービスを 1 つのストリーム/ダッシュボードに集約できるように、それを Turbine AMQP に変更することにしました。

localhost:8989 で実行する Turbine AMQP サーバーをセットアップしましたが、クライアント サービスから Hystrix データを取得していないようです。ブラウザで Turbine サーバーの IP にdata: {"type":"Ping"}アクセスすると、Hystrix の URL をポーリングしているときでも、繰り返し表示されます。Hystrix ダッシュボードでタービン AMQP ストリームを表示しようとすると、次のようになります。Unable to connect to Command Metric Stream.

ポート 5672 で実行される RabbitMQ のデフォルト インストールがあります。

Hystrix-AMQP を使用するクライアント サービスには、次のような application.yml ファイルがあります。

起動ログの末尾は次のようになります。

したがって、PolicyService はメッセージ ブローカーに正常に接続されているようです。

Turbine AMQP サーバーのログの終わり:

Turbine AMQP サーバーが Hystrix AMQP クライアントから通信を受信して​​いない理由はありますか?

編集: Turbine-AMQP メインは次のようになります。

その application.yml は次のとおりです。

ヒットhttp://localhost:8989/turbine.streamすると、次の繰り返しストリームが生成されますdata: {"type":"Ping"}

これをコンソールに表示します：

編集:以下の例外は、ダッシュボードでリッスンしようとしたときではなく、タービン ストリームのリッスンを停止したときにスローされます。

私のタービン-amqp の依存関係は次のとおりです。

私が見た Hystrix の使用法 (つまり、Spring クラウドで) は、AMPQ ブローカーを使用していますか?
RAbbitMQ なしで Netflix Hystrix を使用できますか? つまりJMSで？

Spring Boot アプリケーション内でアノテーションHystrixCommandを使用するときに失敗した理由を取得する方法はありますか? 独自の を実装すると にアクセスできる@HystrixCommandように見えますが、アノテーションを使用する場合、どうすればこれにアクセスできますか? 発生した例外の種類に基づいて、フォールバック メソッドでさまざまなことを実行できるようにしたいと考えています。これは可能ですか？HystrixCommandgetFailedExecutionException

に関するメモを見ましたHystrixRequestContext.initializeContext()が、HystrixRequestContext何もアクセスできません。そのコンテキストを使用して例外にアクセスする別の方法はありますか?