Spring Webflux-aop-如何获取请求/响应正文

Question

我正在使用SpringWebFlux创建RouterFunction和Handler。我的处理函数有@Aspect，如下所示，用于在数据库中存储ServerRequest body和ServerResponse body。但当我试图得到一个对象时，我的请求就被绞死了。是否有实现此功能的示例代码。

@Around("@annotation(Log")
public Object log(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
    Object o = proceedingJoinPoint.proceed();
    ServerRequest serverRequest = ServerRequest.class.cast(proceedingJoinPoint.getArgs()[0]);
    Mono<Customer> customerMono = serverRequest.bodyToMono(Customer.class);
    Customer customer = customerMono.block() //Request Hanged here
    log.info("customer" + customer);
    return o;
}

Answer 1

block（）。

从Mono中打印客户数据

customerMono.flatMap(customer -> System.out.println(customer)); // longhand form
customerMono.flatMap(System.out::println); // shorthand form of the above