Java 目前实现全异步的方式有哪些

1.各种基于 Reactor 模型的框架 /库
2.内置的 java.util.concurrent.CompletableFuture/或者使用其的框架 /库

Java 本体的是 Task/Executor/Future 框架，基于线程池，可满足全部异步编程模型，但是编码易用性几乎为零。

三方框架大多都有编码友好的异步编程组件，通常都是基于 Java 本体的那个框架。如果你用 Spring，那么 @Async 就是用来做异步编程的，编码很容易，但是不支持全部异步编程模型。 @Async 的异步方法只能再抛出事件，不能返回 Futute，或者说仅支持 callback 模式，不支持 await 模式。

Vert.x

JDBC 会比较麻烦，别的还好

@passerbytiny 为什么说编码易用性为 0，completablefuture 不好用吗？

@golangLover 你得手写代码配置执行器 /线程池。此外可以对比下其他语言的异步语法。

JVM 生态上 vertx + kotlin coroutines，丝般顺滑

@passerbytiny #2 web 应用哪里用得着 @Async，都是基于 nio 包装个异步接口调用，@Async 本质是线程池，用这个处理 io 肯定是不行的

@sagaxu #7 求实战经验，这俩学习成本都不低啊

@ljzxloaf 你家 Web 应用该不是只有 Web 入口跟 SQL 两层吧。此外，IO 异步跟异步编程是两码事。

异步？简单的事情更简单，复杂的事情更复杂，而且总有一个链路要处理背压，如果无数请求都直接传给数据库，系统还有什么稳定性可言。只要涉及到 jdbc，现在 java 中异步也就是个玩具罢了。unix 的哲学就是同步比异步好。全链路异步，不用 jdbc，使用 redis, mogodb 之类（也是 epoll 模拟），只有 win 有 iocp, 而且异步的压力最终也会到 os 和 db 上。
spring 的 reactor，你去看看呗。也就几百个运算符。

Actor model 很好用的。不过我不太熟 java，jvm 上只知道一个 akka 。

@passerbytiny #10 web 应用不就这两层吗，就是收发数据啊，中间的 get/set 难道还需要分成几个任务去跑？这就没必要了吧？

哈哈,笑死了..什么是传说中的技术..所谓的难其实就是想要 await 与 async 么

看看第三方的协程库吧，纯 java 实现，我记得有一些

@ikas #14 有啥好笑的。。如果要传说中的技术我谷歌搜下就完事了，就是想知道生产实践中是什么情况。比如什么 ddd 、servicemesh 这些，对我来说就是传说中的技术，因为没在实践中看到过。传说中的技术就是没有生产实践过的技术

CompletableFuture 已经很好用啦

什么 A, B 都做完再做 C 用这个写起来已经够便捷了

目前生产实践用的是线程池挂 Job，然后 CountDownLatch 回来，可惜不按代码行数发工资。
进一步就是用 JUC 下的 CF，但是写起来还是有点难受，因为需要把大量同步代码封装成返回 CF 的调用。
再进一步就是 Vert.x 的 Future，版本到 4.0 几乎所有 API 都支持 Future 返回。then 等链式调用对于 Callback Hell 有所缓解。
妥协之选就是 Quarkus 。Route Layer 往下都是 Vert.x 实现，往上则是 RESTEasy 的 JAX-RS 实现。IO Thread 跟 Work Thread 分开，实现 IO 异步业务同步。
Project Loom 都不知道延期了多久，能不能赶得上 JDK17 这个 LTS……毕竟最终目标是写同步代码用异步执行。

@ljzxloaf 学习成本也还好，vertx 就是 jvm 版的 nodejs，用起来姿势差不多。kotlin coroutine 花一天了解一下 suspend 和 dispatcher，正常使用没问题了。两者的粘合，vertx 官方有专门的支持，vertx 4.0 之后基本是无缝的了。但跟 spring 粘合使用的时候，就有点儿脏了，spring 注入的是单例，而 vertx 讲究的是不要跨 context，一般同 verticle 内办事，跨 verticle 得走 rpc 。

reactor 和 rxjava 都实现了 reactivex，rxjava 兼容性好，能在 Android 上跑，但后端生态肯定 reactor 好，从数据库层的 r2dbc，web 层 webflux，不少 rpc，消息队列，http client 都支持 reactor，真正的全链路响应式

@ccde8259 loom 稳定版不太可能赶得上 17 了，下一个 lts 应该问题不大，下一个 lts 还能期待一下满血版的 zgc

@ccde8259 #18 理想丰满，现实骨感😂

@sagaxu 再等下一个 LTS 怕是已经开滴滴送外卖去了……人生能有几个 LTS ？

Vert.x + kotlin

用 webflux 写过一个主要耗时是 io 的服务，webflux 这套东西很少看到有人用，目前只有 no sql 的数据库支持异步，比如 mongodb 、redis，传统的 mysql 不行，写复杂业务很恶心，而且懂这套的人太少了，意味着二次开发及维护困难，一般就网关用用，属于小众的大杀器

