test/Jpom
1
0
Fork 0
mirror of https://gitee.com/dromara/Jpom.git synced 2024-12-02 11:58:01 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

首页进程列表

Browse Source
This commit is contained in:
Arno 2019-03-22 11:08:58 +08:00
parent 5497d6a38a
commit 595c4fa017
4 changed files with 210 additions and 127 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/main/java/cn/keepbx/jpom/controller/WelcomeController.java
View File

@ -6,6 +6,7 @@ import cn.keepbx.jpom.common.BaseController;
import cn.keepbx.jpom.common.commander.AbstractCommander;
import cn.keepbx.jpom.model.UserModel;
import cn.keepbx.jpom.socket.top.TopManager;
import com.alibaba.fastjson.JSONArray;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@ -35,13 +36,31 @@ public class WelcomeController extends BaseController {
try {
if (AbstractCommander.OS_INFO.isLinux()) {
String s = AbstractCommander.getInstance().execCommand("top -b -n 1");
topInfo = TopManager.getTopInfo(s);
topInfo = TopManager.getTopMonitor(s);
} else {
topInfo = TopManager.getWindowsTop();
topInfo = TopManager.getWindowsMonitor();
}
} catch (Exception e) {
DefaultSystemLog.ERROR().error(e.getMessage(), e);
}
return JsonMessage.getString(200, "", topInfo);
}
@RequestMapping(value = "processList", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
@ResponseBody
public String getProcessList() {
JSONArray array = null;
try {
if (AbstractCommander.OS_INFO.isLinux()) {
String s = AbstractCommander.getInstance().execCommand("top | head -17");
array = TopManager.formatLinuxTop(s);
} else {
String s = AbstractCommander.getInstance().execSystemCommand("tasklist /V | findstr java");
array = TopManager.formatWindowsProcess(s);
}
} catch (Exception e) {
DefaultSystemLog.ERROR().error(e.getMessage(), e);
}
return JsonMessage.getString(200, "", array);
}
}

112
src/main/java/cn/keepbx/jpom/controller/manage/InternalController.java
View File

