java 8 i/o 流应用程序

Question

我在下面有一个 CSV 文件，我编写了下面的方法来解析该文件。

"PRODUCT_NAME","PRODUCT_CATEGORY","SALES_PRICE"
"Hair Gel","Beauty",6.99 
"Scotch tape","Office Supply",2.99
"Office Chair","Office Supply",134.99

我的代码:

public static void ReadFile(String path, Map<String, List<Double>> db){
    try(BufferedReader br = new BufferedReader(new FileReader(path))){
        String line;
        if((line = br.readLine()) != null){
            //this line is the heading..and needed to be skipped
        }
        while ((line = br.readLine()) != null) {
            String[] keys = line.split(",");
            keys[1] = keys[1].replace("\"", "");
            if(db.containsKey(keys[1])){
                List<Double> list = db.get(keys[1]);
                list.add(Double.valueOf(keys[2]));
                db.put(keys[1], list);
            }
            else{
                List<Double> list = new ArrayList<>();
                list.add(Double.valueOf(keys[2]));
                db.put(keys[1],list);
            }
        }

    }catch(IOException e){}
}

它在解析文件时工作正常，但我的主要问题是如何利用 java8 流和 lambda 功能编写上述方法？

Answer 1

您可以使用 Files.lines(path) 在文件的行上检索流(你可以用 Path 得到一个 Paths.get )。使用 skip(1) 跳过标题行, 然后每行围绕 "," 拆分.

最后，Stream 元素按键的第一个元素分组(删除引号)并将值映射到 Double键的第二个元素的值并收集到 List 中.组操作是用 groupingBy(classifier, downstream) 完成的collector:classifier是一个方法，返回key给group by，下游collector收集所有分组到同一个key的Stream元素；在这种情况下，对于具有相同键的值，我们希望将 Stream 元素映射到 Double值 ( mapping ) 并收集那些 Double进入 List ( toList() )。

您设计中的问题是您的方法采用了 Map<String, List<Double>> db作为参数并在最好让方法返回它时对其进行变异。

public static Map<String, List<Double>> readFile(String path) throws IOException {
    try (Stream<String> stream = Files.lines(Paths.get(path))) {
        return stream.skip(1)
                  .map(l -> l.split(","))
                  .collect(Collectors.groupingBy(
                    keys -> keys[1].replace("\"", ""),
                    Collectors.mapping(keys -> Double.valueOf(keys[2]), Collectors.toList())
                  ));
    }
}

请注意，我还修改了您的代码，让它抛出 IOException而不是捕获它什么都不做。如果您想在方法本身中处理该异常，您仍然可以添加 catch 部分。