轻量级的 Kotlin 异步 Web 框架 Next 发布 3.0.0.0

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

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

Cloudopt Next 主要拥有以下特点：

简单 极简设计，几乎不要任何配置，不依赖 Tomcat、Jetty 等 Web 容器。

异步 基于 vertx 轻松实现高性能的异步服务。

扩展 支持 vertx 体系的各种组件，同时支持通过插件扩展功能，官方也提供了大量好用的插件。

中文 全中文文档、中文社区，帮助中文开发者快速上手。

3.0.0.0 主要变动是在升级了底层依赖、全面重构了反射、支持协程及全面实现非阻塞能力。其次是优化了 websocket 的使用和定制了很多协程相关的语法糖。

依赖升级

在 3.0.0.0 中对一些基础依赖进行了全面升级， JDK 升级到 11、Vertx 升级到 4.0.0、Kotlin 升级到 1.4.0。我们也建议在这样的环境下运行，较低的版本尚未做兼容性测试。

反射重构

对使用 Java 的开发者来说影响不大，主要是提升了 Kotlin 开发者的开发体验。

在新版中，对大部分的反射、扫描注解进行了重构。原本是使用 Java 原生的反射操作，现在全部改为了 Kotlin 原生的反射操作。改为 Kotlin 原生语法后对 Kotlin 的基础类型的支持更加友好、也避免了 Kotlin 类转回 Java 类的开销。

在反射上也全面支持了 kotlin 协程的 suspend 声明。

WebSocket 更新

请使用以下新的用法。现在支持更优雅的用法，只需要继承 WebSocketResource 并实现相应的方法即可。

@WebSocket("/websocket")
class WebSocketHandler : WebSocketResource {

    override fun beforeConnection(resource: Resource): Boolean {
        resource.request.response().statusCode = 400
        resource.request.response().end()
        return false
    }

    override fun onConnectionSuccess(websocket: ServerWebSocket) {
        websocket.writeTextMessage("Connection successful!") {
            println("The event of after write.")
        }
        val buffer: Buffer = Buffer.buffer().appendInt(123).appendFloat(1.23f)
        websocket.writeBinaryMessage(buffer) {
            println("The event of after write binary.")
        }
    }

    override fun onConnectionFailure(throwable: Throwable) {

    }

    override fun onConnectionComplete(websocket: ServerWebSocket) {

    }

    override fun onFrameMessage(frame: WebSocketFrame, websocket: ServerWebSocket) {
        println(frame.textData())
        websocket.writeTextMessage("This is the message from the server!")
    }

    override fun onTextMessage(message: String, websocket: ServerWebSocket) {
        println(message)
        websocket.writeTextMessage("This is the message from the server!")
    }

    override fun onBinaryMessage(buffer: Buffer, websocket: ServerWebSocket) {

    }

    override fun onPingPong(buffer: Buffer, websocket: ServerWebSocket) {
        println("Pong...")
    }

    override fun onException(throwable: Throwable, websocket: ServerWebSocket) {
        throwable.printStackTrace()
        if (!websocket.isClosed) {
            websocket.close()
        }
    }

    override fun onDrain(websocket: ServerWebSocket) {

    }

    override fun onEnd(websocket: ServerWebSocket) {
        println("Connection was closed.")
    }


}

支持协程

fun test() {
    var id = worker<Int>({ handler ->
        handler.complete(1)
    }, { asyncResult ->
        //onComplete
    })
}suspend fun test() {

    var id = await<Int> { handler ->
        handler.complete(1)
    }
}

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网

关注我们，获取更多IT资讯^_^

查看所有标签

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。