@wqhui #25 这么看也挺适合那种 BFF （ Backend for Frontend ）聚合服务的，调接口组装数据再返给前端

说实话在 await 和 reactivex 里选 reactivex 使用体验更好，和同步方法的交互也更舒适，callback 肯定是能不用就不用

看了一圈，结论是没有好的解决方案。唯有换 kotlin 。我知道 ea 发明了个 ea-async 但 ea 已经一两年没有维护了。

Mutiny
reactor
rxjava
vertx

目前 java 的常用的 reactive 库就有这几个吧,都跟 kotlin 的 coroutine 有不错的互动

vertx + kotlin coroutine，爽（

@Magentaize rxjava 就没见过在服务器端用的，基本上看到的都是在安卓用

我们以前写 mqtt 服务器就是 vertx，用到了 kotlin，不过没用协程，写起来挺方便的啊
vertx 提供了很多异步风格的 client，我们当时就用到了 redis 和 hazelcast

累不累，直接上 golang 不好么？

在以前的公司用 rxjava 把所有服务端改为了异步，技术性大于实用性，有一些坑需要注意。后端主要的瓶颈还是数据库，没见过单纯因为线程数不足而影响服务的情况

阿里的 wisp2 可以

投票里的 vertx stack 和 kt coroutine 应该算是同一个吧。。。大部分用 vertx 都转 kt 加持了

推荐 ParSeq，一个 java 异步化工具。

生产环境大规模实践过。

@micean vertx 和 kt 不能算同一个，kt 也有用 ktor 的

毕竟纯 vertx 写起来挺难受的

用 vertx 6 年了，很方便啊。

不能 append 了。。

简单总结下：看起来这几种异步实践流行度差不多，所以如果没有 reactive 经验的直接上 vertx+kt coroutine ；有 reactive 经验：如果当前还是 servlet，直接上 webflux ；如果已经是异步 server，可以上 webflux 也可以上 rxjava ；懒得折腾的继续用 future/callback 吧，等 java 发布 coroutine 。

当然还有个不错的选择：转 golang 吧😈

@ljzxloaf #41 异步 server 应该上不了 webflux 了，webflux 包括了 server

@wqhui sql 有 r2dbc 规范, 很多数据库都支持貌似.

我发现 v2 黑夜模式看不到投票的选项。

全异步就得解决数据库连接的问题。例如 JDBC，阻塞转换为非阻塞才行。

否则，都相差不多。

试试看 Cloudopt Next 吧：

https://github.com/cloudoptlab/cloudopt-next

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

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


** Cloudopt Next 主要拥有以下特点：**


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



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



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



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



**GitHub:**


https://github.com/cloudoptlab/cloudopt-next


**开源中国：**

https://gitee.com/cloudopt/cloudopt-next


## 示例


您可以通过访问[Cloudopt Next 的官网]( https://next.cloudopt.net)来查看文档，也可以前往[Example]( https://github.com/cloudoptlab/cloudopt-next-example)查看简单的示例。


### 路由


让我们来看看一个简单的基于 Cloudopt Next 的路由：


```kotlin
@API("/")
class IndexController : Resource() {
@GET
fun get(){
renderHtml(view = "index")
}
}
```


```java
@API(value = "/")
public class IndexController extends Resource {

@GET
public void get(){
View v = new View();
v.setView("index");
renderHtml(v);
}
}
```


### 启动


```kotlin
fun main(args: Array<String>) {
NextServer.run()
}
```


```java
public static void main(String args[]) {
NextServer.run();
}
```


### 超好用的协程
```kotlin
var value = await<String>{handler->
handler.complete(RedisManager.sync().get("key"))
}
```
###
### WebSocket
```kotlin
@WebSocket("/websocket")
class WebSocketHandler : WebSocketResource {

override suspend 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 suspend fun onConnectionFailure(throwable: Throwable) {

}

override suspend fun onConnectionComplete(websocket: ServerWebSocket) {

}

override suspend fun onFrameMessage(frame: WebSocketFrame, websocket: ServerWebSocket) {

}

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

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

}

override suspend fun onPong(buffer: Buffer, websocket: ServerWebSocket) {

}

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

override suspend fun onDrain(websocket: ServerWebSocket) {

}

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


```kotlin
@SocketJS("/socket/api/*")
class SocketController : SocketJSResource {
override fun handler(userSocketConnection: SockJSSocket) {
println(userSocketConnection)
userSocketConnection.handler {message->
println(message)
userSocketConnection.write("Hello world!")
}
}
}
```


### 插件


```kotlin
fun main(args: Array<String>) {
NextServer.addPlugin(TestPlugin())
NextServer.addPlugin(EventPlugin())
NextServer.run()
}
```

尴尬了，回复不支持 markdown，大家可以去 GitHub 看看。

我们的 api 网关是异步 servlet
部分模块也有用 rxjava