java如何将测微计计时器与webflux端点一起使用

Question

有没有简单的方法将测微计计时器与Webflux控制器结合使用

似乎@Timed只适用于非反应性方法。对于反应性，它记录的时间值非常低

我发现了一个类似的问题：How to use Micrometer Timer to record duration of async method (returns Mono or Flux)但对于这样一个常见的问题来说，答案太复杂了

有什么想法吗

Answer 1

如果您想测量Web流量方法/调用的时间，那么可以直接使用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();
   }
});

那么在我的例子中，graphite中的度量是在应用程序名下。玛格达莱娜反应堆。流期间例外流我的测试名。地位完整的。类型通量p50 p50-是一半请求的延迟（或请求集C的98%的p98延迟）。感谢他们在本例中的人工延迟，您可以观察到他们的值接近4000（处理了1s x 4个元素）

应用程序中的配置。yml代表石墨：

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

@Timed注释对我来说也不起作用