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) { // 计算总流入速率