Vert.x 与 JDBC 相比 CompletableFuture.supplyAsync 的数据访问优势
Vert.x data access benefits over CompletableFuture.supplyAsync with JDBC
与 CompletableFuture.supplyAsync 和 JDBC [=25= 相比,使用 vert.x 数据访问库连接到数据库(例如 Reactive PostgreSQL client)有什么好处]在线程管理方面。
假设我们有一个网络应用程序。
在这两种情况下,请求线程在等待数据库时都不会被阻塞,那么为什么有人会在官方 jdbc 上使用 vert.x 驱动程序?
例如 JDBC:
String url = "jdbc:postgresql://localhost/test";
Properties props = new Properties();
props.setProperty("user","fred");
props.setProperty("password","secret");
props.setProperty("ssl","true");
CompletableFuture.supplyAsync(() -> {
Connection conn = DriverManager.getConnection(url, props);
Statement st = conn.createStatement();
ResultSet rs = st.executeQuery("SELECT * FROM mytable WHERE columnfoo = 500");
while (rs.next())
{
System.out.print("Column 1 returned ");
System.out.println(rs.getString(1));
}
rs.close();
st.close();
});
在vert.x
PgConnectOptions connectOptions = new PgConnectOptions()
.setPort(5432)
.setHost("the-host")
.setDatabase("the-db")
.setUser("user")
.setPassword("secret");
// Pool options
PoolOptions poolOptions = new PoolOptions()
.setMaxSize(5);
// Create the client pool
PgPool client = PgPool.pool(connectOptions, poolOptions);
// A simple query
client.query("SELECT * FROM users WHERE id='julien'", ar -> {
if (ar.succeeded()) {
RowSet<Row> result = ar.result();
System.out.println("Got " + result.size() + " rows ");
} else {
System.out.println("Failure: " + ar.cause().getMessage());
}
// Now close the pool
client.close();
});
的确,在这两种情况下,调用者线程都不会被阻塞。
但在第一种情况下,任务被移交给池中的线程(在您的示例中,JDK的内部池),而在第二种情况下,Reactive Pg Client 异步操作并在结果准备就绪时调用提供的回调。
线程是有代价的(内存、上下文切换)。因此,如果您的应用程序需要用较少的资源处理大量请求,Reactive Pg Client 可能是更好的选择。
与 CompletableFuture.supplyAsync 和 JDBC [=25= 相比,使用 vert.x 数据访问库连接到数据库(例如 Reactive PostgreSQL client)有什么好处]在线程管理方面。
假设我们有一个网络应用程序。 在这两种情况下,请求线程在等待数据库时都不会被阻塞,那么为什么有人会在官方 jdbc 上使用 vert.x 驱动程序?
例如 JDBC:
String url = "jdbc:postgresql://localhost/test";
Properties props = new Properties();
props.setProperty("user","fred");
props.setProperty("password","secret");
props.setProperty("ssl","true");
CompletableFuture.supplyAsync(() -> {
Connection conn = DriverManager.getConnection(url, props);
Statement st = conn.createStatement();
ResultSet rs = st.executeQuery("SELECT * FROM mytable WHERE columnfoo = 500");
while (rs.next())
{
System.out.print("Column 1 returned ");
System.out.println(rs.getString(1));
}
rs.close();
st.close();
});
在vert.x
PgConnectOptions connectOptions = new PgConnectOptions()
.setPort(5432)
.setHost("the-host")
.setDatabase("the-db")
.setUser("user")
.setPassword("secret");
// Pool options
PoolOptions poolOptions = new PoolOptions()
.setMaxSize(5);
// Create the client pool
PgPool client = PgPool.pool(connectOptions, poolOptions);
// A simple query
client.query("SELECT * FROM users WHERE id='julien'", ar -> {
if (ar.succeeded()) {
RowSet<Row> result = ar.result();
System.out.println("Got " + result.size() + " rows ");
} else {
System.out.println("Failure: " + ar.cause().getMessage());
}
// Now close the pool
client.close();
});
的确,在这两种情况下,调用者线程都不会被阻塞。
但在第一种情况下,任务被移交给池中的线程(在您的示例中,JDK的内部池),而在第二种情况下,Reactive Pg Client 异步操作并在结果准备就绪时调用提供的回调。
线程是有代价的(内存、上下文切换)。因此,如果您的应用程序需要用较少的资源处理大量请求,Reactive Pg Client 可能是更好的选择。