响应式编程扩展
API 文档
你当前正在浏览历史版本 Vert.x 4.0.3 的文档。 前往 最新版本文档首页。

Vert.x 响应式扩展 (RxJava 1 / 2 / 3)

Vert.x 为 RxJava 响应式流规范提供了完备的语言扩展绑定，支持使用强大的 Observable / Flowable 操作符组合并发事件流。

依赖引入

  • Maven (pom.xml):

<dependency>
 <groupId>io.vertx</groupId>
 <artifactId>vertx-rx-java3</artifactId>
 <version>4.5.35</version>
</dependency>

使用 RxJava 3

import io.vertx.rxjava3.core.Vertx;
import io.vertx.rxjava3.core.http.HttpClient;

Vertx vertx = Vertx.vertx();
HttpClient client = vertx.createHttpClient();

client.rxRequest(HttpMethod.GET, 8080, "localhost", "/")
  .flatMap(request -> request.rxSend())
  .subscribe(response -> {
    System.out.println("收到响应状态码: " + response.statusCode());
  });