通信中间件增加查询部分RTU在线情况内部命令

liurunyu

2024-10-23 dc86d90bdd25025ad44fc777c9956cac2e219bec

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
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() ;
    }
}