摘要：定时器例子之前通过调用定时器，需要传一个回调，然后所有的代码逻辑都包在里面。这里定时器会阻塞在这一行，直到一秒后才会执行下面的一行。
之前介绍过quasar，如果你希望在vert.x项目里使用coroutine的话，建议使用vertx-sync。本篇将介绍vertx-sync。
本来打算另起一篇，写其他方面的东西，但是最近比较忙，就先写一篇实践方面的文章。
vertx-sync是什么上一篇我们已经讲了 Fiber 相关的知识，想必大家对Java实现类似Golang的coroutine已经有印象了，既然Java世界里有第三方提供了这么好的库，那我们就看看怎么跟 vert.x 结合起来使用。
vert.x官方为了解决异步代码编写的困难，使之更加同步化对开发人员更友好，便基于quasar包装了一个的同步库，vertx-sync，该库的作者同样也是vert.x的原作者，所以完成度还是很高的。
vertx-sync 对外只是暴露了几个简单的静态API，来完成对vert.x体系内一系列的操作包装，其实主要也就是三静态API而已。
Sync.fiberHandler 如果你希望你的handler里有一些逻辑需要在Fiber里运行，则你的handler必须用这个方法包一下。
Sync.awaitEvent 从Handler里返回一个事件结果(同步的)，且 不会阻塞EventLoop
Sync.awaitResult 从Handler里返回一个异步事件结果(同步的)，且 不会阻塞EventLoop
直接看介绍可能有点不直观，下面跑几个例子。
使用vertx-sync之前介绍过quasar，如果你希望在项目里使用coroutine的话，需要在JVM里设置一个参数，用于应用启动前修改字节码(注入一些中断方法)，从而可以达到协程的目的。
具体方法也很简单。
-javaagent:/path/to/the/quasar-core-0.7.5-jdk8.jar
如果是基于Maven跑单元测试，那只需要引用quasar instrument的插件就可以里
com.vlkan quasar-maven-plugin 0.7.3 true true true instrument co.paralleluniverse quasar-core 0.7.5
上面是一些非常必要的准备工作，否则你无法使用quasar以及vertx-sync。
之前通过vert.x调用定时器，需要传一个回调handler，然后所有的代码逻辑都包在里面。
vertx.setTimer(1000L, h -> {
System.out.println("time"s up");
});
现在我们来重新塑造一下三观。
awaitEvent(h -> vertx.setTimer(1000L, h));
System.out.println("time"s up");
这里定时器会阻塞在awaitEvent这一行，直到一秒后才会执行下面的一行。有点类似执行 Thread.sleep(1000L)，但是并不会阻塞 EventLoop 因为quasar会在EventLoop基础之上再开启一个fiber。
下面我看个稍微复杂点的例子。
我们先用传统的回调方式使用vert.x的HttpClient API。
HttpClientRequest httpClientRequest = vertx.createHttpClient().get("leapcloud.cn");
httpClientRequest.handler(response -> {
response.handler(responseBody -> {
System.out.println(responseBody.toString());
});
}).end();
这里有两层回调嵌套，一层是得到Http的Response，另一层是从Response里得到详细的body。因为有lambda表达式才使得Java现在看起来并不是那么恶心。但是如果我们需要根据body的内容进一步做判断去继续请求其他页面，则嵌套会变的非常的深。下面尝试改造成sync方式看看。
HttpClientRequest httpClientRequest = vertx.createHttpClient().get("leapcloud.cn");
HttpClientResponse response = awaitEvent(Sync::fiberHandler);
Buffer body = awaitEvent(response::handler);
System.out.println(body.toString());
额，是不是感觉看着很舒服，无嵌套，直接顺序下来，非常的直观，加上Java8特有的方法引用，会让代码更精简。
写过vert.x同学肯定知道其vertx-jdbc-client为了使其兼容异步开发模型，将JDBC的底层线程池用异步方式包装了一下，也就是说JDBC层还是通过线程池去访问数据库的，但是是通过vert.x的context做了层封装，使其可以将结果放到对应的 EventLoop 里，这样比较符合vert.x的开发风格。但是带来的弊端就是嵌套太深。
final JDBCClient client = JDBCClient.createShared(vertx, new JsonObject()
.put("url", "jdbc:hsqldb:mem:test?shutdown=true")
.put("driver_class", "org.hsqldb.jdbcDriver")
.put("max_pool_size", 30));
client.getConnection(conn -> {
if (conn.failed()) {
System.err.println(conn.cause().getMessage());
return;
}
final SQLConnection connection = conn.result();
connection.execute("create table test(id int primary key, name varchar(255))", res -> {
if (res.failed()) {
throw new RuntimeException(res.cause());
}
// insert some test data
connection.execute("insert into test values(1, "Hello")", insert -> {
// query some data
connection.query("select * from test", rs -> {
for (JsonArray line : rs.result().getResults()) {
System.out.println(line.encode());
}
// and close the connection
connection.close(done -> {
if (done.failed()) {
throw new RuntimeException(done.cause());
}
});
});
});
});
});
上面代码可以是不是有点恶心呢？尝试改造一下吧。
final JDBCClient client = JDBCClient.createShared(vertx, new JsonObject()
.put("url", "jdbc:hsqldb:mem:test?shutdown=true")
.put("driver_class", "org.hsqldb.jdbcDriver")
.put("max_pool_size", 30));
try (SQLConnection conn = awaitResult(jdbc::getConnection)) {
awaitResult(h -> conn.execute("create table test(id int primary key, name varchar(255))", h));
awaitResult(h -> conn.execute("insert into test values(1, "Hello")", h));
ResultSet query = awaitResult(h -> conn.query("select * from test", h));
for (JsonArray line : query.result.getResults()) {
System.out.println(line.encode());
}
AsyncResult done = awaitResult(h -> conn.close(h));
if (done.failed()) {
throw new RuntimeException(done.cause())
}
} catch (Exception e) {
e.printStackTrace();
}
除了一个try catch，其他都没有嵌套，整体逻辑的可读性非常高，完全是线性的。
你也许会发现我们似乎一直都没有用到 fiberHandler 这个静态方法，上面虽然写了定义，可能大家还是不能够理解，这里结合场景也许能更好理解。
我们尝试实现一个操作很耗时的逻辑然后包到fiber里，避免 EventLoop 被阻塞。这里你也许会很好奇，既然 Fiber 这么廉价开启10万8万的无所谓啊，恩，这里再提一下quasar的重点部分: fiber可以很廉价的被创造出来，但是他本质上还是跑在一个线程上面，如果其中一个fiber执行了非常耗时的操作，则后面的fiber会一直等待，从而造成整个线程阻塞。 也就是说一个fiber不能执行非常耗时的操作，比如计算100万以内的素数之和，对于这种操作，我们可以通过直接将逻辑放到vert.x的worker线程里多带带去跑，然后通过fiber包装一下就可以了。
