如何使用spring webflux以反应式方式读取JSON文件？

Question

我试图使用spring webflux以一种被动的方式从类路径中读取文件。我能阅读文件。但是我不能解析成Foo对象。

我正在尝试以下方法，但不确定如何转换为FOO类。

public Flux<Object> readFile() {
    Flux<DataBuffer> readFile1 = DataBufferUtils.read("classpath:test.json", new DefaultDataBufferFactory(), 4096);
    return new Jackson2JsonDecoder().decode(readFile1,
        ResolvableType.forType(List.class,Foo.class), null, Collections.emptyMap());
    }

帮助赞赏。

Answer 1

您可以使用杰克逊ObjectMapper：

ObjectMapper mapper = new ObjectMapper();
Student student = mapper.readValue(jsonString, Student.class);

在此之前，您应该读取文件并使用FileReader和readLines（）逐行解析。

[更新]好的，对于读取文件，反应式意味着，读取流中的文件，并且每当读取一行时，处理此行。从这一点开始，BufferReader.readLines将会很好。但是如果你真的想使用反应式方式，你可以使用：

package com.test;

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.stream.Stream;

public class TestReadFile {

    public static void main(String args[]) {

        String fileName = "c://lines.txt";
        try (Stream<String> stream = Files.lines(Paths.get(fileName))) {
            stream.forEach(parseLine);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Answer 2

我认为您这样做是正确的，但不幸的是，您必须将Object转换回正确的类型。这是安全的，因为如果JSON解码无法构造Foo的列表，它将失败：

public Flux<Foo> readFile() {
  ResolvableType type = ResolvableType.forType(List.class,Foo.class);
  Flux<DataBuffer> data = DataBufferUtils.read("classpath:test.json", new DefaultDataBufferFactory(), 4096);
    return new Jackson2JsonDecoder().decode(data, type, null, null)
        .map(Foo.class::cast);
}