如何发送URL编码的数据在SpringWebFluers

Question

我正在编写一个Spring5Web应用程序，我的要求是获得一个url编码的表单，并将url编码的响应发送回来

这是路由器功能代码

@Configuration
public class AppRoute {

  @Bean
  public RouterFunction<ServerResponse> route(FormHandler formHandler) {

    return RouterFunctions.route()
           // .GET("/form", formHandler::sampleForm)
           // .POST("/form", accept(MediaType.APPLICATION_FORM_URLENCODED), formHandler::displayFormData)
            .POST("/formnew", accept(MediaType.APPLICATION_FORM_URLENCODED).and(contentType(MediaType.APPLICATION_FORM_URLENCODED)), formHandler::newForm)
            .build();
  }
}

这是我的处理程序代码

public Mono<ServerResponse> newForm(ServerRequest request) {
    Mono<MultiValueMap<String, String>> formData = request.formData();
    MultiValueMap<String, String> newFormData = new LinkedMultiValueMap<String, String>();

    formData.subscribe(p -> newFormData.putAll(p));
    newFormData.add("status", "success");

    return ServerResponse.ok().contentType(MediaType.APPLICATION_FORM_URLENCODED)
            .body(fromObject(newFormData));
}

这是我得到的错误

2020-04-07 02:37:33.329调试38688---[ctor-http-nio-3]组织。springframework。网状物HttpLogging:[07467aa5]已解决HTTP POST/formnew的[UnsupportedMediaTypeException:bodyType=org.springframework.util.LinkedMultiValueMap]不支持的内容类型'application/x-www-form-urlencoded'

这里有什么问题。我找不到任何方法写回url编码的响应。谁能指出问题所在吗。

Answer 1

尝试将代码重构为功能风格：

public Mono<ServerResponse> newForm(ServerRequest request) {
    Mono<DataBuffer> resultMono = request.formData()
        .map(formData -> new LinkedMultiValueMap(formData))
        .doOnNext(newFormData -> newFormData.add("status", "success"))
        .map(linkedMultiValueMap -> createBody(linkedMultiValueMap));

    return ServerResponse.ok().contentType(MediaType.APPLICATION_FORM_URLENCODED)
        .body(BodyInserters.fromDataBuffers(resultMono));


}

private DataBuffer createBody(MultiValueMap multiValueMap) {
    try {
        DefaultDataBufferFactory factory = new DefaultDataBufferFactory();
        return factory.wrap(ByteBuffer.wrap(objectMapper.writeValueAsString(multiValueMap).getBytes(StandardCharsets.UTF_8)));
    } catch (JsonProcessingException e) {
        throw new IllegalArgumentException("incorrect body");
    }
}