最近，我想從輸出日志中提取某些數據。 這是日志文件的一部分：

2015-01-06 11:33:03 b.s.d.task [INFO] Emitting: eVentToRequestsBolt __ack_ack [-6722594615019711369 -1335723027906100557] 2015-01-06 11:33:03 c.s.p.d.PackagesProvider [INFO] ===---> Loaded package com.foo.bar 2015-01-06 11:33:04 b.s.d.executor [INFO] Processing received message source: eventToManageBolt:2, stream: __ack_ack, id: {}, [-6722594615019711369 -1335723027906100557] 2015-01-06 11:33:04 c.s.p.d.PackagesProvider [INFO] ===---> Loaded package co.il.boo 2015-01-06 11:33:04 c.s.p.d.PackagesProvider [INFO] ===---> Loaded package dot.org.biz

我決定使用Java8 Stream和Lambda Expression功能來實現。

讀取文件

首先，我需要讀取日志文件并將這些行放入Stream中：

Stream<String> lines = Files.lines(Paths.get(args[1]));

過濾相關行

我需要獲取軟件包名稱并將其寫入另一個文件。 并非所有行都包含我需要的數據，因此僅過濾相關行。

lines.filter(line -> line.contains("===---> Loaded package"))

解析相關行

然后，我需要解析相關行。 我首先將每一行拆分為一個字符串數組，然后采用該數組中的最后一個元素來完成此操作。 換句話說，我做了一個雙重映射 。 首先是數組的一行，然后是字符串的數組。

.map(line -> line.split(" ")) .map(arr -> arr[arr.length - 1])

寫入輸出文件

最后一部分是獲取每個字符串并將其寫入文件。 那是終端操作。

.forEach(package -> writeToFile(fw, package));

writeToFile是我創建的方法。 原因是Java文件系統拋出IOException。 您不能在lambda表達式中使用檢查的異常。

這是一個完整的示例（注意，我不檢查輸入）

import java.io.FileWriter; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Paths; import java.util.Arrays; import java.util.List; import java.util.stream.Stream;public class App {public static void main(String[] args) throws IOException {Stream<String> lines = null;if (args.length == 2) {lines = Files.lines(Paths.get(args[1]));} else {String s1 = "2015-01-06 11:33:03 b.s.d.task [INFO] Emitting: adEventToRequestsBolt __ack_ack [-6722594615019711369 -1335723027906100557]";String s2 = "2015-01-06 11:33:03 b.s.d.executor [INFO] Processing received message source: eventToManageBolt:2, stream: __ack_ack, id: {}, [-6722594615019711369 -1335723027906100557]";String s3 = "2015-01-06 11:33:04 c.s.p.d.PackagesProvider [INFO] ===---> Loaded package com.foo.bar";String s4 = "2015-01-06 11:33:04 c.s.p.d.PackagesProvider [INFO] ===---> Loaded package co.il.boo";String s5 = "2015-01-06 11:33:04 c.s.p.d.PackagesProvider [INFO] ===---> Loaded package dot.org.biz";List<String> rows = Arrays.asList(s1, s2, s3, s4, s5);lines = rows.stream();}new App().parse(lines, args[0]);}private void parse(Stream<String> lines, String output) throws IOException {final FileWriter fw = new FileWriter(output);//@formatter:offlines.filter(line -> line.contains("===---> Loaded package")).map(line -> line.split(" ")).map(arr -> arr[arr.length - 1]).forEach(package -> writeToFile(fw, package));//@formatter:onfw.close();lines.close();}private void writeToFile(FileWriter fw, String package) {try {fw.write(String.format("%s%n", package));} catch (IOException e) {throw new RuntimeException(e);}}}

翻譯自: https://www.javacodegeeks.com/2015/01/java-8-stream-and-lambda-expressions-parsing-file-example.html

總結

以上是生活随笔為你收集整理的Java 8流和Lambda表达式–解析文件示例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。