关于java:asyncawait-Java-NIO

76次阅读

共计 1047 个字符，预计需要花费 3 分钟才能阅读完成。

尽管 Java 官网有 loom 我的项目来实现协程，然而切实等不住了。既然 fanx 反对 async/await，所以就尝试和异步 IO 联合，来实现高性能网络框架。

代码见这里：fanx-dev/fanxServer。

架构相似于 netty 的 reactor 模式，像这样：

示例代码：

class TestServer : Handler {override async Void onService(Socket socket) {buf := NioBuf.makeMem(1024)
    n := await socket.read(buf, 1)
    buf.flip()
    echo("=====server receive: $buf:"+buf.readAllStr)

    buf.clear
    buf.printLine("HelloWorld")
    buf.flip
    n2 := await socket.write(buf)
    echo("=====send:"+n2)
  }

  static Void main() {
    Server {
      port = 8080
      handler = TestServer#
    }.start
  }
}

代码中，当运行到 await 的时候当前任务暂停，并交给 selector 线程去监听 IO 事件，以后线程没有阻塞而是去持续解决其余连贯工作。当 selector 发现事件就绪后告诉复原运行工作。因为采纳线程池机制 await 前后可能运行在不同的线程中。

是不是代码看起来比 netty 的回调好多了。

反对根本的 Http 协定：

class HttpTestServer : HttpHandler {override async Void onHttpService(HttpReq req, HttpRes res) {echo("Server receive:"+req.headers)
    res.headers["Content-Type"] = "text/html; charset=utf-8"

    buf := NioBuf.makeMem(1024)
    buf.printLine("<html>
                        <body>Hello World</body>
                       </html>")
    buf.flip
    //await res.writeFixed(buf)
    await res.writeChunk(buf)
  }

  static Void main() {
    Server {
      port = 8080
      handler = HttpTestServer#
    }.start
  }
}

性能方面没有测试，预计必定比阻塞 IO 好。

Java 基于协程的 IO 框架还能够应用 kilim，本我的项目也参考了 kilim 的代码。

正文完