任务6
【任务6.1】创建数据分析接口
在com.qst.dms.gather 下创建接口IDataAnalyse.java
功能要求：
- 包含的抽象方法如下
// 进行数据匹配 Object[] matchData();
程序设计
package com.qst.dms.gather; public interface IDataAnalyse { Object[] matchData(); }
【任务6.2】创建数据过滤抽象类
在com.qst.dms.gather 下创建抽象类DataFilter.java
功能要求：
- 成员属性如下
// 数据集合 private DataBase[] datas;
- 构造方法、get/set方法
- 抽象方法
// 数据过滤抽象方法 public abstract void doFilter();
程序设计
package com.qst.dms.gather; import com.qst.dms.entity.DataBase; import com.qst.dms.entity.LogRec; public abstract class DataFilter { // 数据集合 private DataBase[] datas; // 构造方法 public DataFilter(DataBase[] datas) { this.datas = datas; } // 获取数据集合 public DataBase[] getDatas() { return datas; } // 设置数据集合 public void setDatas(DataBase[] datas) { this.datas = datas; } // 数据过滤抽象方法 public abstract void doFilter(); }
【任务6.3】编写日志数据分析类
在com.qst.dms.gather 下创建LogRecAnalyse.java，继承DataFilter抽象类，实现数据分析IDataAnalyse接口
功能要求：
- 成员属性如下
// “登录”集合 private LogRec[] logIns; // “登出”集合 private LogRec[] logOuts;
- 实现DataFilter抽象类中的过滤抽象方法
// 获取数据集合 …… // 根据日志登录状态统计不同状态的日志个数 int numIn = 0; int numOut = 0; // 遍历统计 …… // 创建登录、登出数组 logIns = new LogRec[numIn]; logOuts = new LogRec[numOut]; // 数组下标记录 int indexIn = 0; int indexOut = 0; // 遍历，对日志数据进行过滤，根据日志登录状态分别放在不同的数组中 for (LogRec rec : logs) { …… }
- 实现IDataAnalyse接口中数据分析方法
// 创建日志匹配数组 MatchedLogRec[] matchLogs = new MatchedLogRec[logIns.length]; // 日志匹配数组下标记录 int index = 0; // 数据匹配分析 for (LogRec in : logIns) { for (LogRec out : logOuts) { if ((in.getUser().equals(out.getUser())) && (in.getIp().equals(out.getIp())) && out.getType()!=DataBase.MATHCH) { //修改in和out日志状态类型为“匹配” in.setType(DataBase.MATHCH); out.setType(DataBase.MATHCH); //添加到匹配数组中 matchLogs[index++] = new MatchedLogRec(in, out); } } } return matchLogs;
程序设计
package com.qst.dms.gather; import com.qst.dms.entity.DataBase; import com.qst.dms.entity.LogRec; import com.qst.dms.entity.MatchedLogRec; public class LogRecAnalyse extends DataFilter implements IDataAnalyse { // “登录”集合 private LogRec[] logIns; // “登出”集合 private LogRec[] logOuts; public LogRecAnalyse(LogRec[] datas) { super(datas); } // 实现DataFilter抽象类中的过滤抽象方法 @Override public void doFilter() { // 获取数据集合 LogRec[] datas = (LogRec[]) getDatas(); // 根据日志登录状态统计不同状态的日志个数 int numIn = 0; int numOut = 0; // 遍历统计 for (LogRec data : datas) { if (data.getLogType() == LogRec.LOG_IN) { numIn++; } else if (data.getLogType() == LogRec.LOG_OUT) { numOut++; } } // 创建登录、登出数组 logIns = new LogRec[numIn]; logOuts = new LogRec[numOut]; // 数组下标记录 int indexIn = 0; int indexOut = 0; // 遍历，对日志数据进行过滤，根据日志登录状态分别放在不同的数组中 for (LogRec data : datas) { if (data.getLogType() == LogRec.LOG_IN) { logIns[indexIn++] = data; } else if (data.getLogType() == LogRec.LOG_OUT) { logOuts[indexOut++] = data; } } } // 实现IDataAnalyse接口中数据分析方法 @Override public Object[] matchData() { // 创建日志匹配数组 MatchedLogRec[] matchLogs = new MatchedLogRec[logIns.length]; // 日志匹配数组下标记录 int index = 0; // 数据匹配分析 for (LogRec in : logIns) { for (LogRec out : logOuts) { if ((in.getUser().equals(out.getUser())) && (in.getIp().equals(out.getIp())) && out.getType() != DataBase.MATHCH) { // 修改in和out日志状态类型为“匹配” in.setType(DataBase.MATHCH); out.setType(DataBase.MATHCH); // 添加到匹配数组中 matchLogs[index++] = new MatchedLogRec(in, out); } } } return matchLogs; } }
【任务6.4】创建日志数据分析测试类，测试任务6.1-6.3中的程序，演示日志信息的采集、分析及打印输出
在com.qst.dms.dos 下创建EntityDataDemo.java
功能要求：
采集3组日志信息，放到数组中，进行日志分析、过滤，对于匹配的日志信息打印输出
// 创建一个日志业务类 // 创建一个日志对象数组，用于存放采集的三个日志信息 // 创建日志数据分析对象 ; // 日志数据过滤 ; // 日志数据匹配分析 ; // 判断objs数组是否是配置日志数组 if (objs instanceof MatchedLogRec[]) { // 将对象数组强制类型转换成配置日志数组 ; // 输出匹配的日志信息 ; }
程序设计
package com.qst.dms.dos; import com.qst.dms.entity.LogRec; import com.qst.dms.entity.MatchedLogRec; import com.qst.dms.gather.LogRecAnalyse; import com.qst.dms.service.LogRecService; public class EntityDataDemos { public static void main(String[] args) { // 创建一个日志业务类 LogRecService logService = new LogRecService(); // 创建一个日志对象数组，用于存放采集的三个日志信息 LogRec[] logs = new LogRec[3]; // 采集日志信息，将采集到的日志对象存放到logs数组中 logs[0] = logService.inputLog(); logs[1] = logService.inputLog(); logs[2] = logService.inputLog(); // 创建日志数据分析对象 LogRecAnalyse logAnalyse = new LogRecAnalyse(logs); // 日志数据过滤 logAnalyse.doFilter(); // 日志数据匹配分析 Object[] objs = logAnalyse.matchData(); // 判断objs数组是否是配置日志数组 if (objs instanceof MatchedLogRec[]) { // 将对象数组强制类型转换成配置日志数组 MatchedLogRec[] matchedLogs = (MatchedLogRec[]) objs; // 输出匹配的日志信息 for (MatchedLogRec log : matchedLogs) { if(log!=null) { System.out.println(log); } } } } }
测试
