系统日志分析demo

package com.loganalyze.java.work; import java.io.StringReader; import javax.xml.bind.JAXBContext; import javax.xml.bind.JAXBException; import javax.xml.bind.Unmarshaller; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.loganalyze.java.model.LogModel; public class ActivityWorkerImpl implements ActivityWorker, Runnable{ private static Logger logger = LoggerFactory .getLogger(ActivityWorkerImpl.class); private static JAXBContext jaxbContext = null; static { try { jaxbContext = JAXBContext.newInstance(LogModel.class); } catch (JAXBException e) { logger.error("不能创建 jaxb instance!", e); } } private String activityLog; public void init(String activityLog) { this.activityLog = activityLog; } @Override public LogModel call() throws Exception { LogModel logModel = this.convertXmlToString(); //you can do something use logModel //example print logModel //在系统日志中记录出来的顺序可能会不一样，因为是多线程的 logger.info("time=" + logModel.getTime()); logger.info("name=" + logModel.getName()); return logModel; } private LogModel convertXmlToString(){ LogModel logModel = null; try { if (StringUtils.isNotEmpty(activityLog)) { Unmarshaller um = jaxbContext.createUnmarshaller(); if (null != um) { logModel = (LogModel) um .unmarshal(new StringReader(activityLog)); } else { logger.error("Unmarshaller is null,ActivityLog Block:{}", activityLog); } } } catch (JAXBException e) { logger.error( "Jaxb Unmarshaller create failure,ActivityLog Block:{}", activityLog, e); } return logModel; } @Override public void run() { try { call(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } }