springwebflux中增加一个返回值处理器去实现自动封装结果集?

在Spring Webflux中，可以通过实现`org.springframework.web.reactive.result.view.View`接口来创建自定义的返回值处理器，进而实现自动封装结果集。

具体步骤如下：

1. 创建一个类实现`View`接口，并实现其中的方法。在`render`方法中，可以将控制器方法返回的数据封装成需要的格式，比如JSON格式，并将其写入响应体中。

import org.springframework.core.ResolvableType;
import org.springframework.http.MediaType;
import org.springframework.http.MediaTypeUtils;
import org.springframework.http.ReactiveHttpOutputMessage;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.http.server.reactive.ServerHttpResponseDecorator;
import org.springframework.web.reactive.result.view.AbstractView;
import org.springframework.web.reactive.result.view.View;
import reactor.core.publisher.Mono;

import java.util.HashMap;
import java.util.Map;

public class ResultView implements View {

    @Override
    public String getContentType() {
        return MediaType.APPLICATION_JSON_VALUE;
    }

    @Override
    public Mono<Void> render(Map<String, ?> model, MediaType contentType, ServerHttpRequest request, ServerHttpResponse response) {

        Object result = model.get("result");
        if (result == null) {
            result = new HashMap<>();
        }
        response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
        return response.writeWith(Mono.just(response.bufferFactory().wrap(result.toString().getBytes())));
    }
}

在这个例子中，我们创建了一个名为`ResultView`的类来实现`View`接口。在`render`方法中，我们从`model`中取出控制器方法返回的数据，将其封装成JSON格式，并写入响应体中。

2. 在Spring配置文件中配置该返回值处理器。可以通过`WebFluxConfigurer`来配置，如下所示：

import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.config.ViewResolverRegistry;
import org.springframework.web.reactive.config.WebFluxConfigurer;

@Configuration
public class WebConfig implements WebFluxConfigurer {

    @Override
    public void configureViewResolvers(ViewResolverRegistry registry) {
        registry.viewResolver(new ResultViewResolver());
    }
}

在这个例子中，我们创建了一个名为`ResultViewResolver`的类，将其注册到Spring Webflux中。

3. 在Controller中使用该返回值处理器。可以通过在控制器方法上添加`@ModelAttribute`注解来将返回值封装成一个模型对象，然后将该模型对象传递给视图解析器。

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

@RestController
public class MyController {

    @GetMapping("/my/path")
    public Mono<Map<String, Object>> handleRequest() {
        Map<String, Object> result = new HashMap<>();
        // 处理请求逻辑
        return Mono.just(result);
    }

    @ModelAttribute("result")
    public Mono<Map<String, Object>> getResult() {
        return handleRequest();
    }
}

在这个例子中，我们在控制器方法上添加了`@ModelAttribute`注解，将返回值封装成一个模型对象，并将其传递给视图解析器。在`getResult`方法中，我们调用了`handleRequest`方法来获取控制器方法的返回值。该返回值将在视图解析器中被封装成JSON格式，并写入响应体中。

通过这种方式，我们可以实现自动封装结果集，减少代码重复，提高开发效率。