Eclipse Vert.x 是一个微服务开发框架,基于事件和异步,依托于全异步 Java 服务器 Netty,并扩展了很多其他特性,以其轻量、高性能、支持多语言开发而备受开发者青睐。
Eclipse Vert.x 4.5.0 现已发布,此版本带来了一些新功能,包括虚拟线程支持。亮点更新如下:
虚拟线程
虚拟线程 verticle 可以等待 Vert.x futures 并同步获取结果。
Verticle verticle = new AbstractVerticle() {
@Override
public void start() {
HttpClient client = vertx.createHttpClient();
HttpClientRequest req = Future.await(client.request(
HttpMethod.GET,
8080,
"localhost",
"/"));
HttpClientResponse resp = Future.await(req.send());
int status = resp.statusCode();
Buffer body = Future.await(resp.body());
}
};
// Run the verticle a on virtual thread
vertx.deployVerticle(verticle, new DeploymentOptions().setThreadingModel(ThreadingModel.VIRTUAL_THREAD));
Vert.x 虚拟线程可以使用await
来 block 任何 Vert.x future :
// create a test table
await(pool.query("create table test(id int primary key, name varchar(255))").execute());
// insert some test data
await(pool.query("insert into test values (1, 'Hello'), (2, 'World')").execute());
// query some data
RowSet<Row> rows = await(pool.query("select * from test").execute());
for (Row row : rows) {
System.out.println("row = " + row.toJson());
}
可以在 example repo 查看更多信息。
动态 SQL 连接创建
默认情况下,连接池始终连接到同一主机,换句话说,数据库配置是静态的。有时数据库配置需要是动态的,例如连接到数据库阵列,或者数据库配置可能会改变。
通过动态连接配置,你可以在 Vert.x 中轻松实现这一点:
Pool pool = PgBuilder.pool()
.with(poolOptions)
.connectingTo(() -> {
Future<SqlConnectOptions> connectOptions = retrieveOptions();
return connectOptions;
})
.using(vertx)
.build();
每次 pool 需要创建连接时,都会调用 options supplier 并使用返回的选项来创建连接。
PG bouncer transaction pooling mode
7 级代理可以在与实际数据库的多个连接上平衡查询负载。当发生这种情况时,客户端可能会因缺乏 session affinity 而感到 confused,并且可能会出现不必要的错误,例如 ERROR: unnamed preded statements does not exit (26000)。
Vert.x SQL 客户端现在支持 7 级代理,例如 PgBouncer 。
TCP SSL 选项更新
现在可以在运行时更新 TCP client/server SSL 选项 ,这对于证书轮换非常有用。
Future<Boolean> fut = server.updateSSLOptions(
new SSLOptions()
.setKeyCertOptions(new JksOptions()
.setPath("/path/to/your/server-keystore.jks")
.setPassword("password-of-your-keystore")));
新连接将使用更新的配置。
WebSocket client
在新的 WebSocket client 中从 Vert.x HTTP client 捕获了 WebSocket client API 。
WebSocketClient wsClient = vertx.createWebSocketClient();
Future<WebSocket> f = wsClient.connect(connectOptions);
这一改动的目的是让HttpClient
接口专注于 HTTP 交互,并清理接口。
Client builders
在 4.5 中开始引入用于高级客户端创建的 builder pattern。
当 Vert.x 客户端需要进行超出选项的配置时,builder pattern 有助于配置和创建 Vert.x 客户端。
更多详情可查看官方博客。