package com.javaweb.framework.aspectj;
|
|
|
import com.javaweb.common.utils.TimeUuidUtil;
|
import com.javaweb.framework.manager.AsyncManager;
|
import com.javaweb.framework.manager.factory.AsyncFactory;
|
import com.javaweb.system.domain.CostTime;
|
import org.aspectj.lang.JoinPoint;
|
import org.aspectj.lang.annotation.AfterReturning;
|
import org.aspectj.lang.annotation.Aspect;
|
import org.aspectj.lang.annotation.Before;
|
import org.aspectj.lang.annotation.Pointcut;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 计算统计服务器响应时间
|
* @author lws
|
*
|
*/
|
@Aspect
|
@Component
|
public class CountResponseTimeAspect {
|
|
public static final int CONDITION_TIME = 500;
|
ThreadLocal<Long> startTime = new ThreadLocal<>();
|
String className = null;
|
String methodName = null;
|
|
// 配置织入点
|
//第一个*代表任意返回值；controller..代表controller包下及子包下；第二个*代表所有类；*(..)代表任意参数的所有方法
|
@Pointcut("execution(* com.javaweb..controller..*.*(..))")
|
public void webLog(){}
|
@Before("webLog()")
|
public void doBefore(JoinPoint joinPoint) throws Throwable {
|
startTime.set(System.currentTimeMillis());
|
className = joinPoint.getTarget().getClass().getName();
|
methodName = joinPoint.getSignature().getName()+"()";
|
}
|
@AfterReturning(returning = "ret", pointcut = "webLog()")
|
public void doAfterReturning(Object ret) throws Throwable {
|
// 处理完请求，返回内容
|
long spendTime = System.currentTimeMillis() - startTime.get();
|
if(spendTime>CONDITION_TIME){
|
CostTime costTime = new CostTime();
|
costTime.setId(TimeUuidUtil.get16UUID());
|
costTime.setClassName(className);
|
costTime.setMethodName(methodName);
|
costTime.setSpendTime(spendTime);
|
AsyncManager.me().execute(AsyncFactory.recordCostTime(costTime));
|
}
|
}
|
}
|
