如何用Java 8 Stream读取文件并映射为MonitoredData对象

你已经完成了文件读取和行拆分的基础步骤，接下来只需要把拆分后的数组映射为MonitoredData对象，再收集成列表就可以实现需求了。下面是具体的实现方案和修改后的代码：

关键步骤说明 #

1. 给MonitoredData添加全参构造器：相比逐个调用setter，用全参构造器在Stream操作中创建对象会更简洁高效。
2. 完善Stream的映射逻辑：将每行拆分后的字符串数组，按索引对应赋值给MonitoredData的三个属性（索引0对应start_time、索引1对应end_time、索引2对应activity）。
3. 收集Stream为列表：使用Collectors.toList()把处理后的Stream转换为List<MonitoredData>。

修改后的完整代码 #

首先更新MonitoredData类，补充全参构造器和可选的getter方法（方便后续访问属性）：

import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.text.SimpleDateFormat;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class MonitoredData {
    private String start_time;
    private String end_time;
    private String activity;

    // 保留原无参构造器
    public MonitoredData(){}

    // 添加全参构造器，用于Stream中快速创建对象
    public MonitoredData(String start_time, String end_time, String activity) {
        this.start_time = start_time;
        this.end_time = end_time;
        this.activity = activity;
    }

    // 可选：添加getter方法，方便后续获取对象属性
    public String getStart_time() {
        return start_time;
    }

    public String getEnd_time() {
        return end_time;
    }

    public String getActivity() {
        return activity;
    }

    public List<MonitoredData> readFile(){
        String file = "Activities.txt";
        // 如果你后续需要将字符串转为Date类型，可以使用这个SimpleDateFormat，当前需求暂时用不到
        SimpleDateFormat sd = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        
        try (Stream<String> stream = Files.lines(Paths.get(file))) {
            return stream
                    .map(line -> line.split("\t"))
                    // 可选但建议：过滤格式错误的行，避免数组越界异常
                    .filter(parts -> parts.length == 3)
                    // 拆分后的数组元素转成MonitoredData对象，trim()去除字段前后可能的空白字符
                    .map(parts -> new MonitoredData(parts[0].trim(), parts[1].trim(), parts[2].trim()))
                    // 收集为MonitoredData对象列表
                    .collect(Collectors.toList());
        } catch (IOException e) {
            e.printStackTrace();
            // 异常场景返回空列表，也可以根据需求抛出异常
            return List.of();
        }
    }
}

额外提示 #

• 我添加了filter(parts -> parts.length == 3)来过滤格式不符合要求的行，避免出现ArrayIndexOutOfBoundsException，如果你的文件每行格式都严格合规，也可以去掉这一步。
• 调用trim()是为了清理字段前后可能存在的换行符残留或意外空格，让数据更整洁。
• 如果你之后需要把start_time和end_time从String转为Date类型，可以在map操作中用sd.parse(parts[0].trim())转换，记得处理ParseException（可以用try-catch包裹，或者将方法声明为抛出异常）。

内容的提问来源于stack exchange，提问作者Rares Macavei