問題タブ [spring-cloud-bus]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Spring Cloud Bus - クライアントが変更を受け取らない
私は、RabbitMQ を使用した Spring Cloud Bus の実装に関して行き詰まっていると思います。
これは、 Spring Boot 2.0.0.M7 および Spring Cloud Finchley.M5を介して行われることに注意してください。これらは、リリース ノートに従って互換性があるはずです。
私はこれを機能させようとしています:
- 構成サーバーの Git リポジトリで .yml ファイルを編集する
- ConfigServer は GitHub の webhook 経由で通知を受信する必要があります (ngrok 経由で公開された localhost アドレス)
/actuator/bus-refresh
構成サーバーに接続されているクライアントは、 POST 呼び出しを介して更新要求を受け取る必要があります。
ただし、サーバーのログでこれを確認できます。
(空の配列が原因ですか?その場合、何をすべきか本当にわかりません:()
そして、クライアント側には何もありません (手動でバス リフレッシュ エンドポイントに POST 要求を送信しない限り)...その場合、ログの出力は次のようになります。
RabbitMQ (Docker コンテナーとして実行される) のグラフを見ると、クライアント、Zuul (リバース プロキシ)、および構成サーバーの 3 つのアプリケーションが接続されていることがわかります。
これで私を助けてもらえますか?どうもありがとうございました。以下は、アプリケーションの構成です。
構成サーバー POM.xml:
構成サーバー application.yml:
クライアントのPOM.xml:
クライアントの bootstrap.yml:
java - amqpクライアントからrabbitmqサーバーへのJava 8 SSLハンドシェイクの失敗
前の投稿の文脈を読んでください。その問題は解決されました。 キューを再作成し、rabbitMQ に再接続する
現在、rabbitmq サーバーと rabbit クライアントの間に ssl 対応の接続をセットアップしようとしています。スプリング クラウド バスでスプリング ブートを使用しています。SSL がなければ完璧に動作します。
- これを使用して、Java ウサギ クライアントを実行しました。
> バージョン
Java 1.8
spring-cloud-starter-bus-amqp => 1.3.1.RELEASE
スプリング ブートの親 => 1.5.9.RELEASE
sudo java -Djavax.net.debug=all -Dhttps.protocols=TLSv1 -jar target/rabbit-client-0.0.1-SNAPSHOT.jar
-Dhttps.cipherSuites=TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 も試しました
- 以下のコマンドを使用しましたが、検証済み [ok] の結果で動作します。これは、rabbitmq サーバーが証明書を使用して正しく構成されていることを示しています。
- chromeブラウザからrabbitmq管理ネットポータルにアクセスできますが、キーチェーンで信頼できる証明書を追加したため、証明書を信頼しています。
- 証明書と CA 証明書を Java キー ストアに追加し、信頼しました。
- Amqp クライアントは接続を確立できず、SSL が有効になっていると失敗します。
これが問題になる可能性があると私は信じていますが、確かではありません。
TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384 TLSv1.1 がサポートされていない暗号のリストに表示されており、rabbitmq サーバーが暗号化スイートとしてそれを要求している可能性があります。
java - spring-cloud-bus の ZooKeeper ホストとポートを設定する
spring-cloud-starter-bus-kafka を使用したプロジェクトがあり、内部に kafka URL を次のapplication.yml
ように設定します。
これは、kafka と Zookeeper がローカルにデプロイされている場合に機能しますが、kafka と Zookeeper を独自のサーバーに移動すると、spring-boot の開始時にエラーが発生します。
新しい設定
エラー
サーバーに接続するには、kafka と Zookeeper をどのように設定すればよいですか?