Spring WebFlux过滤器在请求对象反序列化之后拦截请求

Question

@GetMapping(path = "/search")
Mono<ItemCollection> getItems(SearchRequest searchRequest);

@PostMapping(value = "/search", consumes = MediaType.APPLICATION_JSON_VALUE)
Mono<ItemCollecthtml" target="_blank">ion> getItemsPost(@RequestBody SearchRequest searchRequest);

public class SearchRequest {

    private Fields fields;
    ...
}

public class Fields {

    private Set<String> include;
    private Set<String> exclude;
    ...
}

对于HTTP POST请求，用户可以简单地提交一个遵循此结构的JSON对象。对于HTTP GET请求，我所使用的API规范允许您简单地提供fieldsURL参数，该参数包含一个前缀为“+”或“-”的字段名数组。我创建了一个类，它扩展PropertyEditorSupport，以解析URL参数并填充Fields对象的包含和排除集。这是在我的控制器中使用@initbinder配置的：

@InitBinder
public void initBinder(WebDataBinder binder) {
    binder.registerCustomEditor(Fields.class, "fields", fieldsPropertyEditor);
}

我的SearchRequest对象支持使用Bbox值或Intersects值进行地理空间查询，但是如果两者都指定，则需要返回400。我尝试了以下方法来实现此验证，但找不到我正在寻找的解决方案：

1. 使用WebDataBinder为未指定字段的SearchRequest类注册另一个自定义编辑器。
2. 用WebDataBinder注册验证器（都使用SetValidator和AddValidator方法）。
3. 实现WebFilter.

解决方案1似乎没有效果。从不调用编辑器。在解决方案2中，每个请求都会调用supports方法，但从不调用validate方法。解决方案3可以工作，但需要我编写两组逻辑--一组用于GET，一组用于POST，因为GET URL参数与POST请求体分开存储。此外，为了实际检查请求正文，exchange.getrequest.getbody()返回一个databuffer，该databuffer可用于将正文反序列化为对象，但是如果没有前面提到的属性编辑器（用于GET请求），我不能直接反序列化为searchrequest。

我真的希望找到某种过滤器/转换器/转换器，在请求被反序列化为SearchRequest对象之后，但在控制器处理程序方法被调用之前，我可以调用这种过滤器/转换器/转换器，但我似乎找不到这样做的方法。

有人能告诉我这是否可能，或者我唯一的选择是在Webfilter中单独处理GET/POST请求吗？

Answer 1

这不是我要找的答案，但至少现在看来行得通。基本上，我只是创建了一个自定义验证器，并用@valid注释了控制器方法中的SearchRequest参数。

注释：

@Target({ElementType.TYPE, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Constraint(validatedBy = SingleGeometryValidator.class)
@Documented
public @interface SingleGeometry {
    String message () default "Request should not contain both `intersects` and `bbox`. Please choose one geometry to "
            + "search by.";
    Class<?>[] groups () default {};
    Class<? extends Payload>[] payload () default {};
}

验证器：

public class SingleGeometryValidator implements ConstraintValidator<SingleGeometry, SearchRequest> {

    @Override
    public boolean isValid(SearchRequest searchRequest, ConstraintValidatorContext constraintValidatorContext) {
        return !(searchRequest.getBbox() != null && searchRequest.getIntersects() != null);
    }
}

@Data
@SingleGeometry
public class SearchRequest {
...
}

@GetMapping(path = "/search")
Mono<ItemCollection> getItems(@Valid SearchRequest searchRequest);

@PostMapping(value = "/search", consumes = MediaType.APPLICATION_JSON_VALUE)
Mono<ItemCollection> getItemsPost(@Valid @RequestBody SearchRequest searchRequest);