@ -12,6 +12,7 @@ import cn.keepbx.jpom.common.commander.AbstractCommander;
import cn.keepbx.jpom.model.ProjectInfoModel;
import cn.keepbx.jpom.service.manage.CommandService;
import cn.keepbx.jpom.service.manage.ProjectInfoService;
import cn.keepbx.jpom.socket.top.TopManager;
import cn.keepbx.jpom.system.ConfigBean;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
@ -54,10 +55,17 @@ public class InternalController extends BaseController {
if (AbstractCommander.OS_INFO.isLinux()) {
String command = "top -b -n 1 -p " + pid;
String internal = AbstractCommander.getInstance().execCommand(command);
setAttribute("item", formatTop(internal));
JSONArray array = TopManager.formatLinuxTop(internal);
if (null != array) {
setAttribute("item", array.getJSONObject(0));
}
} else {
JSONObject windowsMem = getWindowsMem(pid);
setAttribute("item", windowsMem);
String command = "tasklist /V /FI \"pid eq " + pid + "\"";
String result = AbstractCommander.getInstance().execCommand(command);
JSONArray array = TopManager.formatWindowsProcess(result);
if (null != array) {
setAttribute("item", array.getJSONObject(0));
}
}
JSONObject beanMem = getBeanMem(tag);
setAttribute("beanMem", beanMem);
@ -67,60 +75,6 @@ public class InternalController extends BaseController {
return "manage/internal";
}
/**
* 获取window下内存
*
* @param pid 进程id
*/
private JSONObject getWindowsMem(String pid) throws Exception {
String command = "tasklist /V /FI \"pid eq " + pid + "\"";
String result = AbstractCommander.getInstance().execCommand(command);
List<String> list = StrSpliter.splitTrim(result, "\n", true);
if (list.size() >= 3) {
List<String> memList = StrSpliter.splitTrim(list.get(2), " ", true);
JSONObject item = new JSONObject();
item.put("pid", pid);
item.put("COMMAND", memList.get(0));
//使用内存 kb
String mem = memList.get(4).replace(",", "");
long aLong = Convert.toLong(mem, 0L);
item.put("RES", aLong / 1024 + " MB");
String status = memList.get(6);
if ("RUNNING".equalsIgnoreCase(status)) {
item.put("S", "运行");
} else if ("SUSPENDED".equalsIgnoreCase(status)) {
item.put("S", "睡眠");
} else if ("NOT RESPONDING".equalsIgnoreCase(status)) {
item.put("S", "无响应");
} else {
item.put("S", "未知");
}
item.put("USER", memList.get(7));
item.put("TIME", memList.get(8));
item.put("PR", -1);
item.put("NI", -1);
item.put("VIRT", -1);
item.put("SHR", -1);
item.put("CPU", -1);
OperatingSystemMXBean operatingSystemMXBean = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
//最近jvmcpu使用率
double processCpuLoad = operatingSystemMXBean.getProcessCpuLoad() * 100;
if (processCpuLoad <= 0) {
processCpuLoad = 0;
}
item.put("CPU", String.format("%.2f", processCpuLoad) + "%");
//服务器总内存
long totalMemorySize = operatingSystemMXBean.getTotalPhysicalMemorySize();
double v = new BigDecimal(aLong).divide(new BigDecimal(totalMemorySize / 1024), 4, BigDecimal.ROUND_HALF_UP).doubleValue() * 100;
item.put("MEM", String.format("%.2f", v) + "%");
if (v <= 0) {
item.put("MEM", 0);
}
return item;
}
return null;
}
/**
* 获取jvm内存
*
@ -167,50 +121,6 @@ public class InternalController extends BaseController {
return null;
}
private JSONObject formatTop(String top) {
List<String> list = StrSpliter.splitTrim(top, "\n", true);
if (list.size() < 5) {
return null;
}
String topName = list.get(list.size() - 2);
List<String> nameList = StrSpliter.splitTrim(topName, " ", true);
String ram = list.get(list.size() - 1);
List<String> ramList = StrSpliter.splitTrim(ram, " ", true);
JSONObject item = new JSONObject();
for (int i = 0; i < nameList.size(); i++) {
String name = nameList.get(i);
String value = ramList.get(i);
if (i == 0) {
item.put("pid", value);
continue;
}
name = name.replaceAll("%", "").replace("+", "");
if ("VIRT".equalsIgnoreCase(name) || "RES".equalsIgnoreCase(name) || "SHR".equalsIgnoreCase(name)) {
value = Convert.toLong(value) / 1024 + " MB";
}
if ("<EFBFBD>".equals(name)) {
name = "S";
}
if ("S".equalsIgnoreCase(name)) {
if ("S".equalsIgnoreCase(value)) {
value = "睡眠";
} else if ("R".equalsIgnoreCase(value)) {
value = "运行";
} else if ("T".equalsIgnoreCase(value)) {
value = "跟踪/停止";
} else if ("Z".equalsIgnoreCase(value)) {
value = "僵尸进程 ";
} else if ("D".equalsIgnoreCase(value)) {
value = "不可中断的睡眠状态 ";
}
}
if ("CPU".equalsIgnoreCase(name) || "MEM".equalsIgnoreCase(name)) {
value += "%";
}
item.put(name, value);
}
return item;
}
/**
* 导出堆栈信息

171
src/main/java/cn/keepbx/jpom/socket/top/TopManager.java
View File

@ -1,5 +1,7 @@
package cn.keepbx.jpom.socket.top;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.text.StrSpliter;
import cn.hutool.core.util.StrUtil;
import cn.hutool.cron.CronUtil;
import cn.hutool.cron.Scheduler;
@ -15,8 +17,10 @@ import com.sun.management.OperatingSystemMXBean;
import javax.websocket.Session;
import java.io.IOException;
import java.lang.management.ManagementFactory;
import java.math.BigDecimal;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
/**
@ -68,9 +72,9 @@ public class TopManager {
String topInfo;
if (AbstractCommander.OS_INFO.isLinux()) {
String result = AbstractCommander.getInstance().execCommand("top -b -n 1");
topInfo = getTopInfo(result);
topInfo = getTopMonitor(result);
} else {
topInfo = getWindowsTop();
topInfo = getWindowsMonitor();
}
send(topInfo);
} catch (Exception e) {
@ -84,7 +88,12 @@ public class TopManager {
watch = true;
}
public static String getWindowsTop() {
/**
* 获取windows 监控
*
* @return 返回cpu占比和内存占比
*/
public static String getWindowsMonitor() {
// https://docs.oracle.com/javase/7/docs/jre/api/management/extension/com/sun/management/OperatingSystemMXBean.html
OperatingSystemMXBean operatingSystemMXBean = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
long totalPhysicalMemorySize = operatingSystemMXBean.getTotalPhysicalMemorySize();
@ -97,29 +106,23 @@ public class TopManager {
JSONObject jsonObject = new JSONObject();
jsonObject.put("top", true);
JSONArray memory = new JSONArray();
JSONObject mem1 = new JSONObject();
mem1.put("name", "占用内存");
mem1.put("value", totalPhysicalMemorySize - freePhysicalMemorySize);
JSONObject mem2 = new JSONObject();
mem2.put("name", "空闲内存");
mem2.put("value", freePhysicalMemorySize);
memory.add(mem1);
memory.add(mem2);
JSONObject cpu1 = new JSONObject();
cpu1.put("name", "占用cpu");
cpu1.put("value", systemCpuLoad);
JSONObject cpu2 = new JSONObject();
cpu2.put("name", "空闲cpu");
cpu2.put("value", 1 - systemCpuLoad);
memory.add(putObject("占用内存", totalPhysicalMemorySize - freePhysicalMemorySize));
memory.add(putObject("空闲内存", freePhysicalMemorySize));
JSONArray cpus = new JSONArray();
cpus.add(cpu1);
cpus.add(cpu2);
cpus.add(putObject("占用cpu", systemCpuLoad));
cpus.add(putObject("空闲cpu", 1 - systemCpuLoad));
jsonObject.put("memory", memory);
jsonObject.put("cpu", cpus);
return jsonObject.toJSONString();
}
public static String getTopInfo(String content) {
/**
* linux 监控
*
* @param content top信息
* @return 返回cpu占比和内存占比
*/
public static String getTopMonitor(String content) {
if (StrUtil.isEmpty(content)) {
return "top查询失败";
}
@ -128,25 +131,145 @@ public class TopManager {
JSONObject jsonObject = new JSONObject();
if (length >= 2) {
String cpus = split[2];
JSONArray cpu = getCpu(cpus);
//cpu占比
JSONArray cpu = getLinuxCpu(cpus);
jsonObject.put("cpu", cpu);
}
if (length >= 3) {
String mem = split[3];
JSONArray memory = getMemory(mem);
//内存占比
JSONArray memory = getLinuxMemory(mem);
jsonObject.put("memory", memory);
}
jsonObject.put("top", true);
return jsonObject.toJSONString();
}
/**
* 将windows的tasklist转为集合
*
* @param result 进程信息
*/
public static JSONArray formatWindowsProcess(String result) {
List<String> list = StrSpliter.splitTrim(result, "\n", true);
if (list.size() < 3) {
return null;
}
JSONArray array = new JSONArray();
for (int i = 0; i < list.size(); i++) {
List<String> memList = StrSpliter.splitTrim(list.get(2), " ", true);
String name = memList.get(0);
if (!name.endsWith(".exe")) {
continue;
}
JSONObject item = new JSONObject();
item.put("pid", memList.get(1));
item.put("COMMAND", name);
//使用内存 kb
String mem = memList.get(4).replace(",", "");
long aLong = Convert.toLong(mem, 0L);
item.put("RES", aLong / 1024 + " MB");
String status = memList.get(6);
if ("RUNNING".equalsIgnoreCase(status)) {
item.put("S", "运行");
} else if ("SUSPENDED".equalsIgnoreCase(status)) {
item.put("S", "睡眠");
} else if ("NOT RESPONDING".equalsIgnoreCase(status)) {
item.put("S", "无响应");
} else {
item.put("S", "未知");
}
item.put("USER", memList.get(7));
item.put("TIME", memList.get(8));
item.put("PR", -1);
item.put("NI", -1);
item.put("VIRT", -1);
item.put("SHR", -1);
OperatingSystemMXBean operatingSystemMXBean = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
//最近jvmcpu使用率
double processCpuLoad = operatingSystemMXBean.getProcessCpuLoad() * 100;
if (processCpuLoad <= 0) {
processCpuLoad = 0;
}
item.put("CPU", String.format("%.2f", processCpuLoad) + "%");
//服务器总内存
long totalMemorySize = operatingSystemMXBean.getTotalPhysicalMemorySize();
double v = new BigDecimal(aLong).divide(new BigDecimal(totalMemorySize / 1024), 4, BigDecimal.ROUND_HALF_UP).doubleValue() * 100;
item.put("MEM", String.format("%.2f", v) + "%");
if (v <= 0) {
item.put("MEM", 0);
}
array.add(item);
}
return array;
}
/**
* 将linux的top信息转为集合
*
* @param top top
*/
public static JSONArray formatLinuxTop(String top) {
List<String> list = StrSpliter.splitTrim(top, "\n", true);
if (list.size() < 5) {
return null;
}
//top信息名称栏
String topName = list.get(5);
List<String> nameList = StrSpliter.splitTrim(topName, " ", true);
JSONArray array = new JSONArray();
for (int j = 6; j < list.size(); j++) {
String ram = list.get(j);
List<String> ramList = StrSpliter.splitTrim(ram, " ", true);
if (ramList.size() < nameList.size()) {
continue;
}
JSONObject item = new JSONObject();
for (int i = 0; i < nameList.size(); i++) {
String name = nameList.get(i);
String value = ramList.get(i);
if (i == 0) {
item.put("pid", value);
continue;
}
name = name.replaceAll("%", "").replace("+", "");
if ("VIRT".equalsIgnoreCase(name) || "RES".equalsIgnoreCase(name) || "SHR".equalsIgnoreCase(name)) {
value = Convert.toLong(value) / 1024 + " MB";
}
if ("<EFBFBD>".equals(name)) {
name = "S";
}
if ("S".equalsIgnoreCase(name)) {
if ("S".equalsIgnoreCase(value)) {
value = "睡眠";
} else if ("R".equalsIgnoreCase(value)) {
value = "运行";
} else if ("T".equalsIgnoreCase(value)) {
value = "跟踪/停止";
} else if ("Z".equalsIgnoreCase(value)) {
value = "僵尸进程 ";
} else if ("D".equalsIgnoreCase(value)) {
value = "不可中断的睡眠状态 ";
}
}
if ("CPU".equalsIgnoreCase(name) || "MEM".equalsIgnoreCase(name)) {
value += "%";
}
item.put(name, value);
}
array.add(item);
}
return array;
}
/**
* 获取内存信息
*
* @param info 内存信息
* @return 内存信息
*/
private static JSONArray getMemory(String info) {
private static JSONArray getLinuxMemory(String info) {
if (StrUtil.isEmpty(info)) {
return null;
}
@ -178,7 +301,7 @@ public class TopManager {
* @param info cpu信息
* @return cpu信息
*/
private static JSONArray getCpu(String info) {
private static JSONArray getLinuxCpu(String info) {
if (StrUtil.isEmpty(info)) {
return null;
}

31
src/main/resources/vm/welcome.vm
View File

@ -62,6 +62,7 @@
</div>
</div>
</form>
<table class="layui-table" id="tab_monitor" lay-filter="tab_monitor"></table>
##<div class="layui-container">
## <div class="terminal"></div>
##</div>
@ -96,6 +97,36 @@
});
}
table.render({
id: 'tab_monitor',
elem: '#tab_monitor',
url: '/processList',
// height: 'full-52',
even: true,
where: apiWhere,
cols: [[
{field: 'pid', title: '进程id', sort: true},
{field: 'USER', title: '所有者',},
{field: 'PR', title: '优先级',},
{field: 'NI', title: 'nice值'},
{field: 'VIRT', title: '使用虚拟内存'},
{field: 'RES', title: '使用物理内存',},
{field: 'SHR', title: '共享内存'},
{field: 'S', title: '进程状态'},
{field: 'CPU', title: '占用CPU',},
{field: 'MEM', title: '占用物理内存'},
{field: 'TIME', title: '时间总计'},
{field: 'COMMAND', title: '进程名称'}
]],
loading: true,
method: 'POST',
response: {
statusCode: 200
},
done: function (data) {
}
});
function linkSocket(status) {
if (!ws) {
ws = new WebSocket("ws://" + window.location.host + "/console/$userInfo/system");