Calling method:
/** * Number of clicks/month (year)Thread */ public void yearlyClickThread() { // Get parameters String year = getPara("year"); // Statistics data set 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("July"); xList.add("August"); xList.add("September"); xList.add("October"); xList.add("November"); xList.add("December"); // Statistics dataset Y List<Integer> yList = new ArrayList<Integer>(); // Statistics thread status List<Thread> threadList = new ArrayList<Thread>(); // Thread status code int threadStatusCode = 0; // Counter int count = 0; // Monthly log analysis for (int m = 1; m <= 12; m++) { // Collect date parameters List<String> dateList = new ArrayList<String>(); // String date = ""; // Determine how many days int days = CalendarUtil.weekForMonth(Integer.valueOf(year), m); // Combination date 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); } // Start the thread Thread thread = new ReadLogFileThreadByYear(dateList); thread.start(); try { // Hibernate Thread.sleep(1000L); } catch (InterruptedException e) { e.printStackTrace(); } threadList.add(thread); } // Get thread status for (Thread t : threadList) { if (t.getState().toString().equals("TERMINATED")) { threadStatusCode += 1; } } // Determine whether all threads have been executed if (threadStatusCode == 12) { // Receive parameters // List<Map<String, Object>> list = ReadLogFileThread.list.subList(0, 12); List<Map<String, Object>> list = ReadLogFileThreadByYear.list; // Set parameters 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(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")); } } } setAttr("totalCount", count); setAttr("x", xList); setAttr("y", yList); renderJson(); }Threading method:
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 com.ninemax.util.loganalysis.tool.ConstantUtil;/** * Multithreading has no return value* * @author Darker * */public class ReadLogFileThreadByYear extends Thread { // Date array private List<String> clickDate; // Shared data public static List<Map<String, Object>> list = new ArrayList<Map<String, Object>>(); public ReadLogFileThreadByYear(List<String> clickDate) { this.clickDate = clickDate; } /** * Read click log file* * Example: article.click.2016-05-20.txt * * @return */ public void run() { // Receive parameters Map<String, Object> map = new HashMap<String, Object>(); // Use FileInputStream to read file information FileInputStream fis = null; // Use InputStreamReader to transcode InputStreamReader reader = null; // Use BufferedReader to buffer BufferedReader bufReader = null; // Use StringBuffer to receive file content container StringBuffer buf = new StringBuffer(); // Clicks/month int monthClick = 0; for (int i = 0; i < clickDate.size(); i++) { // Get file File clickLogFile = new File(ConstantUtil.LOGLOCATION, "article.click."+ clickDate.get(i) + ".txt"); // Determine whether the file exists if (!clickLogFile.exists() || clickLogFile.isDirectory()) { System.err.println(clickDate.get(i) + "The file does not exist..."); } else { try { // Node stream fis = new FileInputStream(clickLogFile); // Convert stream reader = new InputStreamReader(fis, "utf-8"); // Process stream bufReader = new BufferedReader(reader); // Counter int count = 0; // Read String line = ""; // Read file while ((line = bufReader.readLine()) != null) { count++; // Receive data 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 { // Close the stream try { bufReader.close(); reader.close(); fis.close(); } catch (IOException e) { e.printStackTrace(); } } } } map.put("month", clickDate.get(0).subSequence(5, 7)); if(monthClick==0){ map.put("clickCount", 0); }else{ map.put("clickCount", monthClick); } // map.put("clickContent", buf.toString()); list.add(map); } } 1 2Next page Read the full text