From d579f85eeed350fcbe9963b911db424f9c5371de Mon Sep 17 00:00:00 2001
From: gaoyutao <duguprogromer@163.com>
Date: Thu, 22 Jan 2026 17:58:31 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=BD=91=E7=BB=9C=E4=B8=8A?=
 =?UTF-8?q?=E6=8A=A5=E9=87=8D=E8=AF=95=EF=BC=8C=E5=92=8Ctcpdump=E7=BB=93?=
 =?UTF-8?q?=E6=9E=9C=E4=B8=8A=E6=8A=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../agent/server/core/enums/MsgEnum.java      |  4 +++
 .../server/netty/enpoint/AgentEndpoint.java   | 30 +++++++++++++++++++
 2 files changed, 34 insertions(+)

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 4e404a4..7536e9a 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
@@ -41,6 +41,8 @@ public enum MsgEnum {
 
     网络上报("NET"),
 
+    网络上报重试("NET_RECOVER"),
+
     挂载上报("POINT"),
 
     系统其他上报("OTHER_SYSTEM"),
@@ -83,6 +85,8 @@ public enum MsgEnum {
 
     iops结果上报("IOPS_RESULT"),
 
+    tcpdump结果上报("TCPDUMP_RESULT"),
+
     多网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 8a15099..eb31488 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
@@ -214,6 +214,22 @@ public class AgentEndpoint {
                     .content(json.toString()).build();
         }
     }
+    @AgentDispatcher(msgId = MsgEnum.网络上报重试)
+    public class NetRecoverHandler implements AgentHandler {
+        @Override
+        public UpMsgResponse upHandle(String data, String clientId) {
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("clientId", clientId);
+            jsonObject.put("dataType", MsgEnum.网络上报重试.getValue());
+            jsonObject.put("data", data);
+            MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
+            agentProducer.asyncSend(mqMsg);
+            JSONObject json = new JSONObject();
+            json.put("resCode",1);
+            return UpMsgResponse.builder().clientId(clientId).dataType(MsgEnum.采集上报应答.getValue())
+                    .content(json.toString()).build();
+        }
+    }
 
     @AgentDispatcher(msgId = MsgEnum.挂载上报)
     public class PointHandler implements AgentHandler {
@@ -454,6 +470,20 @@ public class AgentEndpoint {
         }
     }
 
+    @AgentDispatcher(msgId = MsgEnum.tcpdump结果上报)
+    public class tcpdumpResultHandler implements AgentHandler {
+        @Override
+        public UpMsgResponse upHandle(String data, String clientId) {
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("clientId", clientId);
+            jsonObject.put("dataType", MsgEnum.tcpdump结果上报.getValue());
+            jsonObject.put("data", data);
+            MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
+            agentProducer.asyncSend(mqMsg);
+            return null;
+        }
+    }
+