diff --git a/src/main/java/com/sqx/common/aspect/IpAccessCounter.java b/src/main/java/com/sqx/common/aspect/IpAccessCounter.java index b6d96355..cd0f1705 100644 --- a/src/main/java/com/sqx/common/aspect/IpAccessCounter.java +++ b/src/main/java/com/sqx/common/aspect/IpAccessCounter.java @@ -63,12 +63,19 @@ public class IpAccessCounter { removeCount.set(0); long currentTime = System.currentTimeMillis(); Set removedIps = new HashSet<>(); - IP_ACCESS_TIMES.forEach((ip, accessTimes) -> { + for (Map.Entry> entry : IP_ACCESS_TIMES.entrySet()) { + List accessTimes = entry.getValue(); accessTimes.removeIf(time -> currentTime - time > ONE_MINUTE); if (accessTimes.isEmpty()) { - removedIps.add(ip); + removedIps.add(entry.getKey()); } - }); + } +// IP_ACCESS_TIMES.forEach((ip, accessTimes) -> { +// accessTimes.removeIf(time -> currentTime - time > ONE_MINUTE); +// if (accessTimes.isEmpty()) { +// removedIps.add(ip); +// } +// }); removedIps.forEach(IP_ACCESS_TIMES::remove); Set removedBlacklistIps = new HashSet<>();