之前我们为了保持课程的紧凑性与连贯性，直接从官网上粘贴了很多不优雅的代码(顺便吐槽一下官网的示例代码，Vert.x明明有更优雅的方案，但大多数示例代码却并没有按照优雅的方式去写)
之前的代码有好多都是lambda表达式里面再套lamdba表达式,以及lambda表达式中.套.........同,时........中再嵌套lambda表达式(不知不觉就写出了回调地狱)
但java程序员，最习惯的是链式调用，我们自然会想，在Vert.x中有没有跟JavaScript的Promise相类似的机制，可以将lambda表达式转换成链式调用呢?
每一个lambda表达式，都是一个Handler接口
很遗憾，在Handler接口中，并没有提供链式调用的方法。
但是，根据java面向对象的特点，只要Handler接口有子类或子接口实现了链式调用的功能，我们直接用这个子类或子接口就可以了。
答案来了Vert.x中给我们提供了一个Handler的子接口——Future,它有个compose()方法可以链式调用。
但Future虽然实现了链式调用，但是无法封装异步调用的结果，所以需要借助Handler的另一个子接口——Promise来封装异步调用的结果，并生成Future
所以，我们用Future+ Promise就将参数中的lambda表达式变成返回值，从而实现链式调用。
注意，只有Handler中的泛型有AsyncResult才可以用Future+ Promise模式。
1、编写FuturePromiseVerticle代码
package vertx;
import io.vertx.config.ConfigRetriever;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future;
import io.vertx.core.Promise;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.web.Router;
import io.vertx.mysqlclient.MySQLConnectOptions;
import io.vertx.mysqlclient.MySQLPool;
import io.vertx.sqlclient.*;
import java.util.ArrayList;
public class FuturePromiseVerticle extends AbstractVerticle {
//声明Router
Router router;
//配置连接参数
MySQLConnectOptions connectOptions;
//配置连接池 Pool options
PoolOptions poolOptions = new PoolOptions()
.setMaxSize(5);
//Create the client pool
MySQLPool client;
@Override
public void start(Promise<Void> startPromise) throws Exception {
ConfigRetriever retriever = ConfigRetriever.create(vertx);
retriever.getConfig(ar -> {
if (ar.failed()) {
// Failed to retrieve the configuration
} else {
JsonObject config = ar.result();
connectOptions = new MySQLConnectOptions()
.setPort(config.getInteger("port"))
.setHost(config.getString("host"))
.setDatabase(config.getString("database"))
.setUser(config.getString("user"))
.setPassword(config.getString("password"));
client = MySQLPool.pool(vertx, connectOptions, poolOptions);
//初始化Router
router = Router.router(vertx);
//配置Router解析url
router.route("/").handler(
req -> {
req.response()
.putHeader("content-type", "text/plain")
.end("Hello from Vert.x!");
}
);
//配置Router解析url
router.route("/test/list").handler(
req -> {
var page = (Integer.valueOf(req.request().getParam("page")) - 1) * 10;
var size = Integer.valueOf(req.request().getParam("size"));
//Get a connection from the pool
this.getCon()
.compose(con -> this.getRows(con, page, size))
.onSuccess(row -> {
var list = new ArrayList<JsonObject>();
row.forEach(item -> {
var json = new JsonObject();
json.put("id", item.getValue("id"));
json.put("name", item.getValue("name"));
json.put("age", item.getValue("age"));
json.put("info", item.getValue("info"));
list.add(json);
});
req.response()
.putHeader("content-type", "application/json")
.end(list.toString());
});
}
);
//将Router与vertx HttpServer 绑定
vertx.createHttpServer().requestHandler(router).listen(8888, http -> {
if (http.succeeded()) {
startPromise.complete();
System.out.println("HTTP server started on port 8888");
} else {
startPromise.fail(http.cause());
}
});
}
});
}
//第一步 获取数据库链接
private Future<SqlConnection> getCon(){
Promise<SqlConnection> promise = Promise.promise();
client.getConnection(ar1 -> {
if (ar1.succeeded()) {
System.out.println("Connected");
//Obtain our connection
SqlConnection conn = ar1.result();
promise.complete(conn);
} else {
promise.fail(ar1.cause());
}
});
return promise.future();
}
//第二步 用获取到的链接查询数据库
private Future<RowSet<Row>> getRows(SqlConnection conn, Integer page, Integer size){
Promise<RowSet<Row>> promise = Promise.promise();
conn
.preparedQuery("select id, name, age, info from person limit ?, ?")
.execute(Tuple.of(page, size), ar2 -> {
//Release the connection to the pool
conn.close();
if(ar2.succeeded()){
promise.complete(ar2.result());
}else{
promise.fail(ar2.cause());
}
});
return promise.future();
}
}2、启动测试
