問題タブ [turbine]

spring-cloud-turbine を使用したとき、タービンを構成しました

clusterNameExpressionの意味がわからない

turbineサーバーを起動したときのログは

異なるポートで2つの同じサービスを開始しましたが、turbineモニターはデフォルトのものしか処理しません。

すべてのサービスを処理するようにタービンを構成するにはどうすればよいですか? .

私は中国人です、私の英語が下手でごめんなさい

Spring Cloud と Netflix OSS のオファリング スイートに基づいて、デモ アプリケーションをセットアップしました。すべてのモジュールを実行すると、アプリはローカルの開発環境だけでなく、Pivo​​tal Web サービスでも完全に実行されます。

私が直面している問題は、モジュールを docker で実行するように構成しているときです。Hystrix/Turbine 用の RabbitMQ に依存するアプリを起動すると、AMQP 接続例外が発生します。

次の構成でdockerでrabbitmqを開始しました：

ブラウザで問題なく管理ポートにアクセスできます。

docker で依存プロジェクトの 1 つを起動するときに、rabbitmq を docker link 引数で指定します。

ここに何が欠けているのか分かりますか?

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

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

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

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

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

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

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

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

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

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

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

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 の依存関係は次のとおりです。

サービスの検出にconsulを使用しています。すべてのサーキット ブレーカー ストリームをタービンに集約します。

Turbine は発見部分に Eureka を必要としますか、それとも consul と同様に機能しますか?

次のエラーが表示されます。

ありがとう

Spring Cloud Netflix のガイドに従ってTurbine を構成しました。2 つのマイクロサービスで Hystrix を有効にした後、/hystrix.stream エンドポイントが正しい出力を生成することを確認しました。

hystrix ダッシュボード プロジェクトで、すべてのサービスの集計結果を取得するように Turbine を構成しました。しかし、私が得るのは次の連続です：

これは私の設定です:

HystrixDashboard + タービン アプリケーション:

HystrixDashboard + タービン application.yml:

アップデート

kreel の指示に従って、Turbine を次のように構成しました。

例外で失敗することはもうありません。ログを見ると、Turbine が 2 つの候補ホスト/マイクロサービスを見つけていることがわかります。

ただし、最終的に登録されるのはそのうちの 1 つだけです。ホストの 1 つだけが追加されます。これInstanceObservable.run()は、ハッシュコードが同じであるため、newState.hostsUp に追加されたときに同じと見なされるためです。com.netflix.turbine.discovery.Instanceハッシュコードは、ホスト名 (どちらの場合も「myhost」) とクラスター (「デフォルト」) に基づいて計算されます。

同じホストが 2 つの異なるマイクロサービスを提供している場合、どうすればよいでしょうか? この場合、最初のインスタンスのみが登録されます。

Turbine アプリケーションをセットアップしましたが、ローカルで実行するとすべて正常に動作します。

アプリケーションは Cloud Foundry で起動しますが、Hystrix ダッシュボードは :8989/turbine.stream に接続できないようです。

コマンド メトリック ストリームに接続できません。

Cloud Foundry では、/turbine.stream のサービスを公開する必要がありますか?

アプリはすべてrabbitmqに接続されています。

Turbine アプリケーションは yml で構成されます。

アプリはこちら