JAVA解析服务器日志
????? 最近做项目有个功能是需要统计各服务器使用情况，因此写一个方法并计算Used值（本文仅统计了以“G”结尾的Used的值），服务器日志内容如图所示：
?
????? 其核心代码就是，解析服务器日志的java类--AnalysisLog.java，代码如下：
?
package com.fz.cloudsync.business.sns;
?
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import com.funambol.util.TimeUtil;
import com.opensymphony.xwork2.util.logging.Logger;
import com.opensymphony.xwork2.util.logging.LoggerFactory;
?
public class AnalysisLog {
?
?private Logger log = LoggerFactory.getLogger(AnalysisLog.class);
?
?public int storageUsed = 0;//定义了一个全局变量，方便其他类直接使用
?
?//解析日志
?public List<String> parserLog(String dir){
??List<String> comList = new ArrayList<String>();
??List<String> fileList = getLogFileByScanFolder(dir);
??if(fileList==null){return null;}
??
??for (int i = 0; i < fileList.size(); i++) {
???String log_file = fileList.get(i);
???boolean isFlag = checkLogTime(log_file);
???if (isFlag) {
????File file = new File(log_file);
????try {
?????List<String> logList = new ArrayList<String>();// 存储日志内容
?????FileReader fr = new FileReader(file);
?????BufferedReader br = new BufferedReader(fr);
?????String line = null;
?????while ((line = br.readLine()) != null) {
??????logList.add(line);
?????}
?
?????for (int j = 0; j < logList.size(); j++) {
??????if (j == 0) {
???????logList.remove(0);
??????}
??????for (int k = 0; k < logList.size(); k++) {
???????if (j == k) {
????????String log_data = logList.get(k);
????????String usedVlaue = appointField(log_data);// Used值
????????if (usedVlaue.endsWith("G")) {
?????????comList.add(usedVlaue);
????????}
???????}
??????}
?????}
?????br.close();
?????fr.close();
????} catch (Exception e) {
?????e.printStackTrace();
????}
???}
??}
??
??countUsedValue(comList);// 调用readLogData()并计算Used值
??
??return comList;
?}
?
?//计算Used的使用值
?public void countUsedValue(List<String> comList){
??List<String> usedList = new ArrayList<String>();
??List<String> dataList = comList;//日志内容
??
??for (int i = 0; i < dataList.size(); i++) {
???String usedGV = dataList.get(i);
???if(usedGV.endsWith("G")){
????double usedValue = Double.valueOf(usedGV.substring(0, usedGV.lastIndexOf("G")).toString());
????usedList.add(String.valueOf(usedValue));
???}
??}
??double usedVlaue_sum = 0,usedVlaue=0;
??for (int i = 0; i < usedList.size(); i++) {
???usedVlaue = Double.valueOf(usedList.get(i));
???usedVlaue_sum +=usedVlaue;
??}
??int used = Integer.valueOf(String.valueOf(Math.round(usedVlaue_sum)));
??storageUsed = used;
???? log.info("disk has used：" + storageUsed + "G");
?}
?
?// 去除空格，获取Used值
?public String appointField(String field) {
??String used = "";
??String[] str = field.split("\\s{1,}");
??for (int i = 0; i < str.length; i++) {
???if (i == 2) {
????used = str[i];//获取Used
???}
??}
??return used;
?}
?
?// 检查前一天日志文件存在与否（日志文件名中有时间段）
?public boolean checkLogTime(String logFile) {
??SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
??String yesterday = sdf.format(TimeUtil.getBefore(new Date(), 1));
??String vorgestern? = sdf.format(TimeUtil.getBefore(TimeUtil.getDateOfStart(new Date()), 2));
??
??String[] str = logFile.split("_");
??String logtime = "";// 日志时间戳
??for (int i = 0; i < str.length; i++) {
???if(i==1){
????logtime = str[i];
???}
??}
??if(yesterday.equals(logtime)){
???return true;
??}
??//删除前天或以前的日志文件
??if(vorgestern.compareTo(logtime)>=0){
???deleteLogFile(logFile);//调用deleteLogFile()方法删除日志
??}
??
??return false;
?}
?
?//检查文件夹存在与否
?public boolean checkFolderIsExists(String dir){
??File folder = new File(dir);
??if (folder.getParentFile() == null) {
???log.info("ParentFile is not exists!");
???return false;
??}else{
???if(!folder.getParentFile().exists()){
????folder.getParentFile().mkdir();
????checkFolderIsExists(dir);
????return true;
???}else{
????folder.mkdir();
????return true;
???}
??}
?}
?
?//扫描文件夹获取日志文件
?public List<String> getLogFileByScanFolder(String dir){
??List<String> fileList = new ArrayList<String>();
??boolean isFlag = checkFolderIsExists(dir);
???if(isFlag==true){
????File file = new File(dir);
????if (file.isDirectory()) {// 是不是目录
?????String[] files = file.list();// 返回该目录下所有文件及文件夹数组
?????if(files.length>0){
??????Arrays.sort(files); // 排序
??????for (int i = 0; i < files.length; i++) {
???????String log_file = files[i];
???????if (log_file.endsWith(".log")) {
????????String log_path = dir + "/" + log_file;
????????fileList.add(log_path);
???????}
??????}
?????}else{
??????log.info("Server Log File is not exists!");
??????return null;
?????}
????}
???}
??return fileList;
?}
?
?//删除日志文件
?public void deleteLogFile(String delpath){
??try {
???File file = new File(delpath);
???if (!file.isDirectory()) {
????file.delete();
???} else if (file.isDirectory()) {
????String[] filelist = file.list();
????for (int i = 0; i < filelist.length; i++) {
?????File delfile = new File(delpath + "\" + filelist[i]);
?????if (!delfile.isDirectory()) {
??????delfile.delete();
?????} else if (delfile.isDirectory()) {
??????deleteLogFile(delpath + "\" + filelist[i]);
?????} else {
??????file.delete();
?????}
????}
???}
??} catch (Exception e) {
???e.printStackTrace();
??}
?}
?public int getStorageUsed() {
??return storageUsed;
?}
?
?public void setStorageUsed(int storageUsed) {
??this.storageUsed = storageUsed;
?}
?
?public static void main(String[] args){
??// String dir = "D:/opt/tools/diskUse";
??// new AnalysisLog().parserLog(dir);
?}
}
?
????? 结束语：这段代码，我在无聊的时候进行了一次修改，使其各方法更简单明了，便于理解的方式展现给大家，当然也有些不足之处，就留作大家自己修改完善，希望对初学者和大家有所帮助。
