Javaキャッシュパイプフロー(BufferedReader)行ごとにファイルを読み込む
4440 ワード
入力ファイル
POM.xml
コード#コード#
パッケージ実行パッケージ 実行
/home/jerry/304.log
POM.xml
4.0.0
com.geo.cn
DASink
1.0
jar
maven-assembly-plugin
false
jar-with-dependencies
com.geo.cn.pojo.Test
make-assembly
package
assembly
org.apache.maven.plugins
maven-compiler-plugin
3.1
1.8
1.8
UTF-8
コード#コード#
package com.geo.cn.pojo;
import java.io.*;
public class Test {
public static void main(String[] args) {
BufferedReader bf_read = null;
BufferedWriter bf_write = null;
try {
//BufferedReader bf = new BufferedReader(new FileReader(args[0]));
bf_read = new BufferedReader(new InputStreamReader(new FileInputStream("/home/jerry/304.log")));
bf_write = new BufferedWriter(new OutputStreamWriter(new FileOutputStream("/home/jerry/indx304.log")));
String str;
try {
while ((str = bf_read.readLine()) !=null){
//System.out.println(" "+str.split("\t").length);
//System.out.println(str.split("\t"));
if(!"".equals(str) && null != str.split("\t",-1)[11] && !"".equals(str.split("\t",-1)[11] )){
str = str.replace(" : (null, ","");
//String [] res = str.split("\t",-1);
//System.out.println("=============== "+res[11]);
//System.out.println("$$$$$$$$$$$$$$$$$$$$"+str);
int indexFlag = str.indexOf(")");
str = str.substring(0,indexFlag);
System.out.println("----------------"+str);
bf_write.write(str);
bf_write.newLine();
}else{
System.out.println("########### "+str);
}
}
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
bf_read.close();
} catch (IOException e) {
e.printStackTrace();
}
try {
bf_write.close();
} catch (IOException e) {
e.printStackTrace();
}
}
} catch (FileNotFoundException e) {
e.printStackTrace();
}
}
}
パッケージ実行
mvn package
( ):/home/jerry/304.log
java -jar Test.jar /home/jerry/304.log