Vertx WebClient响应缓慢

Question

我不熟悉vertx和RxJava。我正在尝试实现一个简单的测试程序。然而，我无法理解这个项目的动态。为什么有些请求需要10秒钟以上才能响应？

下面是我的示例测试应用程序

public class Test {

public static void main(String[] args) {

Vertx vertx = Vertx.vertx();
WebClient webClient = WebClient.create(vertx);

Observable < Object > google = hitURL("www.google.com", webClient);
Observable < Object > yahoo = hitURL("www.yahoo.com", webClient);

for (int i = 0; i < 100; i++) {
  google.repeat(100).subscribe(timeTaken -> {
    if ((Long) timeTaken > 10000) {
      System.out.println(timeTaken);
    }
  }, error -> {
    System.out.println(error.getMessage());
  });
  yahoo.repeat(100).subscribe(timeTaken -> {
    if ((Long) timeTaken > 10000) {
      System.out.println(timeTaken);
    }
  }, error -> {
    System.out.println(error.getMessage());
  });
}
}

public static Observable < Object > hitURL(String url, WebClient webClient) {
return Observable.create(emitter -> {
  Long l1 = System.currentTimeMillis();
  webClient.get(80, url, "").send(ar -> {
    if (ar.succeeded()) {
      Long elapsedTime = (System.currentTimeMillis() - l1);
      emitter.onNext(elapsedTime);
    } else {
      emitter.onError(ar.cause());
    }
    emitter.onComplete();
  });
});
}
}

我想知道的是，是什么让我的响应时间变慢了？

Answer 1

这里的问题似乎在于您使用WebClient的方式和/或您测量“响应”时间的方式（取决于您在这里试图实现的目标）。

垂直。与大多数http客户端一样，x的WebClient在后台使用大小有限的连接池来发送请求。换句话说，调用。发送（…） 不一定立即启动http请求-相反，它可能会在某种队列中等待可用的连接。您的测量包括此潜在等待时间。

您正在使用默认池大小，它似乎是5（至少在最新版本的Vert. x中-它在此处定义），并且几乎立即启动200个超文本传输协议请求。大多数时候您的请求都在等待可用连接，这并不奇怪。

如果要测试我是否正确，可以尝试增加池大小：

WebClient WebClient=WebClient。创建（vertx，new WebClientOptions（）。setMaxPoolSize（…）；