Firefly 4.5.0 正式版发布

Firefly 4.5.0增加了Kotlin DSL风格的API和 Spring Reactor
适配器来帮助我们更方便的构建异步应用程序。

Kotlin DSL风格的API允许我们以半声明的方式来构造应用,例如:

private val log = Log.getLogger { }

fun main(args: Array<String>) {
    val server = HttpServer(requestLocal) {
        router {
            httpMethod = HttpMethod.GET
            path = "/"

            asyncHandler {
                end("hello world!")
            }
        }

        router {
            httpMethods = listOf(GET, POST)
            path = "/product/:type/:id"

            asyncHandler {
                statusLine {
                    status = OK.code
                    reason = OK.message
                }

                header {
                    "My-Header" to "Ohh nice"
                    SERVER to "Firefly kotlin DSL server"
                    +HttpField("Add-My-Header", "test add")
                }

                trailer {
                    "You-are-trailer" to "Crane ....."
                }

                val type = getRouterParameter("type")
                val id = getRouterParameter("id")
                log.info { "req type: $type, id: $id" }

                writeJson(Response("ok", 200, Product(id, type))).end()
            }
        }
    }
    server.listen("localhost", 8080)
}

在这个例子中,我们使用Kotlin DSL风格的API来设置HTTP method, path, header等,它能更清晰的表达HTTP协议的结构。

Firefly HTTP Server/Client (Kotlin版本)在协程(Coroutine)中执行业务逻辑,这意味着我们可以以同步风格的代码编写异步应用程序。编写协程同步风格的代码相比异步回调更简单,更易于阅读,并且不会影响程序的性能和伸缩性。

由于Java语言并没有原生协程(Coroutine),在未来的版本中我们考虑增加 Quasar
(一个JVM第三方协程库)适配器来使得Java版本的HTTP Server/Client运行在协程中。

为了让Java版本的框架更容易编写异步应用程序,增加了 Spring Reactor
适配器来帮助我们更流畅的构建异步应用。例如:

@Override
public Mono<Boolean> buy(ProductBuyRequest request) {
    if (request == null) {
        return Mono.error(new IllegalArgumentException("The product request is required"));
    }

    if (request.getUserId() == null || request.getUserId().equals(0L)) {
        return Mono.error(new IllegalArgumentException("The user id is required"));
    }

    if (CollectionUtils.isEmpty(request.getProducts())) {
        return Mono.error(new IllegalArgumentException("The products must bu not empty"));
    }

    return db.newTransaction(c -> buy(request, c));
}

private Mono<Boolean> buy(ProductBuyRequest request, ReactiveSQLConnection c) {
    return inventoryDAO.updateBatch(request.getProducts(), InventoryOperator.SUB, c)
                       .doOnSuccess(this::verifyInventory)
                       .flatMap(arr -> productDAO.list(toProductIdList(request), c))
                       .map(products -> toOrders(request, products))
                       .flatMap(orders -> orderDAO.insertBatch(orders, c))
                       .map(orderIdList -> true);
}

更多的例子请参考:

  • 示例应用
    (Java版)

  • 示例应用
    (Kotlin版)

更新日志:

  1. 增加Kotlin DSL风格的API

  2. 增加异步SQL客户端

  3. 增加Reactive stream适配器

  4. 增加Coroutine dispatcher

  5. HTTP客户端增自动识别gzip编码

  6. 增加slf4j MDC实现

  7. 增加日志formatter

  8. 增加AffinityThreadPool

原文 

https://www.oschina.net/news/90067/firefly-4-5-0

PS:如果您想和业内技术大牛交流的话,请加qq群(527933790)或者关注微信公众 号(AskHarries),谢谢!

转载请注明原文出处:Harries Blog™ » Firefly 4.5.0 正式版发布

赞 (0)

分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址