stream类如何读取json文件夹

Hey小伙伴们，今天要分享的是一个超级实用的小技巧，关于如何使用stream类来读取json文件夹，是不是听起来就很酷？那就跟着我一起往下看吧！

我们要明确一点，json是一种轻量级的数据交换格式，它易于人阅读和编写，同时也易于机器解析和生成，在编程的世界里，我们经常需要处理json数据，尤其是在处理API接口或者配置文件时，如何用stream类来读取这些数据呢？

什么是Stream类？

在Java中，Stream是一个接口，它允许我们以声明式方式处理数据集合，Stream操作可以分成两类：中间操作（如filter、map）和终止操作（如forEach、collect），在处理文件时，我们通常会用到Files类中的lines方法，它返回一个Stream<String>，让我们能够按行读取文件。

读取单个JSON文件

假设我们有一个名为data.json的文件，我们想要读取这个文件中的json数据，我们可以使用Files类的readAllBytes方法来读取整个文件的内容，然后使用new String将字节数组转换为字符串，最后使用json解析库（比如Jackson或Gson）来解析这个字符串。

import java.nio.file.Files;
import java.nio.file.Paths;
import java.io.IOException;
import com.fasterxml.jackson.databind.ObjectMapper;
public class JsonReader {
    public static void main(String[] args) {
        String path = "path/to/your/data.json";
        try {
            byte[] jsonData = Files.readAllBytes(Paths.get(path));
            String jsonStr = new String(jsonData);
            ObjectMapper mapper = new ObjectMapper();
            // 假设我们的json是一个对象
            YourObject obj = mapper.readValue(jsonStr, YourObject.class);
            // 接下来就可以使用obj对象了
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

读取整个JSON文件夹

如果你有一个文件夹，里面包含了多个json文件，你想要读取这些文件，那么就需要稍微复杂一点的操作了，我们可以遍历文件夹中的所有文件，然后对每个文件应用上面的方法。

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.stream.Stream;
public class JsonFolderReader {
    public static void main(String[] args) {
        String folderPath = "path/to/your/folder";
        try (Stream<Path> paths = Files.walk(Paths.get(folderPath))) {
            paths.filter(Files::isRegularFile)
                 .forEach(file -> {
                     try {
                         byte[] jsonData = Files.readAllBytes(file);
                         String jsonStr = new String(jsonData);
                         // 假设我们的json是一个对象
                         YourObject obj = new ObjectMapper().readValue(jsonStr, YourObject.class);
                         // 接下来就可以使用obj对象了
                     } catch (IOException e) {
                         e.printStackTrace();
                     }
                 });
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}