问题描述
当我在处理 QUarkus 应用程序时,我试图返回 Uni,但它给了我错误:
@GET
@javax.ws.rs.Path("/notification/typeCount")
@Produces({MediaType.APPLICATION_JSON,MediaType.TEXT_PLAIN})
public Uni<Response> getNoti(){
return Uni.createFrom().item(getAllCount()).onItem().transform(f -> f != null ? Response.ok(f) : Response.ok(null))
.onItem().transform(ResponseBuilder::build);
}
public Uni<Object> getAllCount() {
try{
sql="my query";
return client.query(sql).execute().onItem().transform(pgRowSet -> {
Map<String,Object> l = CUtils.mapLogic(pgRowSet);
return l;
});
}
catch(Exception e){
return null;
}
}
RESTEASY002020:未处理的异步异常,发回 500:com.fasterxml.jackson.databind.exc.InvalidDeFinitionException:未找到类 io.smallrye.mutiny.context.ContextPropagationUniInterceptor$2 的序列化程序,也未发现任何属性 创建 BeanSerializer(为了避免异常,禁用 SerializationFeature.FAIL_ON_EMPTY_BEANS)
请告诉我如何解决它。
我找到了一种方法,但如果我更改以下几行,我认为它不合适:
来自:
return Uni.createFrom().item(getAllCount()).onItem().transform(f -> f != null ? Response.ok(f) : Response.ok(null))
.onItem().transform(ResponseBuilder::build);
致:
return Uni.createFrom().item(getAllCount()).onItem().transform(f -> f != null ? Response.ok(f.await().indefinitely()) : Response.ok(null))
.onItem().transform(ResponseBuilder::build);
它会起作用。因此,如果我添加“f.await().infinitely()”,它会起作用,我的问题是它仍然是反应性的吗?
解决方法
如果您使用的是传统 RESTEasy,请确保您的项目中有 quarkus-resteasy-mutiny 扩展,如 https://quarkus.io/guides/getting-started-reactive 所示。
如果您使用的是 RESTEasy Reactive,它应该可以 OOTB。