admin/ko-time
1
0
Fork 0
mirror of https://gitee.com/huoyo/ko-time.git synced 2025-12-06 16:58:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

add ParamMetric

Browse Source
This commit is contained in:
huoyo 2022-03-06 22:52:49 +08:00
parent a83ea8c9e5
commit a9c2c5bc87
9 changed files with 179 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -6,7 +6,7 @@
<groupId>cn.langpy</groupId>
<artifactId>ko-time</artifactId>
<version>2.0.7</version>
<version>2.0.8</version>
<name>koTime</name>
<description>koTime</description>
<licenses>

9
src/main/java/cn/langpy/kotime/controller/KoTimeController.java
View File

@ -134,6 +134,15 @@ public class KoTimeController {
return list;
}
@GetMapping("/getParamGraph")
@ResponseBody
@Auth
public Map<String, ParamMetric> getParamGraph(String methodId) {
GraphService graphService = GraphService.getInstance();
Map<String, ParamMetric> list = graphService.getMethodParamGraph(methodId);
return list;
}
@GetMapping("/getApiTips")
@ResponseBody
@Auth

97
src/main/java/cn/langpy/kotime/data/MemoryBase.java
View File

@ -6,7 +6,11 @@ import cn.langpy.kotime.util.Common;
import cn.langpy.kotime.util.Context;
import cn.langpy.kotime.util.MethodType;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import java.lang.reflect.Field;
import java.lang.reflect.Parameter;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;
@ -26,22 +30,25 @@ public class MemoryBase implements GraphService {
private volatile static Map<String, ExceptionRelation> exceptionRelations;
private volatile static Map<String, Map<String, ParamMetric>> paramValueMetricMap;
static {
methodNodes = new HashMap<>();
exceptions = new HashMap<>();
methodRelations = new HashMap<>();
exceptionRelations = new HashMap<>();
paramValueMetricMap = new HashMap<String, Map<String, ParamMetric>>();
}
@Override
public void addMethodNode(MethodNode methodNode) {
if (null==methodNode) {
if (null == methodNode) {
return;
}
if (!methodNodes.containsKey(methodNode.getId())) {
methodNodes.put(methodNode.getId(), methodNode);
}else {
if (methodNode.getMethodType()==MethodType.Controller && !StringUtils.isEmpty(methodNode.getRouteName())) {
} else {
if (methodNode.getMethodType() == MethodType.Controller && !StringUtils.isEmpty(methodNode.getRouteName())) {
MethodNode controller = methodNodes.get(methodNode.getId());
controller.setRouteName(methodNode.getRouteName());
methodNodes.put(methodNode.getId(), controller);
@ -49,10 +56,74 @@ public class MemoryBase implements GraphService {
}
}
List<Class<?>> baseTypes = Arrays.asList(Integer.class, Double.class, Float.class, String.class, Boolean.class, MultipartFile.class);
public void addMethodAnalyse(String methodId, Parameter[] names, Object[] values, double v) {
List<String> params = new ArrayList<>();
for (int i = 0; i < names.length; i++) {
Class<?> type = names[i].getType();
if (baseTypes.contains(type)) {
if (values[i] != null) {
params.add(names[i].getName());
}
} else {
if (type == HttpServletRequest.class) {
continue;
}
Field[] declaredFields = values[i].getClass().getDeclaredFields();
for (Field field : declaredFields) {
field.setAccessible(true);
try {
Object value = field.get(values[i]);
if (value != null) {
params.add(field.getName());
}
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
}
}
String paramsKey = "-";
if (params.size()>0) {
paramsKey = String.join("-", params);
}
if (paramValueMetricMap.containsKey(methodId)) {
Map<String, ParamMetric> paramMetricMap = paramValueMetricMap.get(methodId);
if (paramMetricMap.containsKey(paramsKey)) {
ParamMetric paramMetric = paramMetricMap.get(paramsKey);
BigDecimal bg = BigDecimal.valueOf((paramMetric.getAvgRunTime() + v) / 2.0);
double avg = bg.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
paramMetric.setAvgRunTime(avg);
if (v > paramMetric.getMaxRunTime()) {
paramMetric.setMaxRunTime(v);
}
if (v < paramMetric.getMinRunTime()) {
paramMetric.setMinRunTime(v);
}
} else {
ParamMetric paramMetric = new ParamMetric();
paramMetric.setMaxRunTime(v);
paramMetric.setAvgRunTime(v);
paramMetric.setMaxRunTime(v);
paramMetricMap.put(paramsKey, paramMetric);
}
} else {
ParamMetric paramMetric = new ParamMetric();
paramMetric.setMaxRunTime(v);
paramMetric.setAvgRunTime(v);
paramMetric.setMaxRunTime(v);
Map<String, ParamMetric> paramMetricMap = new HashMap<>();
paramMetricMap.put(paramsKey, paramMetric);
paramValueMetricMap.put(methodId, paramMetricMap);
}
}
@Override
public MethodRelation addMethodRelation(MethodNode sourceMethodNode, MethodNode targetMethodNode) {
if (null!=sourceMethodNode && null!=targetMethodNode && sourceMethodNode.getId().equals(targetMethodNode.getId())) {
if (null != sourceMethodNode && null != targetMethodNode && sourceMethodNode.getId().equals(targetMethodNode.getId())) {
return null;
}
MethodRelation methodRelation = new MethodRelation();
@ -135,7 +206,7 @@ public class MemoryBase implements GraphService {
MethodRelation relation = null;
if (relations.isPresent()) {
relation = relations.get();
}else{
} else {
continue;
}
MethodInfo methodInfo = new MethodInfo();
@ -157,6 +228,12 @@ public class MemoryBase implements GraphService {
return methodInfos;
}
@Override
public Map<String, ParamMetric> getMethodParamGraph(String methodId) {
Map<String, ParamMetric> paramMetricMap = paramValueMetricMap.get(methodId);
return paramMetricMap;
}
@Override
public List<MethodInfo> searchMethods(String question) {
List<MethodInfo> methodInfos = new ArrayList<>();
@ -167,7 +244,7 @@ public class MemoryBase implements GraphService {
MethodRelation relation = null;
if (relations.isPresent()) {
relation = relations.get();
}else{
} else {
continue;
}
MethodInfo methodInfo = new MethodInfo();
@ -198,7 +275,7 @@ public class MemoryBase implements GraphService {
methodInfos.add(methodNode.getName());
}
}
if (methodInfos.size()>=10) {
if (methodInfos.size() >= 10) {
break;
}
}
@ -302,19 +379,19 @@ public class MemoryBase implements GraphService {
rootInfo.setExceptionNum(exceptionInfos.size());
rootInfo.setExceptions(exceptionInfos);
List<String> methodInfos = new ArrayList<>();
recursionMethod(rootInfo,methodInfos);
recursionMethod(rootInfo, methodInfos);
methodInfos.clear();
return rootInfo;
}
public void recursionMethod(MethodInfo rootInfo,List<String> methodInfos) {
public void recursionMethod(MethodInfo rootInfo, List<String> methodInfos) {
List<MethodInfo> children = getChildren(rootInfo.getId());
if (children != null && children.size() > 0) {
if (!methodInfos.contains(rootInfo.getId())) {
methodInfos.add(rootInfo.getId());
rootInfo.setChildren(children);
for (MethodInfo child : children) {
recursionMethod(child,methodInfos);
recursionMethod(child, methodInfos);
}
}

12
src/main/java/cn/langpy/kotime/data/MysqlBase.java
View File

@ -3,7 +3,9 @@ package cn.langpy.kotime.data;
import cn.langpy.kotime.model.*;
import cn.langpy.kotime.service.GraphService;
import java.lang.reflect.Parameter;
import java.util.List;
import java.util.Map;
/**
* zhangchang
@ -15,6 +17,11 @@ public class MysqlBase implements GraphService {
}
@Override
public void addMethodAnalyse(String methodId, Parameter[] names, Object[] values, double v) {
}
@Override
public void addExceptionNode(ExceptionNode exceptionNode) {
@ -25,6 +32,11 @@ public class MysqlBase implements GraphService {
return null;
}
@Override
public Map<String, ParamMetric> getMethodParamGraph(String methodId) {
return null;
}
@Override
public SystemStatistic getRunStatistic() {
return null;

1
src/main/java/cn/langpy/kotime/handler/RunTimeHandler.java
View File

@ -54,6 +54,7 @@ public class RunTimeHandler implements MethodInterceptor {
graphService.addMethodNode(parent);
graphService.addMethodNode(current);
graphService.addMethodRelation(parent, current);
graphService.addMethodAnalyse(current.getId(),invocation.getMethod().getParameters(), invocation.getArguments(),((end - begin) / 1000000.0));
MethodStack.clear();
return obj;
}

32
src/main/java/cn/langpy/kotime/model/ParamMetric.java Normal file
View File

@ -0,0 +1,32 @@
package cn.langpy.kotime.model;
public class ParamMetric {
private Double avgRunTime = 0.0;
private Double maxRunTime = 0.0;
private Double minRunTime = 0.0;
public Double getAvgRunTime() {
return avgRunTime;
}
public void setAvgRunTime(Double avgRunTime) {
this.avgRunTime = avgRunTime;
}
public Double getMaxRunTime() {
return maxRunTime;
}
public void setMaxRunTime(Double maxRunTime) {
this.maxRunTime = maxRunTime;
}
public Double getMinRunTime() {
return minRunTime;
}
public void setMinRunTime(Double minRunTime) {
this.minRunTime = minRunTime;
}
}

6
src/main/java/cn/langpy/kotime/service/GraphService.java
View File

@ -5,7 +5,9 @@ import cn.langpy.kotime.data.MysqlBase;
import cn.langpy.kotime.model.*;
import cn.langpy.kotime.util.Context;
import java.lang.reflect.Parameter;
import java.util.List;
import java.util.Map;
/**
* zhangchang
@ -25,10 +27,14 @@ public interface GraphService {
void addMethodNode(MethodNode methodNode);
void addMethodAnalyse(String methodId,Parameter[] names, Object[] values,double v);
void addExceptionNode(ExceptionNode exceptionNode);
MethodInfo getTree(String methodId);
Map<String, ParamMetric> getMethodParamGraph(String methodId);
SystemStatistic getRunStatistic();
List<MethodInfo> searchMethods(String question);

2
src/main/java/cn/langpy/kotime/util/Common.java
View File

@ -19,7 +19,7 @@ public class Common {
public static String getRoute(MethodInvocation pjp) {
Class<?> targetClass = pjp.getThis().getClass();
String[] classRoute = getRouteValue(targetClass);
if (classRoute == null) {
if (classRoute == null || classRoute.length==0) {
return null;
}
StringBuilder routes = new StringBuilder(classRoute[0]);

32
src/main/resources/kotime.html
View File

File diff suppressed because one or more lines are too long