自定义日志阅读器——包括了一个load取Tomcat日志的分析器

竹子开花的时

　　最近在写往公司产品里添加Tomcat适配器，以支持Tomcat。有一些功能需要摘取到Tomcat的部分日志。没有合适的工具，也不想去网上找了，就自己写了一个。
　　简单的画了一下设计方案：

　　
　　下面直接上代码了：
　　日志阅读器：





  1 package com.fjn.tools.log.reader;
  2
  3 import java.io.File;
  4 import java.util.LinkedList;
  5 import java.util.List;
  6 import java.util.Scanner;
  7
  8 import com.fjn.tools.log.reader.parser.CatalinaSimpleFormatterParser;
  9
10 public class LogReader {
11     private String logFile;
12     private List logFilterChain = new LinkedList();
13     private final ContinueRead continueRead = new ContinueRead();
14     private LogParser parser;
15     private final boolean doFilter(LogRecord record) {
16         for (LogFilter filter : logFilterChain) {
17             if (!filter.accept(record)) {
18                 return false;
19             }
20         }
21         return true;
22     }
23
24     public void addFilter(LogFilter filter) {
25         if(filter!=null){
26             logFilterChain.add(filter);
27         }
28     }
29
30     public final String readLogRecords(String startTime, String endTime) {
31         if (parser == null) {
32             return null;
33         }
34         StringBuilder buff = new StringBuilder();
35         Scanner scanner = null;
36         
37         try {
38             scanner = new Scanner(new File(logFile));
39            
40
41             NewLine newLine = null;
42             if (startTime != null) {
43                 StartTimeFilter filter = new StartTimeFilter();
44                 filter.startTime = startTime;
45                 addFilter(filter);
46             }
47             if (endTime != null) {
48                 EndTimeFilter filter = new EndTimeFilter();
49                 filter.endTime = endTime;
50                 filter.continueRead = this.continueRead;
51                 addFilter(filter);
52             }
53             while (scanner.hasNextLine() && continueRead.value) {
54                 LogRecord record = null;
55                 if (newLine == null) {
56                     newLine = new NewLine();
57                 }
58                 if (!newLine.hasGetNewLine) {
59                     newLine.line = scanner.nextLine();
60                     newLine.hasGetNewLine = true;
61                 }
62                 record = parser.getLogRecord(scanner, newLine, continueRead);
63                 if (record != null) {
64                     if (doFilter(record)) {
65                         buff.append(record.toString());
66                     }
67                 }
68             }
69         } catch (Exception ex) {
70             // Ignore it
71         } finally {
72             if (scanner != null) {
73                 scanner.close();
74             }
75         }
76         return buff.toString();
77     }
78
79     public static interface LogParser {
80         public LogRecord getLogRecord(Scanner scanner, NewLine newLine,
81                 ContinueRead continueRead);
82     }
83
84     public static interface LogFilter {
85         public boolean accept(LogRecord record);
86     }
87
88     public static abstract class LogRecord {
89         public String prefix;
90         public String message;
91         public String threadStack;
92         public String datetime;
93     }
94
95     public static class NewLine {
96         public boolean hasGetNewLine = false;
97         public String line = "";
98     }
99
100     public static class ContinueRead {
101         public boolean value = true;
102     }
103
104     private class StartTimeFilter implements LogFilter {
105         private String startTime;
106
107         @Override
108         public boolean accept(LogRecord record) {
109             if (startTime == null) {
110                 return true;
111             }
112
113             if (startTime.compareTo(record.datetime)