| New file | 
|  |  |  | 
|---|
|  |  |  | package com.dy.rtuMw.server.local.localProtocol; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.dy.common.util.*; | 
|---|
|  |  |  | import lombok.Data; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.util.LinkedList; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * @Author: liurunyu | 
|---|
|  |  |  | * @Date: 2024/7/29 10:54 | 
|---|
|  |  |  | * @Description | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Data | 
|---|
|  |  |  | public class MwInfoVo { | 
|---|
|  |  |  | public Integer rtuTotalConnect ;//已经连接过中间件的RTU总数(包括在线与离线的) | 
|---|
|  |  |  | public Integer rtuTotalOnLine ;//在线RTU总数 | 
|---|
|  |  |  | public Integer rtuTotalOffLine ;//离线RTU总数 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public Integer comTotalDown ;//缓存的下行命令总数 | 
|---|
|  |  |  | public Integer comNoResTotalDownByOnLine;//RTU在线,但对其下行命令未收到应答的总数 | 
|---|
|  |  |  | public Integer comNoResTotalDownByOffLine;//RTU离线,但对其下行命令未收到应答的总数 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public Integer dataTotalUp ;//上行数据在缓存中还未处理的总数 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public Integer shortCurThread = 0 ;//短线程池当前线程数 | 
|---|
|  |  |  | public Integer shortMaxThread = 0 ;//短线程池最大线程数 | 
|---|
|  |  |  | public Integer shortMinThread = 0 ;//短线程池最小线程数 | 
|---|
|  |  |  | public Integer longCurThread = 0 ;//长线程池当前线程数 | 
|---|
|  |  |  | public Integer longMaxThread = 0 ;//长线程池最大线程数 | 
|---|
|  |  |  | public Integer longMinThread = 0 ;//长线程池最小线程数 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public Integer taskTreePoolTotalInstance = 0 ;//任务树池任务实例总数 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public SysJvmUtil.JvmInfoVo jvmInfoVo ; | 
|---|
|  |  |  | public SysMemoryUtil.MemInfoVo memInfoVo ; | 
|---|
|  |  |  | public SysSysUtil.SysInfoVo sysInfoVo ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public String toString(){ | 
|---|
|  |  |  | StringBuilder sb = new StringBuilder() ; | 
|---|
|  |  |  | sb.append("通信中间件运行信息:\n"); | 
|---|
|  |  |  | sb.append("   连接RTU总数:" + rtuTotalConnect + "\n"); | 
|---|
|  |  |  | sb.append("      在线RTU总数:" + rtuTotalOnLine + "\n"); | 
|---|
|  |  |  | sb.append("      离线RTU总数:" + rtuTotalOffLine + "\n"); | 
|---|
|  |  |  | sb.append("   下行未应答命令总数:" + comTotalDown + "\n"); | 
|---|
|  |  |  | sb.append("      在线RTU未应答命令总数:" + comNoResTotalDownByOnLine + "\n"); | 
|---|
|  |  |  | sb.append("      离线RTU未应答命令总数:" + comNoResTotalDownByOffLine + "\n"); | 
|---|
|  |  |  | sb.append("   上行未处理数据总数:" + dataTotalUp + "\n"); | 
|---|
|  |  |  | sb.append("   短线程池当前线程数:" + shortCurThread + "\n"); | 
|---|
|  |  |  | sb.append("      短线程池配置最大线程数:" + shortMaxThread + "\n"); | 
|---|
|  |  |  | sb.append("      短线程池配置最小线程数:" + shortMinThread + "\n"); | 
|---|
|  |  |  | sb.append("   长线程池当前线程数:" + longCurThread + "\n"); | 
|---|
|  |  |  | sb.append("      长线程池配置最大线程数:" + longMaxThread + "\n"); | 
|---|
|  |  |  | sb.append("      长线程池配置最小线程数:" + longMinThread + "\n"); | 
|---|
|  |  |  | sb.append("   任务树池任务实例总数:" + taskTreePoolTotalInstance + "\n"); | 
|---|
|  |  |  | if(jvmInfoVo != null){ | 
|---|
|  |  |  | sb.append(jvmInfoVo.toString()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(memInfoVo != null){ | 
|---|
|  |  |  | sb.append(memInfoVo.toString()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(sysInfoVo != null){ | 
|---|
|  |  |  | sb.append(sysInfoVo.toString()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | sb.append("\n"); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return sb.toString() ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|