调用方法:
/**
* 点击量/月(年)Callable
*/
public void yearlyClickCallable() {
// 获取参数
String year = getPara("year");
// 统计数据集X
List<String> xList = new ArrayList<String>();
xList.add("January");
xList.add("February");
xList.add("March");
xList.add("April");
xList.add("May");
xList.add("June");
xList.add("July");
xList.add("August");
xList.add("September");
xList.add("October");
xList.add("November");
xList.add("December");
// 统计数据集Y
List<Integer> yList = new ArrayList<Integer>();
// 接收线程值
List<Future<List<Map<String, Object>>>> futureList = new ArrayList<Future<List<Map<String, Object>>>>();
// 计数器
int count = 0;
// 创建一个线程池(决定开启几个线程)
ExecutorService pool = Executors.newCachedThreadPool();
// 每月的日志分析
for (int m = 1; m <= 12; m++) {
// 收集日期参数
List<String> dateList = new ArrayList<String>();
//
String date = "";
// 判断有多少天
int days = CalendarUtil.weekForMonth(Integer.valueOf(year), m);
// 组合日期
for (int i = 1; i <= days; i++) {
if (i <= 9) {
if (m <= 9) {
date = year + "-0" + m + "-0" + i;
} else {
date = year + "-" + m + "-0" + i;
}
} else {
if (m <= 9) {
date = year + "-0" + m + "-" + i;
} else {
date = year + "-" + m + "-" + i;
}
}
dateList.add(date);
}
// 启动
Future<List<Map<String, Object>>> future = pool.submit(new ReadLogFileCallableByYear(dateList));
futureList.add(future);
}
// 关闭线程池
pool.shutdown();
// 接收结果集
for (Future<List<Map<String, Object>>> future : futureList) {
try {
// 接收参数
List<Map<String, Object>> list = future.get(1, TimeUnit.SECONDS);
// 设置参数
for (int p = 0; p < list.size(); p++) {
count += (int) list.get(p).get("clickCount");
if (list.get(p).get("month").equals("01")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("02")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("03")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("04")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("05")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("06")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("07")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("08")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("09")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("10")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("11")) {
yList.add((Integer) list.get(p).get("clickCount"));
} else if (list.get(p).get("month").equals("12")) {
yList.add((Integer) list.get(p).get("clickCount"));
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
setAttr("totalCount", count);
setAttr("x", xList);
setAttr("y", yList);
renderJson();
}
多线程方法:
package com.ninemax.util.loganalysis;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Callable;
import com.ninemax.util.loganalysis.tool.ConstantUtil;
/**
* 多线程有返回值
*
* @author Darker
*
*/
public class ReadLogFileCallableByYear implements Callable<List<Map<String, Object>>> {
// 日期数组
private List<String> clickDate;
// 返回结果集
public List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
public ReadLogFileCallableByYear(List<String> clickDate) {
this.clickDate = clickDate;
}
@Override
public List<Map<String, Object>> call() throws Exception {
// 接收参数
Map<String, Object> map = new HashMap<String, Object>();
// 利用FileInputStream读取文件信息
FileInputStream fis = null;
// 利用InputStreamReader进行转码
InputStreamReader reader = null;
// 利用BufferedReader进行缓冲
BufferedReader bufReader = null;
// 利用StringBuffer接收文件内容容器
StringBuffer buf = new StringBuffer();
// 点击量/月
int monthClick = 0;
for (int i = 0; i < clickDate.size(); i++) {
// 获取文件
File clickLogFile = new File(ConstantUtil.LOGLOCATION, "article.click."+ clickDate.get(i) + ".txt");
// 判断文件是否存在
if (!clickLogFile.exists() || clickLogFile.isDirectory()) {
System.err.println(clickDate.get(i) + "的文件不存在...");
map.put("month", clickDate.get(i).substring(5, 7));
map.put("clickCount", 0);
list.add(map);
return list;
} else {
try {
// 节点流
fis = new FileInputStream(clickLogFile);
// 转换流
reader = new InputStreamReader(fis, "utf-8");
// 处理流
bufReader = new BufferedReader(reader);
// 计数器
int count = 0;
// 按行读取
String line = "";
// 读取文件
while ((line = bufReader.readLine()) != null) {
// 计数
count++;
// 接收数据
if (!line.equals(null) && !line.equals("")) {
buf.append(line + "\n");
}
}
if (count == 0) {
count = 0;
} else {
count = count - 1;
}
monthClick += count;
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭流
try {
bufReader.close();
reader.close();
fis.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
// 结果集
map.put("month", clickDate.get(0).substring(5, 7));
if (monthClick == 0) {
map.put("clickCount", 0);
} else {
map.put("clickCount", monthClick);
}
list.add(map);
return list;
}
}
菜鸟交流群:260052172(大神莫入)