spring - 如何让微米普罗米修斯指标适用于 Flux？

Question

对于 Spring Framework 5.0.1.RELEASE 和 Spring Boot 2.0.0.M6 我们希望使用 micrometer application monitoring ，所以 wie 包括:

compile('org.springframework.boot:spring-boot-starter-actuator')
compile('io.micrometer:micrometer-registry-prometheus')

进入我们的依赖项集并创建一个具有以下剩余端点的 Controller :

@RestController
@Timed
public class MyController {

    @Autowired
    private MyService service;

    @RequestMapping(value = "/test", method = RequestMethod.GET)
    public void test() {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @RequestMapping(value = "/test/flux", method = RequestMethod.GET, produces = "application/stream+json")
    public Flux<MyItem> getMyItems(@RequestParam Map<String, String> params) {
        return this.service.getMyItems(params);
    }
}

因此，我们得到了只等待两秒钟的 /test 端点，并且得到了返回项目列表的 /test/flux 端点。

机器人请求工作。唯一的区别是，对于 /test 端点，我获得了 prometheus 指标，而对于 /test/flux 端点，我没有获得任何指标:

http_server_requests_duration_seconds_count{exception="None",method="GET",status="200",uri="/get/test",} 1.0
http_server_requests_duration_seconds_sum{exception="None",method="GET",status="200",uri="/get/test",} 2.002811046
http_server_requests_duration_seconds_max{exception="None",method="GET",status="200",uri="/get/test",} 0.0

我是否必须配置其他内容才能使其适用于返回 Flux 或尚不支持 Flux 的请求？

Answer 1

Boot 2 RC2 中包含 WebFlux 端点的自动配置!