From 75c5db6f91110c4b8d6b4a4560bf4ec426eae477 Mon Sep 17 00:00:00 2001 From: gaoyutao Date: Tue, 30 Dec 2025 18:21:52 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0pppoe=E7=8A=B6=E6=80=81?= =?UTF-8?q?=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 | 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 86afdff..821d5f4 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 @@ -79,6 +79,8 @@ public enum MsgEnum { 修改frp配置文件应答("UPDATE_FRP_RSP"), + macvlan状态上报("MACVLAN_STATUS_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 79ab279..3865b7e 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 @@ -427,6 +427,19 @@ public class AgentEndpoint { return null; } } + @AgentDispatcher(msgId = MsgEnum.macvlan状态上报) + public class upMacvlanStatusHandler implements AgentHandler { + @Override + public UpMsgResponse upHandle(String data, String clientId) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("clientId", clientId); + jsonObject.put("dataType", MsgEnum.macvlan状态上报.getValue()); + jsonObject.put("data", data); + MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build(); + agentProducer.asyncSend(mqMsg); + return null; + } + }