截取log中耗时超过三秒的方法的RequestId和耗时，并按耗时降序排序把结果输出到文件

野性酷女 2024-04-17 18:54 25阅读 0赞

第一种:java IO流

public class ReadLog  throw Exception\{

Hash<String,Integer> resultMap =new HashMap<>();  
//要读取的log文件  
File fileRead =new File("D:\\log-1.log");

BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(fileRead),"UTF-8"));  
//把ETL的结果输出到这个文件  
File fileWrite = new File("D:\\out.txt");  
//加true,意思是追加数据，默认不加是覆盖  
BufferWriter writer = new BufferWriter(new OutputStreamWriter(new FileOutputStream(fileWrite,true),"UTF-8"));

String s = "";  
while((s = bf.readLine()) != null)\{  
 //截取requestId  
 String  requestId = "";  
 int begin = s.indexOf("\[RequestId-")+11;//\[RequestId-有十一个字符串  
 int end = s.indexOf("\] INFO");  
 if(end>begin)\{//为了防止下标越界  
  requestId = s.substring(begin,end);//substring是包前不包后  
 \}  
   
 //截取time  
 int b = s.indexOf("cost time=");  
 int timeBegin =  b + 10;;  
 int timeEnd = s.indexOf("ms-----");  
 if(b>0&&timeEnd>0&&timeEnd>timeBegin)\{  
    time = Integer.parseInt(s.substring(timeBegin,timeEnd).trim());  
 \}  
 //把运行时间大于3秒的方法的requestId，和对应的耗时组成map  
 if(time>3000)\{  
  resultMap .put(requestId,time);  
 \}  
   
 //  
 if(null != resultMap &&resultMap .size>0)\{  
   //排序后用这个sortmap接收，一定要是LinkedHashMap,否则排序不起作用  
   Map<String,Integer> sortMap =new LinkedHashMap<>();  
   //用Lambda排序  
   resultMap .entrySet().stream()  
      .sorted((o1,o2)->o2.getValue().compareTo(o1.getValue()))  
      .forEach(entry->sortMap.put(entry.getKey(),entry.getValue()));  
   //遍历写出  
   for(Map,Entry<String,Integer> m:sortMap.entrySet())\{  
    writer.write(m.getKey()+":"+m.getValue()+"\\r\\n");  
   \}  
     
 \}  
 br.close();  
 bw.close();  
   
\}

第二种方法：google的jar包

import com.google.common.io.Files;  
import com.google.common.io.LineProcessor;  
import java.io.File;  
import java.io.IOException;  
import java.nio.charset.Charset;  
import java.util.\*;

public class ReadLog\{  
 private static final int threshold = 3000;  
   
 public static void main(String\[\] args) throws IOException\{  
  Map<String,Integer> logs = Files.asCharSource(new File("D://","log.TXT"),  
  Charset.defaultCharset())readLines(new LineProcessor<Map<String,Integer>>())\{  
   Map<String,Integer> map = new HashMap<>();  
   @Override  
   public boolean processLine(String s)\{  
    //提取Request-Id  
    int requestIdBeginInd = s.indexOf("\[RequestId-")+11;  
    String rowStr = s.substring(requestIdBeginInd);  
    String requestId = rowStr.substring(0,rowStr.indexOf("\]"));  
    //耗时  
    int costTimeBeginInd = rowStr.indexOf("cost time=")+10;  
    int costTimeEndInd = rowStr.indexOf("ms----");  
    int costTime = Integer.parseInt(rowStr.substring(costTimeBeginInd,costTimeEndInd).trim());  
    if(costTime > threshold)\{  
     map.put(requestId,costTime);  
    \}  
    return true;  
   \}  
     
   @Override  
   public Map<String,Integer> getResult()\{  
    Map<String,Integer> sortedMap = new LinkedHashMap<>();  
    List<Map.Entry<String,Integer>> entryList = new ArrayList<>(map.entrySet);  
    entryList.sort((o1,o2)->o2.getValue()-o1.getValue());  
    entryList.forEach(entry ->sortedMap.put(entry.getKey(),entry.getValue()));  
    return sortedMap;  
   \}  
  \});  
  System.out.println(logs);  
 \}  
\}