From fb27c1c0e02dd32f37ac1d32d467b36face5828c Mon Sep 17 00:00:00 2001 From: gaoyutao Date: Tue, 17 Mar 2026 17:59:08 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=B8=9A=E5=8A=A1=E6=B5=81?= =?UTF-8?q?=E9=87=8F=E5=AD=98=E5=82=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/tongran/rocketmq/handler/MessageHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java index 1457888..7c12aff 100644 --- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java @@ -205,7 +205,7 @@ public class MessageHandler { // 1. 构建快速查找的Map,使用MAC地址+网卡名称作为唯一键 Map tempMap = tempList.stream() .collect(Collectors.toMap( - tempItem -> generateKey(tempItem.getMac(), tempItem.getName()), + tempItem -> tempItem.getProcessName(), Function.identity(), (existing, replacement) -> existing )); @@ -233,7 +233,7 @@ public class MessageHandler { iface.setIpv6OutSpeed(null); // 使用MAC地址+网卡名称作为查找键 - String key = generateKey(iface.getMac(), iface.getName()); + String key = iface.getProcessName(); InitialNetBusinessTrafficTemp tempInfo = tempMap.get(key); if (tempInfo != null) { // 计算总流入速率