在WebClient中，我可以将请求与响应进行匹配吗？

Question

我试图使用Spring的新反应类在RESTfulendpoint上进行一些负载测试。我仍在学习这些课程，所以我可能会走错方向，所以如果你知道一条更简单的道路，请将我重定向到一条更容易的道路上。。。

这是我到目前为止的情况。这是groovy代码：

def token="xyz"

WebClient webClient=WebClient
    .builder()
    //Using google for example purposes only
    .baseUrl("http://google.com")
    //In the real code, there's a lot of extra headers like this one..
    .defaultHeaders({ headers ->
      headers.add(HttpHeaders.AUTHORIZATION,"bearer $token")
    })
    .build()

//This is where load is measured
for (int i:1..3) {
  webClient
      .method(HttpMethod.GET)
      .header("x","y")
      .attribute("i",i)
      .retrieve()
      .bodyToMono(String)
      .subscribe {
        body -> 
          println body
          //Is there any way to get the "i" attribute here to determine the request???
      }
}

sleep 30000
println "done"

我可以看到三个请求回来了，所以它正在工作。现在，我想对三个请求中的每一个的请求和响应之间的延迟进行计时。如果我可以获得“i”属性，每个循环都可以通过将当前时间存储在映射中开始，然后订阅方法可以使用“i”读取映射并将其与当前时间进行比较来计算增量。

我正在考虑的另一个选择是为每个请求创建一个新的WebClient，但会有1000个请求，我想优化性能。

而且，我对最后需要睡眠声明感到不太高兴。。。

使用Reactive类加载测试RESTful服务的最佳方法是什么？

Answer 1

我决定只使用一大组WebClient对象。在我的情况下，请求吞吐量足够高，足以淹没服务器，并导致请求速度较慢时无法看到的错误。不需要担心属性，而是为循环的每次迭代创建一个新变量来存储开始时间戳。请参见下面的代码：

for (int i:1..3) {
  WebClient webClient=WebClient
    .builder()
    //Using google for example purposes only
    .baseUrl("http://google.com")
    //In the real code, there's a lot of extra headers like this one..
    .defaultHeaders({ headers ->
      headers.add(HttpHeaders.AUTHORIZATION,"bearer $token")
    })
    .build()

  //Get timestamp here

  webClient
      .method(HttpMethod.GET)
      .header("x","y")
      .retrieve()
      .bodyToMono(String)
      .subscribe {
        body -> 
          //Get timestamp here and compare with the other timestamp to calculate latency.
      }
}