vert.x

0熱

1答えて

私はverticleをテストしようとしていますが、MongoDBを使っています（単体テストの過程で実際のDBアクションを実行しないようにしています）、私はクライアントをモックしようとしましたが、私はvertx.deployVerticle()を使用しています。私のモックは考慮されていません。私はそれを嘲笑しましたけれども @RunWith(VertxUnitRunner.class) @Prep

-2熱

1答えて

vert.xとJOOQを統合する方法（自動生成DAOとPOJOと接続プーリングを使用）

私が知っているように、vert.xはイベントベースです。そこで私はJOOQの自動生成されたDAOを作業者の頂点から使用するつもりです。

2熱

1答えて

execを実行するときにSPI実装を登録するには：

exec:java Mavenプラグインで実行しているときにVertX Mertricsを動作させようとしています。私はfatjarにアプリケーションをパッケージ化して、私はmvn clean package exec:java -DskipTestsでそれを実行すると、私は見java -jar fat.jar -conf config.json -Dvertx.metrics.options.

0熱

2答えて

WebSocketのスループットを向上させる方法

Webソケット経由でJavaサーバーに接続する多くのクライアントからデータを取得する必要があります。 Webソケットの実装がたくさんあり、私はvert.xを選択しました。私は、JSONのフレームをテキスト・ジャクソンとそれらを解析し、バック応答を送信するために聞く簡単なデモを行いました。 Jsonパーサはスループットに大きく影響しません。 2人または10人のクライアントで全体の速度が毎秒2.5k

1熱

2答えて

応答を送信せずに非同期vertxイベントバスハンドラをテストする方法

私はjavaのvertxで書かれた2つのマイクロサービスを持っています。イベントバス経由で通信します。最初にメッセージを送信し、2番目にメッセージを受信します。最初のアイデア：ユニットテストでは、Vertxイベントバスメッセージに返信します。私はそのメッセージをテストしたいはエラーなしに処理されているので、私は返事 eventbus.send("address", message, repl

0熱

1答えて

Eclipseはvertexのioを読むことができません

今日私はjava、vert.xで何か新しいことを始めたいWebサイトから基本情報を持っていますが、私が学んだことを適用したいときはインポートの例外の背後にある自分自身が解決できませんimport io.vertx.core.AbstractVerticle、参照されたライブラリに既にvertx core jarがあり、そのクラスが存在するかどうかを確認しました。なんて思っていますか？ありがと

1熱

1答えて

Vert.xでの将来の仕組みは？

私はEventBusを使用してメッセージを送信しています。返信メッセージを変数に取り込み、それを返します。これがコードブロックです。ブロック決してexit.Itsはfuture.resultを（平均しながら public class MessageExecute { private static final Logger logger = LoggerFactory.getLogger(Mes

2熱

1答えて

観測可能/送信/通過元の発信を購読するには

私はメッセージを消費し、保存してから、成功または失敗を返すユースケースを持っています。 mongoインサートはObservableを返すので、私はフラットマップを使ってチェーンすることができます。問題はinsert Observableが挿入の結果を出力することですが、最初のobservableから元のMessage emitを返す必要があります。したがって、この作業を行うために、最初のObser

0熱

2答えて

並列に要求を処理するVertxサーバを作る方法は？

並列に要求を処理するVertxサーバを作る方法は？ HTTPリクエストをVertxサーバーに送信しているユーザーが50人いるとしたら、すべてのユーザー要求を同時に処理する必要がありますか？ VERTX 2マニュアルの文脈でお願い

5熱

2答えて

RxJava Vert.xで連鎖HTTPリクエストを終了するには？

Rx Vert.Xでチェーンされた要求を終了する方法は？ HttpClient client = Vertx.vertx().createHttpClient(); HttpClientRequest request = client.request(HttpMethod.POST, "someURL") .putHeader("content-type