如何使用Spring WebClient将嵌套JSON数组反序列化为Flux？

Question

我在Spring Boot（2.0.0. M1）应用程序中使用org.springframework.web.reactive.function.client.WebClient来查询返回嵌套数组的REST接口：

[
    [ "name1", 2331.0, 2323.3 ],
    [ "name2", 2833.3, 3838.2 ]
]

我现在尝试将此响应映射到对象的Flux。为此，我进行了以下调用：

WebClient webClient = WebClient.create("http://example.org");

Flux<Result> results = webClient.get().uri("/query").
    accept(MediaType.APPLICATION_JSON_UTF8).
    exchange().
    flatMapMany(response -> response.bodyToFlux(Result.class));

Result类看起来像这样：

import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.Data;

import java.math.BigDecimal;

@Data
@JsonFormat(shape = JsonFormat.Shape.ARRAY)
public class Result {

    private final String name;
    private final BigDecimal value1;
    private final BigDecimal value2;

    @JsonCreator
    public Result(
        @JsonProperty String name,
        @JsonProperty BigDecimal value1,
        @JsonProperty BigDecimal value2) {
        this.name = name;
        this.value1 = value1;
        this.value2 = value2;
    }
}

不幸的是，我出现以下错误：

org.springframework.web.reactive.function.UnsupportedMediaTypeException: Content type 'application/json;charset=utf-8' not supported

有谁能告诉我我做错了什么，或者告诉我一种更好的方法来将这种响应反序列化为流量，最好是以非阻塞的方式？

Answer 1

该问题与通量无关。

Jackson根本无法反序列化您的json对象，并且可能无法使用不同值的数组执行public Result（@JsonProperty String name，@JsonProperty BigDecimal value e1，@JsonProperty BigDecimal value e2）。

最简单的解决方法是使用下一个构造函数实现。

@JsonCreator
public Result(Object[] args) {
     this.name = String.valueOf(args[0]);
     this.value1 = new BigDecimal(String.valueOf(args[1]));
     this.value2 = new BigDecimal(String.valueOf(args[2]));
}