vert.x

1熱度

1回答

我試圖用Vert.x做非常簡單的SSH客戶端。由於我沒有非阻塞的SSH庫，所以我必須處理rxExecuteBlocking中的所有內容。它的工作的偉大，當我運行的所有邏輯代碼的一個大塊如下： public Single<String> exec() { return vertx.rxExecuteBlocking(f -> { String result = "";

0熱度

2回答

爲什麼Vert.x調用響應，即使它是單線程的

我從Vert.x文檔（及其中的一點編碼）中瞭解到Vert.x是單線程並執行中的事件活動池。它不等待I/O或任何網絡操作，而不是等待另一個事件（這在以前的任何Java多線程框架中都沒有）。但我不明白以下幾點：如何單線程是優於多線程？如果有數以百萬計的傳入HTTP請求會怎麼樣？它不會比其他多線程框架慢嗎？ Verticles依賴於CPU核心。儘可能多的CPU核心，可以有許多垂直並行運行的垂直。在虛

0熱度

1回答

Vert.x文件根與Handlebars模板位置

我在嘗試使用Vertex的HandleBars模板引擎的模板時不斷掙扎着NoSuchFileException。我個人認爲醚Vertx文件系統的根目錄不一致，或者我失去了一些東西，代碼片段如下： String templateLocation = "templates"+File.separator+"index.hbs"; fs = vertx.fileSystem();

3熱度

3回答

使用vertx讀取大文件

我是使用vertx的新手，我使用vertx文件系統api來讀取大尺寸的文件。 vertx.fileSystem().readFile("target/classes/readme.txt", result -> { if (result.succeeded()) { System.out.println(result.result()); } else {

0熱度

1回答

Vertx合併單個文件中多個文件的內容

將多個文件的內容追加到vertx中的單個文件中的最佳方法是什麼？我已經嘗試vertx 文件系統和asyncFile但都沒有選擇追加文件或我不知道任何。是否有任何其他方法異步合併或追加vertx文件。我能找到的唯一解決方案是使用循環將緩衝區列表寫入每個先前緩衝區長度的末尾。

0熱度

1回答

Mongo GridFS支持Vert.x 3.2.0

我試圖在Mongo DB GridFS中存儲二進制內容。我想知道在Vert.x 3.2.0中是否支持Mongo DB GridFS 我最近沒有看到這方面的官方說明。請爲我提供指南另外我打算爲我的微服務使用Vert.x或Spring啓動（它已經支持GridFSOperations的彈簧數據） - 想知道從長遠的角度來看我應該選擇哪一個GridFS支持有關嗎？

0熱度

1回答

Vert.x與Rx-Java實現服務調用的緩存

說，SomeOtherService在一個Veritcle在不同Verticle中使用UserService，通信發生在Event Bus上。在另一臺機器上的另一verticle /微服務 class SomeOtherService { final UserService userService = new UserService(); // Mutable state

0熱度

1回答

使用vertit TestSuite和junit

我一直在使用vertx junit integration example，但我不明白如何從junit @test方法或junit @ Suite.SuiteClasses運行TestSuite？ @RunWith(VertxUnitRunner.class) public class RunOnContextJUnitTestSuite { @Rule public Ru

0熱度

2回答

選擇Verticle名稱以從Maven shell開始

我有一個基於Maven的Vert-x應用程序，它包含一個Java Verticle。目前，我開始與應用： java -jar jarfile.jar 現在我需要另一個Verticle添加到項目中。如何選擇以Maven開頭的Verticle？謝謝

0熱度

1回答

如何配置log4j2以使用WARN級別記錄`MyException`錯誤

如何配置log4j（v 2）以記錄具有WARN級別的MyException錯誤？見代碼（rxjava）的例子，拋出異常MyException return map.get(id).toObservable() .filter(Objects::nonNull) .switchIfEmpty(Observable.error(new MyException("Hap