From f9b9f0639055a75345dacf9f118b51587b458c0d Mon Sep 17 00:00:00 2001
From: gaoyutao <duguprogromer@163.com>
Date: Thu, 15 Jan 2026 18:15:37 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=A3=81=E7=9B=98IOPS?=
 =?UTF-8?q?=E4=B8=8A=E6=8A=A5=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../tongran/agent/server/core/enums/MsgEnum.java    |  2 ++
 .../agent/server/netty/enpoint/AgentEndpoint.java   | 13 +++++++++++++
 2 files changed, 15 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 821d5f4..4e404a4 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
@@ -81,6 +81,8 @@ public enum MsgEnum {
 
     macvlan状态上报("MACVLAN_STATUS_RSP"),
 
+    iops结果上报("IOPS_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 3865b7e..8a15099 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
@@ -440,6 +440,19 @@ public class AgentEndpoint {
             return null;
         }
     }
+    @AgentDispatcher(msgId = MsgEnum.iops结果上报)
+    public class iopsResultHandler implements AgentHandler {
+        @Override
+        public UpMsgResponse upHandle(String data, String clientId) {
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("clientId", clientId);
+            jsonObject.put("dataType", MsgEnum.iops结果上报.getValue());
+            jsonObject.put("data", data);
+            MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
+            agentProducer.asyncSend(mqMsg);
+            return null;
+        }
+    }