RestController中subscribe后如何返回ViewResponse响应对象？

你的代码存在两个核心问题：

1. 在Reactive控制器中使用subscribe()是错误的——subscribe()用于触发流的执行，但它的回调无法向控制器返回值，当前方法实际没有返回任何有效结果，会导致请求处理异常。
2. Redis查询返回的Mono<Object>需要通过Reactive操作符进行链式转换，才能生成最终要返回的Mono<ResponseEntity<ViewResponse>>。

修正后的代码 #

@RestController
@RequestMapping("/view")
public class ViewController {
    @GetMapping(value = "/{channelId}/**")
    public Mono<ResponseEntity<ViewResponse>> viewObject(@PathVariable(value = "channelId") String channelId) {
        // 链式调用Reactive操作符，直接返回处理后的Mono
        return redisController.getChannelData(channelInfoset, channelId)
                // 当Redis返回有效数据时，转换为成功响应
                .map(redisResponse -> {
                    // 这里根据实际情况，将redisResponse转换为ViewResponse
                    // 示例中直接构造ViewResponse，你需要根据Redis返回的数据结构调整
                    ViewResponse viewResponse = new ViewResponse("val", "1", false);
                    return new ResponseEntity<>(viewResponse, HttpStatus.OK);
                })
                // 当Redis未找到数据（Mono为空）时，返回500错误
                .switchIfEmpty(Mono.just(new ResponseEntity<>(null, HttpStatus.INTERNAL_SERVER_ERROR)));
    }
}

关键说明 #

• 避免使用subscribe()：在Spring WebFlux控制器中，只需返回Mono/Flux对象，框架会自动处理订阅和流的执行，无需手动调用subscribe()。
• map()操作符：用于同步转换Mono中的数据，把Redis返回的结果转换成对应的ResponseEntity。
• switchIfEmpty()：处理Redis查询无结果的场景（此时getChannelData返回的是一个空Mono，而非null），返回内部服务器错误响应。
• 类型转换：注意getChannelData返回的是Mono<Object>，你需要根据实际存储在Redis中的数据类型，将redisResponse转换为ViewResponse（比如反序列化JSON字符串、映射字段等）。

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