package com.dy.rtuMw.server.local.localProtocol;
|
|
import com.dy.common.threadPool.TreadPoolFactory;
|
import com.dy.common.util.*;
|
import com.dy.rtuMw.server.forTcp.TcpDownCommandCache;
|
import com.dy.rtuMw.server.forTcp.TcpSessionCache;
|
import com.dy.rtuMw.server.rtuData.RtuDataCache;
|
import com.dy.rtuMw.server.rtuData.TaskPool;
|
import oshi.SystemInfo;
|
import oshi.hardware.HardwareAbstractionLayer;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2024/7/29 11:07
|
* @Description
|
*/
|
public class MwInfoDeal {
|
|
public MwInfoVo deal() throws Exception{
|
MwInfoVo vo = new MwInfoVo() ;
|
Integer[] info = TcpSessionCache.info() ;
|
vo.rtuTotalConnect = info[0] ;
|
vo.rtuTotalOnLine = info[1] ;
|
vo.rtuTotalOffLine = info[2] ;
|
|
info = TcpDownCommandCache.info() ;
|
vo.comTotalDown = info[0] ;
|
vo.comNoResTotalDownByOnLine = info[1] ;
|
vo.comNoResTotalDownByOffLine = info[2] ;
|
|
vo.dataTotalUp = RtuDataCache.size() ;
|
|
info = TreadPoolFactory.pool_short_state() ;
|
vo.shortCurThread = info[0] ;
|
vo.shortMaxThread = info[1] ;
|
vo.shortMinThread = info[2] ;
|
|
info = TreadPoolFactory.pool_long_state() ;
|
vo.longCurThread = info[0] ;
|
vo.longMaxThread = info[1] ;
|
vo.longMinThread = info[2] ;
|
|
vo.taskTreePoolTotalInstance = TaskPool.totalTasks() ;
|
|
SystemInfo si = new SystemInfo();
|
HardwareAbstractionLayer hal = si.getHardware();
|
vo.memInfoVo = SysMemoryUtil.info(hal.getMemory());
|
vo.sysInfoVo = SysSysUtil.info();
|
vo.jvmInfoVo = SysJvmUtil.info();
|
|
return vo ;
|
}
|
}
|
