package com.dy.rtuMw.server.local.localProtocol;
|
|
import com.dy.common.threadPool.TreadPoolFactory;
|
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;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2024/7/29 11:07
|
* @Description
|
*/
|
public class MwInfoDeal {
|
|
public MwInfoVo deal(){
|
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() ;
|
|
return vo ;
|
}
|
}
|
