内容简介:Firefly 4.5.0增加了Kotlin DSL风格的API和Spring Reactor适配器来帮助我们更方便的构建异步应用程序。 Kotlin DSL风格的API允许我们以半声明的方式来构造应用,例如: private val log = Log.getLogger { ...
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); }
更多的例子请参考:
更新日志:
增加Kotlin DSL风格的API
增加异步 SQL 客户端
增加Reactive stream适配器
增加Coroutine dispatcher
HTTP客户端增自动识别gzip编码
增加slf4j MDC实现
增加日志formatter
增加AffinityThreadPool
【声明】文章转载自:开源中国社区 [http://www.oschina.net]
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- React 17 正式版发布
- Eclipse 4.9 正式版发布!
- PyCharm 2018.3 正式版发布!
- GoLand 2018.3 正式版发布!
- PhpStorm 2018.3 正式版发布!
- Gradle 5.0 正式版发布
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
人类思维如何与互联网共同进化
[美] 约翰·布罗克曼 / 付晓光 / 浙江人民出版社 / 2017-3 / 79.90元
➢人类是否因互联网的诞生进入了公平竞争的场域? “黑天鹅事件”频频发生,我们的预测能力是否正在退化? 智人的第四阶段有哪些特征? 全球脑会使人类成为“超级英雄”吗? 虚拟现实技术会不会灭绝人类的真实体验? 还有更多不可预知答案的问题,你将在本书中找到属于自己的答案! ➢ 我们的心智正和互联网发生着永无止境的共振,人类思维会因此产生怎样的进化效应?本书编者约翰•布......一起来看看 《人类思维如何与互联网共同进化》 这本书的介绍吧!