Quarkus Reactive：如何替换Uni中getSingleResult的返回值？

问题核心原因 #

Mutiny的invoke()方法仅用于执行副作用操作（比如日志打印、资源清理），它不会修改流中传递的元素值。你在invoke里执行了解析逻辑，但原JSON字符串仍会沿着流传递，所以最终返回的还是原始字符串。

正确解决方案：用map()替换invoke()转换元素 #

要替换getSingleResult()返回的值，必须使用map()操作——它会接收流中的原始元素，处理后返回新元素，以此替换原有值。

代码示例对比 #

原错误代码（使用invoke）

PanacheQuery<String> query = yourRepository.find("SELECT json_agg(t) FROM YourTable t");
return query.singleResult()
        .invoke(jsonStr -> {
            // 此处解析操作无法改变流中的jsonStr
            ObjectMapper mapper = new ObjectMapper();
            List<Object> list = mapper.readValue(jsonStr, new TypeReference<List<Object>>() {});
        });

修改后的正确代码（使用map）

// 建议通过CDI注入ObjectMapper，避免重复初始化
@Inject
ObjectMapper mapper;

// ...

PanacheQuery<String> query = yourRepository.find("SELECT json_agg(t) FROM YourTable t");
return query.singleResult()
        .map(jsonStr -> {
            try {
                // 解析JSON字符串并返回新元素，替换原字符串
                return mapper.readValue(jsonStr, new TypeReference<List<Object>>() {});
            } catch (JsonProcessingException e) {
                // 转换为非检查型异常，或自定义异常处理逻辑
                throw new RuntimeException("JSON数组解析失败", e);
            }
        });

额外注意事项 #

• ObjectMapper的正确使用：在Quarkus中优先通过CDI注入ObjectMapper实例（框架默认提供），避免手动重复创建带来的性能和线程安全问题。
• 异常处理：readValue()抛出的检查型异常需要在map()中转为非检查型，或通过Uni.onFailure()统一捕获处理。
• 泛型类型安全：使用TypeReference<List<Object>>()可以避免Java泛型擦除导致Jackson解析类型错误。

内容的提问来源于stack exchange，提问作者Adobe