私は Vertx にはかなり慣れていませんが、Spring との統合をテストすることに非常に興味があります。Spring Boot を使用してプロジェクトを後押しし、2 つのバーティクルをデプロイしました。イベントバスを使って通信したいのですが、うまくいきません。これは私がしたことです：

1. メインアプリケーションで:

   @SpringBootApplication public class MySpringVertxApplication { @Autowired MyRestAPIServer myRestAPIServer; @Autowired MyRestAPIVerticle MyRestAPIVerticle;

   }

2. APIVerticle では:

   @Component public class MyRestAPIVerticle extends AbstractVerticle {

   }

3. 最後に ServerVerticle:

   @Service public class MyRestAPIServer extends AbstractVerticle {

   }

しかし、起動して /page1 にアクセスすると、ServerVerticle から APIVerticle にメッセージをまったく送信できません。イベント バス コンシューマーを Sender と同じ垂直に移動すると、イベントを受信できます。

2 つのバーティクル間でメッセージを送信する際に何か問題がありますか? どうすればそれを機能させることができますか？

前もって感謝します。

i would like deploy inside my Java VertX a javascript Verticle. Of course, this is not a problem. The question is, how can i give them a callback ?

My Java Code:

My server.js:

Of course, my server.js is bigger and this need's some time for starting. In my clustered Vertx i get during the start some messages that something blocks my bus.

How can i fix this ?

Thanks Marcel

mongoDB に保存するファイルがあります。私が望むのは、ファイル全体 (サイズが数 MB になる可能性があります) をロードするのを避けることです。代わりに、ストリームを開いて mongoDB に転送し、書き込み操作のパフォーマンスを維持したいと考えています。コンテンツを base64 でエンコードされたバイト [] に保存してもかまいません。

その後、ファイルの読み取り時に同じことをしたい、つまり、ファイル全体をメモリにロードするのではなく、ストリームで読み取ります。

現在、Vertx サーバーで hibernate-ogm を使用していますが、原因を効率的に処理する場合は、別の API に切り替えることができます。

複数のフィールドと複数の添付ファイルを含むドキュメントを実際に保存したいと考えています。

Vertx 3.2.1 での Spring Boot の展開

vertx フレームワークで Spring Boot を使用して開発されたサービスをデプロイしようとしています。

サービスは Spring Boot で開発され、Gradle を使用してデプロイされます。以下は私の開発環境です。a) Java バージョン - 1.8 b) Spring ブート バージョン - 1.2.8.RELEASE c) Gradle バージョン - 2.0 d) Vertx バージョン - 3.2.1。

vertx アプリケーションは、コマンドvertx run samplevertx.java -cp sampleFAT.jarを使用して起動されます。vertx アプリケーションを起動すると、次の例外がスローされます

他のメンバーによって投稿された次の解決策を試しましたが、うまくいきませんでした。

解決策 1、 解決策 2、 解決策 3、 解決策 4。

必要な注釈と依存関係を build.gradle ファイルに追加しましたが、問題は解決しません。

フォーラムの誰かがこの問題を解決するのを手伝ってくれますか?

Java vertx で作成された 2 つのマイクロサービスがあります。それらはイベントバスを介して通信します。1 つ目はメッセージを送信し、2 つ目はメッセージを受信します。

最初のアイデア: 単体テストで Vertx イベントバス メッセージにのみ応答します。

メッセージがエラーなしで処理されていることをテストしたいので、返信をチェックする 2 番目のマイクロサービスに単体テストを記述します

コンシューマーで返信を送信する必要がありますが、テストでのみ実行したいので、本番環境で返信を送信する必要はありません。本番環境で返信を送信するために CPU とネットワークを消費したくありません。だから私が探しているのは次のようなものです：

2番目のアイデアはcdelmasのコメントの後に来て、私自身の答えにあります

メッセージを消費して保存し、成功または失敗を返信するユースケースがあります。mongo 挿入は Observable を返すので、flatmap を使用して連鎖できます。問題は、挿入オブザーバブルが挿入の結果を発行することですが、返信するには最初のオブザーバブルから発行された元のメッセージが必要です。したがって、これを機能させるために、最初の Observable のサブスクライブ内で挿入を実行し、2 番目のサブスクライブ内で応答しています。

flatmap のようなある種の演算子を使用して、より反応的な方法でこれを達成したいと考えていました。演算子のリストを検索しましたが、探しているものが何も見つかりません。

上記のコードはそれを行うべき方法ですか、それともより良いアプローチがありますか? 2 つのサブスクライブは適切ではありません。

メイン メソッドから Verx 3 Verticle を開始するにはどうすればよいですか? 単体テストから開始する方法を理解しました。入門ガイドでは、ファット jar の作成方法が説明されています。しかし、デバッグやプロファイリングなどの目的で、メイン メソッドから単純に開始するにはどうすればよいでしょうか。

いくつかのテキスト フィールドといくつかのアップロード ファイルを含むマルチパート フォームがあります。このマルチパート ポスト リクエストを vertx ハンドラで処理して、アップロードされたすべてのファイル (可変数) をチャンクで読み取る必要があります (メモリ効率を高めるため)。チャンクを (foreach ループで) 読み取った瞬間に、それをファイルに直接ストリーミングしたいと考えています。テキスト フィールドを含むマルチパートの場合、単純に値をモデル オブジェクトに格納したいと考えています。

私は vertx を初めて使用するため、これを実現するためのコード スニペットを探していますが、vertx ドキュメントのどこにも見つかりませんでした。