Javaの課題丸投げコミュのWEBサーバアクセスログ集計プログラムの開発

こりきに　CR-X さん

ありがとうございます。
awk でも教えて頂けたら助かります。

こんな感じ。
エラー処理がかなり適当。
ちゃんとテストしてないから、もしかしたら間違ってるかも。
あと、標準出力に出すのに文字コード指定ってのは、javacのオプションいじるくらいしか思いつかないんだけど、簡単な方法ってあるのかな…？


public class LogItem {
public LogItem(Date aDate, String aPath, int aResponseTime){
mDate = aDate;
mPath = aPath;
mResponseTime = aResponseTime;
}

private Date mDate;
private int mResponseTime;
private String mPath;

public Date getDate(){
return mDate;
}

public int getResponseTime(){
return mResponseTime;
}
public String getPath(){
return mPath;
}
}

↑　importコピーするの忘れた。　適時追加してね。


import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Reader;
import java.nio.charset.Charset;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.TimeZone;

public class LogParser {
public LogParser(Charset aCharset) {
mCharset = aCharset;
}

private Charset mCharset;
private static final DateFormat DATE_FORMAT = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
{
DATE_FORMAT.setTimeZone(TimeZone.getTimeZone("GMT+0"));
}

public List<LogItem> parse(File aFile) throws IOException, ParseException {
Reader tReader = null;
try {
tReader = new InputStreamReader(new FileInputStream(aFile), mCharset);
return parse(tReader);
} finally {
if (tReader != null)
tReader.close();
}
}

public List<LogItem> parse(Reader aReader) throws IOException, ParseException {
BufferedReader tReader = new BufferedReader(aReader);
List<LogItem> tResult = new ArrayList<LogItem>();
String tLine;
while ((tLine = tReader.readLine()) != null) {
tResult.add(parseLine(tLine));
}

return tResult;
}

private LogItem parseLine(String aLine) throws ParseException {
String[] tValues = aLine.split("\t");
Date tDate = DATE_FORMAT.parse(tValues[0]);
String tPath = tValues[1];
int tResponseTime = Integer.parseInt(tValues[2]);

return new LogItem(tDate, tPath, tResponseTime);
}
}

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Collections;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.TimeZone;

public class LogAggregator {
/**
*
* @param aLogs 集計対象ログ
*/
public LogAggregator(List<LogItem> aLogs) {
// 一応、時間でソートする
Collections.sort(aLogs, new Comparator<LogItem>() {
@Override
public int compare(LogItem aLeft, LogItem aRight) {
return aLeft.getDate().compareTo(aRight.getDate());
}
});

mLogs = aLogs;
}

/**
* ミリ秒で表した１日
*/
private static final long DAY_AS_MIL = 3600 * 24 * 1000;
private static final DateFormat DATE_FORMAT = new SimpleDateFormat("HH:mm");
{
DATE_FORMAT.setTimeZone(TimeZone.getTimeZone("GMT+0"));
}

private List<LogItem> mLogs;

public void printAggregate(long aAggregateSpan) {
long tCurrentTime = 0;
long tAggregateSpan = aAggregateSpan;

List<LogItem> tLogs = mLogs;
int tLogCount = tLogs.size();
int tIndex = 0;

for (tCurrentTime = 0; tCurrentTime < DAY_AS_MIL; tCurrentTime += tAggregateSpan) {
int tRangeCount1 = 0;
int tRangeCount2 = 0;
int tRangeCount3 = 0;
int tSum = 0;

while (tIndex < tLogCount) {
LogItem tItem = tLogs.get(tIndex);
long tLogTime = tItem.getDate().getTime() % DAY_AS_MIL;
if (tLogTime - tCurrentTime < tAggregateSpan) {
tIndex++;

int tResponseTime = tItem.getResponseTime();
tSum += tResponseTime;
if (tResponseTime < 1000)
tRangeCount1++;
else if (tResponseTime < 5000)
tRangeCount2++;
else
tRangeCount3++;
} else {
break;
}
}

int tTotalCount = tRangeCount1 + tRangeCount2 + tRangeCount3;
int tAverage = 0;
if (tTotalCount != 0)
tAverage = tSum / tTotalCount;

printAggregate(tCurrentTime, tRangeCount1, tRangeCount2, tRangeCount3, tAverage);
}
}

private void printAggregate(long aTime, int aCount1, int aCount2, int aCount3, int aAverage) {
String tTimeString = DATE_FORMAT.format(new Date(aTime));
String tOutput = String.format("%s\t%d\t%d\t%d\t%d", tTimeString, aCount1, aCount2, aCount3, aAverage);

System.out.println(tOutput);
}
}

import java.io.File;
import java.nio.charset.Charset;
import java.util.List;

public class Main {

/**
* @param args
*/
public static void main(String... aArgs) {
if (aArgs.length != 1) {
System.out.println("ログファイルをひとつだけ指定してください");
return;
}

File tFile = new File(aArgs[0]);
if (!tFile.exists()) {
System.out.println("対象ファイルがみつかりません");
return;
}

Charset tCharset = Charset.forName("EUC-JP");
try {
List<LogItem> tLogs = new LogParser(tCharset).parse(tFile);
new LogAggregator(tLogs).printAggregate(5 * 60 * 1000);
} catch (Exception e) {
e.printStackTrace();
}
}

}

以上、４クラス。
同じパッケージに入れてね。