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() ; } }