Stream-Java 8を使用してファイル内のテキストを置き換えます。

Question

特定の部分文字列を含むすべての行をテキストファイル内の別の文字列に置き換えるAPIを作成しようとしています。

私は与えられたパターンが含まれている行をフィルタリングするには、Java 8のストリームを使用しています。ファイル書き込み部分に問題があります。上記のコード

Files.lines(targetFile).filter(line -> line.contains(plainTextPattern)).parallel() 
     .map(line-> line.replaceAll(plainTextPattern, replaceWith)).parallel(); 

は、ファイルの行単位で読み込み、パターンと一致する行をフィルタリングし、所与の文字列に置き換え、置き換えのみのラインを持っている文字列の流れをバック与えます。

これらの行をファイルに書き戻す必要があります。パイプラインが終了すると、我々は、ストリームを失うので、私は、パイプラインに以下を追加：

.forEach(line -> { 
try { 
      Files.write(targetFile, line.toString().getBytes()); 
} catch (IOException e) { 
    e.printStackTrace(); 
} 

私はそれがファイルのみ変更された（それがパイプラインにあるので）ラインに書き込み、他を続けるだろう期待していた

手つかずの線。

しかし、ファイル内の各行のファイルを切り捨て、最後に処理ラインを保つように見えるし、パイプラインで一致しなかったすべての行を削除します。

ストリームを使用してファイルを処理する方法がありますか？

Answer 1

は、ストリームから、フィルタに一致しないものを排除します。 （また、それは価値がある何のために、A）あなたは一度だけparallelを使用する必要があること、b）parallelは、c）それはあなたがするまでparallelを使用することがほとんどない良いアイデアません、I/Oのソースからのストリーム上でその効果的ではありません実際には非平行になっていて、遅すぎると感じました）

これは、replaceAllを実行しようとすると、パターンに一致する行を除外する必要はありません。あなたのコードは次のようになりますから、

try (Stream<String> lines = Files.lines(targetFile)) { 
    List<String> replaced = lines 
     .map(line-> line.replaceAll(plainTextPattern, replaceWith)) 
     .collect(Collectors.toList()); 
    Files.write(targetFile, replaced); 
} 

Answer 2

このファイルがどのように動作するかではないことを教えてくれてとても申し訳ありません。ファイルの途中に書き込む場合は、RandomAccessが必要です。 FilePointerを取得し、そのポインタを探し、そこから書き込みます。

あなたは、書き込みは、あなたが上書きしたいデータのサイズと同じであるデータのサイズたい場合に成立します。そうでない場合は、ファイルの末尾を一時バッファにコピーし、書き込むテキストに追加する必要があります。

btw、parallelStreamsをIOにバインドしたタスクは、しばしば悪い考えです。 filterを使用して