如何将Uni转换为<Response>json，然后在@interceptor中打印

Question

我有一个简单的资源，它返回一个Uni<响应>

@POST
@Path("/test2")
public Uni<Response> test2(SampleEntity test) {
List<SampleEntity> recordList = new ArrayList<>();
recordList.add(new SampleEntity("cat", 12));
recordList.add(new SampleEntity("dog", 14));
return Uni.createFrom().item(Response.ok(recordList).build());
}

我有一个示例拦截器，用于将请求/响应记录为json

@AroundInvoke
public Object resourceLog(InvocationContext context) throws Exception {
timer.restart();
log.info(StrUtil.format("request->[{}]", JSONUtil.toJsonStr(context.getParameters())));
Object response = context.proceed();
log.info(StrUtil.format("response->[{}]", response));
return response;
}

当我发送json请求时：

{
"name": "cat",
"age": 12
}

打印出来的日志是：

2021-04-09 10:29:34,529 INFO  [cof.gei.int.ResourceInterceptor] (vert.x-eventloop-thread-4) request->[[{"name":"cat","age":12}]]
2021-04-09 10:29:34,529 INFO  [cof.gei.int.ResourceInterceptor] (vert.x-eventloop-thread-4) response->[io.smallrye.mutiny.operators.uni.builders.UniCreateFromKnownItem@a0122dd]

我想问的问题是：如何在拦截器拦截到Uni<响应>

这是我目前的解决方案：

Object response = context.proceed();
if(response instanceof Uni uni) {
uni.subscribe().with(body -> log.info(StrUtil.format("response->Uni:[{}]", JSONUtil.toJsonStr(body))));
}else {
log.info(StrUtil.format("response->[{}]", JSONUtil.toJsonStr(response)));
}

但我觉得它很难看。

Answer 1

最好的方法是不使用CDI拦截器，而是使用JAX-RSContainerResponseFilter。

它看起来像：

@Provider
public class YourFilter implements ContainerResponseFilter {
@Override
public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
throws IOException {
Object entity = responseContext.getEntity(); // this will contain the body of the response
// print it
}
}