Agent/tr-agent-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加关闭采集指令处理

Browse Source
This commit is contained in:
qiminbao
2025-09-13 11:51:04 +08:00
parent 12442fde4a
commit 4c90fa9089
2 changed files with 30 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java
+8 -8
View File
@@ -40,21 +40,21 @@ public enum MsgEnum {
交换机上报("SWITCHBOARD"), 交换机上报("SWITCHBOARD"),
开启系统采集("SYSTEM_COLLECT_START"), 开启或更新系统采集("SYSTEM_COLLECT_START"),
开启系统采集应答("SYSTEM_COLLECT_START_RSP"), 开启或更新系统采集应答("SYSTEM_COLLECT_START_RSP"),
关闭系统采集("SYSTEM_COLLECT_STOP"), 关闭所有系统采集("SYSTEM_COLLECT_STOP"),
关闭系统采集应答("SYSTEM_COLLECT_STOP_RSP"), 关闭所有系统采集应答("SYSTEM_COLLECT_STOP_RSP"),
开启交换机采集("SWITCH_COLLECT_START"), 开启或更新交换机采集("SWITCH_COLLECT_START"),
开启交换机采集应答("SWITCH_COLLECT_START_RSP"), 开启或更新交换机采集应答("SWITCH_COLLECT_START_RSP"),
关闭交换机采集("SWITCH_COLLECT_STOP"), 关闭所有交换机采集("SWITCH_COLLECT_STOP"),
关闭交换机采集应答("SWITCH_COLLECT_STOP_RSP"), 关闭所有交换机采集应答("SWITCH_COLLECT_STOP_RSP"),
告警设置("ALARM_SET"), 告警设置("ALARM_SET"),
src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java
+22 -6
View File
@@ -199,7 +199,7 @@ public class AgentEndpoint {
} }
} }
@AgentDispatcher(msgId = MsgEnum.开启系统采集) @AgentDispatcher(msgId = MsgEnum.开启或更新系统采集)
public class SystemCollectStartHandler implements AgentHandler { public class SystemCollectStartHandler implements AgentHandler {
@Override @Override
public String downHandle(String data, String clientId) { public String downHandle(String data, String clientId) {
@@ -207,13 +207,13 @@ public class AgentEndpoint {
} }
} }
@AgentDispatcher(msgId = MsgEnum.开启系统采集应答) @AgentDispatcher(msgId = MsgEnum.开启或更新系统采集应答)
public class SystemCollectStartRspHandler implements AgentHandler { public class SystemCollectStartRspHandler implements AgentHandler {
@Override @Override
public UpMsgResponse upHandle(String data, String clientId) { public UpMsgResponse upHandle(String data, String clientId) {
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("clientId", clientId); jsonObject.put("clientId", clientId);
jsonObject.put("dataType", MsgEnum.开启系统采集应答.getValue()); jsonObject.put("dataType", MsgEnum.开启或更新系统采集应答.getValue());
jsonObject.put("data", data); jsonObject.put("data", data);
MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build(); MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
agentProducer.asyncSend(mqMsg); agentProducer.asyncSend(mqMsg);
@@ -221,7 +221,15 @@ public class AgentEndpoint {
} }
} }
@AgentDispatcher(msgId = MsgEnum.开启交换机采集) @AgentDispatcher(msgId = MsgEnum.关闭所有系统采集)
public class SystemCollectClosetHandler implements AgentHandler {
@Override
public String downHandle(String data, String clientId) {
return data;
}
}
@AgentDispatcher(msgId = MsgEnum.开启或更新交换机采集)
public class SwitchCollectStartHandler implements AgentHandler { public class SwitchCollectStartHandler implements AgentHandler {
@Override @Override
public String downHandle(String data, String clientId) { public String downHandle(String data, String clientId) {
@@ -229,13 +237,13 @@ public class AgentEndpoint {
} }
} }
@AgentDispatcher(msgId = MsgEnum.开启交换机采集应答) @AgentDispatcher(msgId = MsgEnum.开启或更新交换机采集应答)
public class SwitchCollectStartRspHandler implements AgentHandler { public class SwitchCollectStartRspHandler implements AgentHandler {
@Override @Override
public UpMsgResponse upHandle(String data, String clientId) { public UpMsgResponse upHandle(String data, String clientId) {
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
jsonObject.put("clientId", clientId); jsonObject.put("clientId", clientId);
jsonObject.put("dataType", MsgEnum.开启交换机采集应答.getValue()); jsonObject.put("dataType", MsgEnum.开启或更新交换机采集应答.getValue());
jsonObject.put("data", data); jsonObject.put("data", data);
MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build(); MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
agentProducer.asyncSend(mqMsg); agentProducer.asyncSend(mqMsg);
@@ -243,6 +251,14 @@ public class AgentEndpoint {
} }
} }
@AgentDispatcher(msgId = MsgEnum.关闭所有交换机采集)
public class SwitchCollectClosetHandler implements AgentHandler {
@Override
public String downHandle(String data, String clientId) {
return data;
}
}
@AgentDispatcher(msgId = MsgEnum.告警设置) @AgentDispatcher(msgId = MsgEnum.告警设置)
public class AlarmSetHandler implements AgentHandler { public class AlarmSetHandler implements AgentHandler {
@Override @Override