vert.x

1熱度

2回答

單元測試Vertx - java.util.concurrent.TimeoutException

我想單元測試一個來自vertx WebClient的http調用VertxUnitRunner和RXified版本的vertx。問題是我的單元測試總是失敗，出現超時異常。有沒有不同的方式單元測試WebClient http調用？下面是我的代碼： import io.vertx.core.AsyncResult; import io.vertx.core.http.HttpClientOptio

0熱度

2回答

Vert.x處理程序檢查檢查存在的最佳做法是什麼？

我正在實施一種方法，使用Vertx檢查數據庫中是否存在某個值，並使用Handler和AsyncResult。我想知道哪一個是最好的做法：選項1：如果沒有發現，處理程序與succeededFuture但結果爲FALSE： public void checkExistence (..., String itemToFind, Handler<AsyncResult<Boolean>> result

1熱度

2回答

單元測試垂直部署

我有一個簡單的Verticle從配置文件中讀取配置並加載到vertx配置中。我已經寫了一個單元測試來測試這個Verticle的部署，並且測試失敗的可能原因是該位置的屬性文件不可用。當我運行測試時，單元測試通過，無論是否更改屬性文件名或路徑，處理程序說Verticle已成功部署。我在這裏做錯了什麼？下面是我的代碼 import io.vertx.config.ConfigRetrieverOpt

0熱度

1回答

確保登錄只在頂點完成一次

假設我有5個任務需要處理。如果沒有登錄完成，第一項任務是負責進行登錄。如果登錄已完成，則後面的任務應該重新使用登錄。我有3個verticles： V1是用於執行上述邏輯。 V2是與數據庫檢查如果登錄沒有完成 V3負責通過Web服務由於3個verticles是異步的，而T1是由V2檢查，T2到達做登錄由V1處理（因爲V1現在是免費的）。我最終得到T1和T2登錄到Web服務。有沒有辦法在T1正

1熱度

1回答

可觀察鏈模具上和IntelliJ時滯/凍結

我有這個簡單的可觀測被稱爲： Map<Integer, List<Long>> localLookup = new HashMap<>(); return Observable.from(userList) .filter(lookupId -> userLookup.containsKey(lookupId)) .map(lookupId -> {

0熱度

1回答

kapt插件不能用gradle-script-kotlin

我想將基於vertx的項目移動到https://github.com/sczyh30/vertx-blueprint-microservice.git模板。藍圖項目使用註釋@vertxGen等在編譯期間生成代碼。我正在使用gradle-script-kotlin來構建項目。我需要使用kapt插件根據註釋生成代碼（通過vertx ... codegen）。不幸的是，我無法正確配置kapt插件。它給

0熱度

1回答

異步性在Vertx，它被設置

之前在我MainVerticle我設置路由器 router.get("/persons").handler(ctx -> apiService.getPersons(ctx, client)); 我要調用兩次相同的主機列表返回空，首先我需要的人ID的列表，然後調用同一個主機的另一種方法來獲取人員詳細信息。。所以，在這段代碼中，我正在另一個接聽電話。由於異步性，personList是空的，因爲

0熱度

1回答

爲連接到Redis的大量Vertx引發的異常

嘗試使用Redis模擬重負載情況（僅限默認配置）。爲了簡單起見，當立即執行multi時，關閉連接。 import io.vertx.core.*; import io.vertx.core.json.Json; import io.vertx.redis.RedisClient; import io.vertx.redis.RedisOptions; im

-1熱度

2回答

生成招搖的API與現有vert.x項目

我有一個現有的vert.x項目，它變得太重量級和不透明。* 來取代它，我檢查的幾個選項，它們是招搖的一個。有誰知道一個開源的lib目錄中，可以創建一個vert.x招搖的API？

0熱度

1回答

如何在Vert.x中有效地編程組合協調

我在想什麼是在Vert.x中異步運行以下一組調用的最佳方法。 C1: [v1, v2] +--> C2(v1): x --> C2.1(x): xx --| |--> C3(v2): y --> C3.1(y): yy --+- C4(xx, yy) 至於符號C1: [v1, v2]意味着呼叫C1返回值[v1, v2]的陣列。我在想什麼，此刻是： Future c1 = Fut