From c8980142d8479f92cd1fc96ffc3e9c092b2bdcb7 Mon Sep 17 00:00:00 2001 From: qiminbao Date: Tue, 28 Oct 2025 14:26:41 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=A4=9A=E7=BD=91IP=E6=8E=A2?= =?UTF-8?q?=E6=B5=8B=E4=B8=8A=E6=8A=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tongran/agent/server/core/enums/MsgEnum.java | 4 +++- .../agent/server/netty/enpoint/AgentEndpoint.java | 14 ++++++++++++++ 2 files changed, 17 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java b/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java index f254fad..1bbb9d7 100644 --- a/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java +++ b/src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java @@ -75,7 +75,9 @@ public enum MsgEnum { Agent版本更新("AGENT_VERSION_UPDATE"), - Agent版本更新应答("AGENT_VERSION_UPDATE_RSP"); + Agent版本更新应答("AGENT_VERSION_UPDATE_RSP"), + + 多网IP探测上报("NETWORK_DETECT"); private String value; diff --git a/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java b/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java index d767d9b..ea5b04b 100644 --- a/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java +++ b/src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java @@ -400,6 +400,20 @@ public class AgentEndpoint { } } + @AgentDispatcher(msgId = MsgEnum.多网IP探测上报) + public class DetectNetworkHandler implements AgentHandler { + @Override + public UpMsgResponse upHandle(String data, String clientId) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("clientId", clientId); + jsonObject.put("dataType", MsgEnum.多网IP探测上报.getValue()); + jsonObject.put("data", data); + MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build(); + agentProducer.asyncSend(mqMsg); + return null; + } + } +