public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 20:22:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

监控器优化，去除内存的统计。

Browse Source 
有点鸡肋
This commit is contained in:
bryan.zhang
2018-01-30 14:15:36 +08:00
parent a71958acdd
commit da1002957a
4 changed files with 11 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@@ -5,7 +5,7 @@
<artifactId>liteflow</artifactId>
<packaging>jar</packaging>
<modelVersion>4.0.0</modelVersion>
<version>1.2.20-SNAPSHOT</version>
<version>1.3.0</version>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

1
src/main/java/com/thebeastshop/liteflow/core/NodeComponent.java
View File

@@ -50,7 +50,6 @@ public abstract class NodeComponent {
CompStatistics statistics = new CompStatistics();
statistics.setComponentClazzName(this.getClass().getSimpleName());
statistics.setTimeSpent(timeSpent);
statistics.setMemorySpent(initm-endm);
MonitorBus.addStatistics(statistics);

4
src/main/java/com/thebeastshop/liteflow/entity/data/AbsSlot.java
View File

@@ -139,4 +139,8 @@ public abstract class AbsSlot implements Slot{
public String getRequestId() {
return (String)dataMap.get(REQUEST_ID);
}
public Deque<CmpStep> getExecuteSteps() {
return executeSteps;
}
}

28
src/main/java/com/thebeastshop/liteflow/monitor/MonitorBus.java
View File

@@ -60,34 +60,22 @@ public class MonitorBus {
public static void printStatistics(){
try{
Map<String, Long> compAverageTimeSpent = new HashMap<String, Long>();
Map<String, Long> compAverageMemorySpent = new HashMap<String, Long>();
Map<String, BigDecimal> compAverageTimeSpent = new HashMap<String, BigDecimal>();
long totalTimeSpent = 0;
long totalMemorySpent = 0;
for(Entry<String, LimitQueue<CompStatistics>> entry : statisticsMap.entrySet()){
for(CompStatistics statistics : entry.getValue()){
totalTimeSpent += statistics.getTimeSpent();
totalMemorySpent += statistics.getMemorySpent();
}
compAverageTimeSpent.put(entry.getKey(), new BigDecimal(totalTimeSpent).divide(new BigDecimal(entry.getValue().size()), 2, RoundingMode.HALF_UP).longValue());
compAverageMemorySpent.put(entry.getKey(), new BigDecimal(totalMemorySpent).divide(new BigDecimal(entry.getValue().size()), 2, RoundingMode.HALF_UP).longValue());
compAverageTimeSpent.put(entry.getKey(), new BigDecimal(totalTimeSpent).divide(new BigDecimal(entry.getValue().size()), 2, RoundingMode.HALF_UP));
}
List<Entry<String, Long>> compAverageTimeSpentEntryList = new ArrayList<>(compAverageTimeSpent.entrySet());
List<Entry<String, Long>> compAverageMemorySpentEntryList = new ArrayList<>(compAverageMemorySpent.entrySet());
List<Entry<String, BigDecimal>> compAverageTimeSpentEntryList = new ArrayList<>(compAverageTimeSpent.entrySet());
Collections.sort(compAverageTimeSpentEntryList,new Comparator<Entry<String, Long>>() {
Collections.sort(compAverageTimeSpentEntryList,new Comparator<Entry<String, BigDecimal>>() {
@Override
public int compare(Entry<String, Long> o1, Entry<String, Long> o2) {
return o2.getValue().compareTo(o1.getValue());
}
});
Collections.sort(compAverageMemorySpentEntryList,new Comparator<Entry<String, Long>>() {
@Override
public int compare(Entry<String, Long> o1, Entry<String, Long> o2) {
public int compare(Entry<String, BigDecimal> o1, Entry<String, BigDecimal> o2) {
return o2.getValue().compareTo(o1.getValue());
}
});
@@ -99,13 +87,9 @@ public class MonitorBus {
logStr.append(MessageFormat.format("SLOT TOTAL SIZE : {0}\n", DataBus.SLOT_SIZE));
logStr.append(MessageFormat.format("SLOT OCCUPY COUNT : {0}\n", DataBus.OCCUPY_COUNT));
logStr.append("===============================TIME AVERAGE SPENT=====================================\n");
for(Entry<String, Long> entry : compAverageTimeSpentEntryList){
for(Entry<String, BigDecimal> entry : compAverageTimeSpentEntryList){
logStr.append(MessageFormat.format("COMPONENT[{0}] AVERAGE TIME SPENT : {1}\n", entry.getKey(), entry.getValue()));
}
logStr.append("==============================MEMORY AVERAGE SPENT====================================\n");
for(Entry<String, Long> entry : compAverageMemorySpentEntryList){
logStr.append(MessageFormat.format("COMPONENT[{0}] AVERAGE MEMORY SPENT : {1}K\n", entry.getKey(), new BigDecimal(entry.getValue()).divide(new BigDecimal(1024), 2, RoundingMode.HALF_UP)));
}
logStr.append("======================================================================================\n");
LOG.info(logStr.toString());
}catch(Exception e){