如何将千分尺计时器与webflowendpoint一起使用

Question

有没有什么简单的方法可以将千分尺计时器与网络流量控制器一起使用？

似乎@Timed只对非反应式方法有效。对于反应式，它记录非常低的时间值。

我发现了一个类似的问题：如何使用千分尺计时器记录异步方法的持续时间（返回单声道或通量），但对于这样一个常见的问题来说，答案太复杂了。

有什么想法吗？

Answer 1

如果您想测量Web flux方法/调用的时间，则可以直接使用flux/Mono中的轻松度量（此外，还可以将项目配置为导出度量，例如graphite）

一个例子看起来像

Flux<String> dataStream = Flux.just("AA", "BB", "CC", "DD");
dataStream.name("my-test-name").tag("key1", "value1").metrics().subscribe(p ->
   {
      System.out.println("Hello " + p);
      try {
         Thread.sleep(1000);
      } catch (InterruptedException e) {
         e.printStackTrace();
   }
});

然后在我的例子中，石墨中的指标是e.g.underapplication-name.magdalena.reactor.flow.duration.exception.flow.my-test-name.status.completed.type.Flux.p50 p50-是一半请求的延迟（或98%请求集的p98延迟）。谢谢他们在这个例子中的人工延迟，你可以观察到它们的值接近4000（处理了1s x 4个元素）。

石墨在应用中的配置：

management:
    metrics:
        export:
            graphite:
                enabled: true
                host: graphite-lhr10.something.com
                port: 2003
                protocol: plaintext

@定时注释对我也不起作用。