webflux Mono响应为空

Question

我的项目中有一个非常简单的SpringWebFlux restendpoint。

@Bean
public RouterFunction authRoute() {
    return RouterFunctions.route(POST("/auth/signin").and(accept(APPLICATION_JSON)), this::signIn)
            .andRoute(POST("/auth/signup").and(accept(APPLICATION_JSON)), this::signUp)
            .andRoute(POST("/auth/test").and(accept(APPLICATION_JSON)), this::test);
}

endpoint只需使用提供的用户名回复即可。

public Mono<ServerResponse> test(ServerRequest request) {
    System.out.println("Start test ");
    Mono<JwtRequest> jwtRequestMono = request.bodyToMono(JwtRequest.class);
    jwtRequestMono.subscribe(v -> System.out.println(v.getUsername() + ":" + v.getPassword()));
    return jwtRequestMono
            .flatMap(j -> ServerResponse.ok().contentType(APPLICATION_JSON).bodyValue(j.getUsername()));
}

我面临的问题是响应体是空的，应该是用户名，我还验证了当我返回硬编码字符串时，它通过了，当我依赖jwtRequest estMono.flatMap（...

Answer 1

这句话几乎可以肯定是你的垮台：

jwtRequestMono.subscribe(v -> System.out.println(v.getUsername() + ":" + v.getPassword()));

您的请求不能被多次订阅-因此您在这一行上订阅它（按预期工作并打印出值），然后框架订阅它，它就会崩溃。我希望在默认情况下看到一个异常，并返回500个响应，所以很可能您在某个地方吞下了一个异常。

切勿在自己的应用程序中订阅。这就是框架的工作。

相反，如果您想在值输入时打印它们的“副作用”，请使用doOnNext（）作为反应链的一部分：

return jwtRequestMono
        .doOnNext(v -> System.out.println(v.getUsername() + ":" + v.getPassword()))
        .flatMap(j -> ServerResponse.ok().contentType(APPLICATION_JSON).bodyValue(j.getUsername()));