Skip to content

Commit

Permalink
fixed cpu usage
Browse files Browse the repository at this point in the history
  • Loading branch information
@smartloli
smartloli committed Dec 17, 2021
1 parent 2dd79e4 commit cea2ad8
Show file tree
Hide file tree
Showing 3 changed files with 151 additions and 13 deletions.
158 changes: 148 additions & 10 deletions efak-common/src/main/java/org/smartloli/kafka/eagle/common/util/AppUtils.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,11 @@
*/
package org.smartloli.kafka.eagle.common.util;

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.lang.management.*;
import java.util.*;

/**
* Count the percent of application resources.
Expand Down Expand Up @@ -53,19 +57,23 @@ public static AppUtils getInstance() {
* <p>
* 100% -> 1 cpu cores
*/
// public double getProcessCpu() {
// long totalTime = 0;
// for (long id : threadBean.getAllThreadIds()) {
// totalTime += threadBean.getThreadCpuTime(id);
// }
// long curtime = System.nanoTime();
// long usedTime = totalTime - preUsedTime;
// long totalPassedTime = curtime - preTime;
// preTime = curtime;
// preUsedTime = totalTime;
// return StrUtils.numberic((((double) usedTime) / totalPassedTime / osMxBean.getAvailableProcessors()) * 100);
// }
public double getProcessCpu() {
long totalTime = 0;
for (long id : threadBean.getAllThreadIds()) {
totalTime += threadBean.getThreadCpuTime(id);
}
long curtime = System.nanoTime();
long usedTime = totalTime - preUsedTime;
long totalPassedTime = curtime - preTime;
preTime = curtime;
preUsedTime = totalTime;
return StrUtils.numberic((((double) usedTime) / totalPassedTime / osMxBean.getAvailableProcessors()) * 100);
return StrUtils.numberic(getCpuUsagePercent());
}


/**
* Get application mem used.
*/
Expand All @@ -84,5 +92,135 @@ public String getStartTime() {
return CalendarUtils.convertUnixTime2Date(runtimeMXBean.getStartTime());
}

/**
* Get os cpu info.
*/
private static Map<?, ?> getCpuInfo() {
InputStreamReader inputs = null;
BufferedReader buffer = null;
Map<String, Object> map = new HashMap<String, Object>();
try {
inputs = new InputStreamReader(new FileInputStream("/proc/stat"));
buffer = new BufferedReader(inputs);
String line = "";
while (true) {
line = buffer.readLine();
if (line == null) {
break;
}
if (line.startsWith("cpu")) {
StringTokenizer tokenizer = new StringTokenizer(line);
List<String> temp = new ArrayList<String>();
while (tokenizer.hasMoreElements()) {
String value = tokenizer.nextToken();
temp.add(value);
}
map.put("user", temp.get(1));
map.put("nice", temp.get(2));
map.put("system", temp.get(3));
map.put("idle", temp.get(4));
map.put("iowait", temp.get(5));
map.put("irq", temp.get(6));
map.put("softirq", temp.get(7));
map.put("stealstolen", temp.get(8));
break;
}
}
} catch (Exception e) {
e.printStackTrace();
LoggerUtils.print(AppUtils.class).error("Get cpu info has error, msg is ", e);
} finally {
try {
buffer.close();
inputs.close();
} catch (Exception ex) {
LoggerUtils.print(AppUtils.class).error("Close cpu stream object has error, msg is ", ex);
}
}
return map;
}

/**
* Get cpu usage.
*/
private static double getCpuUsagePercent() {
try {
Map<?, ?> map1 = getCpuInfo();
Thread.sleep(10);
Map<?, ?> map2 = getCpuInfo();

long user1 = Long.parseLong(map1.get("user").toString());
long nice1 = Long.parseLong(map1.get("nice").toString());
long system1 = Long.parseLong(map1.get("system").toString());
long idle1 = Long.parseLong(map1.get("idle").toString());

long user2 = Long.parseLong(map2.get("user").toString());
long nice2 = Long.parseLong(map2.get("nice").toString());
long system2 = Long.parseLong(map2.get("system").toString());
long idle2 = Long.parseLong(map2.get("idle").toString());

long total1 = user1 + system1 + nice1;
long total2 = user2 + system2 + nice2;
float total = total2 - total1;

long totalIdle1 = user1 + nice1 + system1 + idle1;
long totalIdle2 = user2 + nice2 + system2 + idle2;
float totalidle = totalIdle2 - totalIdle1;

double cpusage = (total * 1.0 / totalidle) * 100;
return cpusage;
} catch (InterruptedException e) {
LoggerUtils.print(AppUtils.class).error("Get cpu usage percent has error, msg is ", e);
}
return 0.00;
}

/**
* Get memory usage.
*/
public static double getOSMemUsage() {
Map<String, Object> map = new HashMap<String, Object>();
InputStreamReader inputs = null;
BufferedReader buffer = null;
try {
inputs = new InputStreamReader(new FileInputStream("/proc/meminfo"));
buffer = new BufferedReader(inputs);
String line = "";
while (true) {
line = buffer.readLine();
if (line == null)
break;
int beginIndex = 0;
int endIndex = line.indexOf(":");
if (endIndex != -1) {
String key = line.substring(beginIndex, endIndex);
beginIndex = endIndex + 1;
endIndex = line.length();
String memory = line.substring(beginIndex, endIndex);
String value = memory.replace("kB", "").trim();
map.put(key, value);
}
}

long memTotal = Long.parseLong(map.get("MemTotal").toString());
long memFree = Long.parseLong(map.get("MemFree").toString());
long memused = memTotal - memFree;
long buffers = Long.parseLong(map.get("Buffers").toString());
long cached = Long.parseLong(map.get("Cached").toString());

double usage = (double) (memused - buffers - cached) * 1.0 / memTotal * 100;
return StrUtils.numberic(usage);
} catch (Exception e) {
LoggerUtils.print(AppUtils.class).error("Get os memory usage percent has error, msg is ", e);
} finally {
try {
buffer.close();
inputs.close();
} catch (Exception ex) {
LoggerUtils.print(AppUtils.class).error("Close os memory object has error, msg is ", ex);
}
}
return 0.00;
}
}

2 changes: 1 addition & 1 deletion efak-web/src/main/java/org/smartloli/kafka/eagle/web/dao/TopicDao.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -165,7 +165,7 @@
</foreach>
)
</if>
and tm between #{stime} and #{etime} group by from_unixtime(timespan/1000,'%Y-%m-%d %H:%i:%s')
and tm between #{stime} and #{etime} group by from_unixtime(timespan/1000,'%Y-%m-%d %H:%i:%s'),tm
)a group by tm
</select>

Expand Down
4 changes: 2 additions & 2 deletions efak-web/src/main/webapp/WEB-INF/views/cluster/worknodes.jsp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -52,8 +52,8 @@
<tr>
<th>IP</th>
<th>Port</th>
<th>Memory(Used | Percent)</th>
<th>CPU</th>
<th>Heap Memory(Used | Percent)</th>
<th>Usage CPU</th>
<th>Status</th>
<th>Role</th>
<th>ZKCli(Max | Idle)</th>
Expand Down

0 comments on commit cea2ad8

Please sign in to comment.