資訊專欄INFORMATION COLUMN
摘要：但經過一段使用后，發現的一些問題。這樣產生了一系列問題。部署的是異步的多線程環境，這個方法必須是線程安全的。小結的體系結構無疑是非常先進的，多線程異步結構，內置，支持，支持高可用度，這些都不是輕易能夠提供的。
最近想選高效，簡潔，擴充性強的web框做為移動平臺后臺，在對一系列框架對比后，選擇了vertx。但經過一段使用后，發現vertx的一些問題。
1.vertx使用共享資源產生的重復代碼
在vertx中，verticle是最基本的結構，簡單的說類似j2ee servlet,但是verticle更加靈活，不僅可以是服務，也可是客戶端，verticle之間通過eventbus通訊，實際上更類似akka的actor，vertx實現了類似nodejs express風格的web框架，但是java是多線程的，通常java的面向的目標環境更復雜。這樣產生了一系列問題。
如jdbc連接池，在創建的時候必須在 verticle的start 中引入類似的語句
JDBCClient client = JDBCClient.createShared(vertx, new JsonObject().clear()
.put("provider_class", "io.vertx.ext.jdbc.spi.impl.HikariCPDataSourceProvider")
.put("jdbcUrl", "jdbc:postgresql://127.0.0.1:5432/mydb")
.put("username", "postgres")
.put("password","password")
.put("driverClassName", "org.postgresql.Driver")
.put("maximumPoolSize", 30),"mypool");
如果有另外一個verticle 需要使用連接池 mypool，也必須在start方法中加入這樣一段。verticle 部署的是異步的多線程環境，這個createShared方法必須是線程安全的。如果有很多程序需要使用這個連接池 mypool，就會產生大量的冗余代碼，這段代碼必須是線程安全的。一個可行的方案是創建一個configuration verticle，這個verticle初始化所有的共享資源。然后通過這個verticle的靜態方法訪問系統的所有的共享資源。這樣會減少大量的冗余代碼，作為單例類，也不必是線程安全的。
需要注意是 當使用 vertx.deployVerticle 部署verticle （vertx是可以理解為一個verticle的環境），不能保證verticle的運行順序，部署是異步的。為了保證configuration verticle的在其他verticle之前運行，必須使部署過程同步。同步方法并不復雜，可以用future實現。
try {
log.info("deploy " + verticleID);
CompletableFuture future = new CompletableFuture();
vertx.deployVerticle(verticleID, deploymentOptions, res -> {
if (res.succeeded()) {
log.info("Deployment id is: " + res.result());
future.complete(1);
} else {
log.error("Deployment failed!");
future.complete(0);
}});
int result = future.get();
} catch (Throwable t) {
log.error("error", t);
}
2.異步jdbc
異步jdbc確實能夠提高效率，vertx提供了基于sql 語句的異步api，下面是從vertx jdbc example 摘下來的一個例子。
// create a test table
execute(conn.result(), "create table test(id int primary key, name varchar(255))", create -> {
// start a transaction
startTx(conn.result(), beginTrans -> {
// insert some test data
execute(conn.result(), "insert into test values(1, "Hello")", insert -> {
// commit data
endTx(conn.result(), commitTrans -> {
// query some data
query(conn.result(), "select count(*) from test", rs -> {
for (JsonArray line : rs.getResults()) {
System.out.println(line.encode());
}
// and close the connection
conn.result().close(done -> {
if (done.failed()) {
throw new RuntimeException(done.cause());
}
});
});
});
});
});
});
});
}
這是一個非常簡單的事務，都需要寫成這樣，無法想象一個復雜事務的處理程序會變成什么樣子。其實jdbc driver api依然是同步的，不過vertx提供了一個異步封裝。語句級別異步api過細，如果程序員能夠自己控制異步的粒度，將會改善這種情況。我的方案是提供jdbc同步api，然后程序員可以異步封裝一個過程。這在vertx很容易實現。
executor.executeBlocking((Futuref) -> { try { jdbc_routine(); } f.complete(); } catch (SQLException e) { f.fail(e); } }, handler);
小結 vertx的體系結構無疑是非常先進的，多線程異步結構，內置metrics，支持cluster，支持高可用度，這些都不是nodejs輕易能夠提供的。 但是目前使用起來確實有諸多不變，需要一點hack。
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/64824.html
摘要：今天分享的是里的共享問題。主要考慮到清除的時候使用，因為數據主要以保存在為主，本地保存是輔助作用。 現在越來越流行微服務架構了，提到微服務架構的話，大家能想到的是spring boot和vertx吧！前者大家聽的比交多些，但是今天我給大家分享的是后者vertx。想要了解更多請閱讀vertx官網http://vertx.io/docs/vertx-we... 廢話不多說了，直接進主題...
摘要：本文章是藍圖系列的第二篇教程。這就是請求回應模式。好多屬性我們一個一個地解釋一個序列，作為的地址任務的編號任務的類型任務攜帶的數據，以類型表示任務優先級，以枚舉類型表示。默認優先級為正常任務的延遲時間，默認是任務狀態，以枚舉類型表示。 本文章是 Vert.x 藍圖系列 的第二篇教程。全系列： Vert.x Blueprint 系列教程(一) | 待辦事項服務開發教程 Vert.x B...
摘要：定時器例子之前通過調用定時器，需要傳一個回調，然后所有的代碼邏輯都包在里面。這里定時器會阻塞在這一行，直到一秒后才會執行下面的一行。 之前介紹過quasar，如果你希望在vert.x項目里使用coroutine的話，建議使用vertx-sync。本篇將介紹vertx-sync。 showImg(/img/bVzIsu); 本來打算另起一篇，寫其他方面的東西，但是最近比較忙，就先寫一篇實...
摘要：而不是開始，將服務使用多線程的請求重量級的容器。是啟動多個輕便單線程的服務器和流量路由到他們。亮點應用程序是事件驅動，異步和單線程的。通過使用事件總線傳遞消息通信。為了建立一個消息系統，則需要獲得該事件總線。 摘要 如果你對Node.js感興趣，Vert.x可能是你的下一個大事件：一個建立在JVM上一個類似的架構企業制度。 這一部分介紹Vert.x是通過兩個動手的例子（基于Vert.x...
閱讀 3094·2021-11-24 10:47
閱讀 3848·2021-11-02 14:43
閱讀 2242·2021-09-26 10:15
閱讀 2295·2021-09-08 09:35
閱讀 580·2019-08-30 12:45
閱讀 2785·2019-08-29 17:04
閱讀 3219·2019-08-26 14:05
閱讀 1266·2019-08-26 12:10
