Cloudopt 的后端就是基于 Kotlin + Vert.x 的。我们为了更好的使用 Vert.x 开发了一个基于 Kotlin + Vert.x 的后端框架 Cloudopt Next。同时也是 vertx 及 awesome-kotlin 推荐项目。

    Cloudopt Next 是一个非常轻量级且现代的、基于 Kotlin 编写的全栈开发框架，同时支持 Java 和 Kotlin，您可以处理Url的解析，数据的封装,Json的输出等等，从根本上减少开发时间、提升开发体验。

    比如直接用 Vert.x 写路由的话是下面这样的写法：

    1. router.route().handler(ctx -> {
    2.   // This handler will be called for every request
    3.   HttpServerResponse response = ctx.response();
    4.   response.putHeader("content-type", "text/plain");
    5.   // Write to the response and end it
    6.   response.end("Hello World from Vert.x-Web!");
    7. });

    那么当你还要操作数据库的话，那么看起来就是一个回调嵌着一个回调，很容易形成回调地狱。

    让我们看看在 Next 中如何实现一个简单的输出 Json 的路由：

    1. @GET("json")
    2. fun json() {
    3.   var map = hashMapOf<String, Any>()
    4.   map.put("a", 1)
    5.   map.put("b", 2)
    6.   renderJson(map)
    7. }

    在写法上完全不需要改变自己的习惯用传统的写法即可。甚至你还可以直接使用类似 spring boot 的参数注入的写法（结合 hibernate 的参数校验）：

    1. fun argsController(
    2.   @Chinese(false)
    3.   @Parameter("name", defaultValue = "Peter")
    4.   name: String,
    5.   @Min(18)
    6.   @Parameter()
    7.   age: Int
    8.   ) {
    9.     var map = hashMapOf<String, Any>()
    10.     map["name"] = name
    11.     map["age"] = age
    12.     renderJson(map)
    13. }

    而且在 Cloudopt Next 中支持多种异步写法，你可以选择自己喜欢写法自由发挥：

    比如我们现在需要运行某个阻塞的代码并需要将结果传递回来，你可以用以下的方式运行。当然你也可以通过 Worker.worker 运行阻塞的代码。记得在结尾通过 handler.complete 传递结果。

    1. fun test() {
    2.     var id = worker<Int>({ handler ->
    3.         handler.complete(1)
    4.     }, { asyncResult ->
    5.         //onComplete
    6.     })
    7. }

    第二种做法是利用 kotlin 的协程的 await 特性，写起来会更为优雅。但利用 kotlin 协程需要在方法上声明 suspend。这也是我们推荐的异步写法。

    1. suspend fun test() {
    2.     var id = await<Int> { handler ->
    3.         handler.complete(1)
    4.     }
    5. }

    第三种情况是你在无法支持 suspend 语法的地方使用 await 语法。你可以使用下面的方式运行：

    1. fun test() {
    2.     global {
    3.         var id = await<Int> { handler ->
    4.             handler.complete(1)
    5.         }
    6.     }
    7. }

    第四种做法是你可以在路由的方法上增加 @Blocking 注解，使其自动变为普通的路由。

    1. @Blocking
    2. @GET("blocking")
    3. fun blocking() {
    4.     renderText("This is Blocking!")
    5. }

    比如我们利用 await 语法就可以直接使用任意的同步操作数据库 orm ，完全不用担心阻塞的问题（这里用的是 jooq）：

    1. @GET
    2. suspend fun get() {
    3.     await { promise ->
    4.             val result = JooqManager.dsl?.selectFrom(Tables.TODO)?.fetch()?.into(Todo::class.java)
    5.             renderJson(result )
    6.             promise.complete()
    7.         }
    8. }

    当然你把它封装好的话，看起来就是这样的：

    1. @GET
    2. suspend fun get() {
    3.     renderJson(todoService.getTodoList())
    4. }

    当然还支持通过注解来设置验证器、Handler 等等，甚至还简化了 Vert.x 的 EventBus，你只需要在路由上面声明 @AfterEvent即可自动完成在 xxx 事件后执行 xxx 事件这种方式。

    1. @GET("afterEvent")
    2. @AfterEvent(["net.cloudopt.web.test"])
    3. fun afterEvent() {
    4.     this.context.data().put("key","value")
    5.     renderText("AfterEvent is success!")
    6. }

    你只需要在其它类上声明 @AutoEvent 并继承 EventListener 即可自动订阅这个事件。

    1. @AutoEvent("net.cloudopt.web.test")
    2. class TestEventListener:EventListener {
    3.     override fun listener(message: Message<Any>) {
    4.         print(message.body())
    5.     }
    6. }

    Cloudopt Next 在很大程度上让你保留了原先的编程习惯，同时获得了 Vert.x 的强大的性能。不仅如此，Cloudopt Next 提供了大量的插件，如分布式二级缓存、jooq、redis、日志、spring支持、quartz、国际化等等 Vert.x 没有提供的功能。还兼容 Vert.x 的模块体系。也就是说你不仅可以用 Next 官方出的插件，还可以用 Vert.x 的插件以及 Vert.x 社区贡献的一系列生态。

    赶紧试试吧，使用 Koltin + Next 你将获得一个学习曲线平滑、使用简单、符合直觉且性能极高的异步服务。