wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3345: 添加限流

Browse Source
This commit is contained in:
yanglin 2025-02-08 09:41:48 +08:00
parent 8483b955b2
commit 97e99dcb3f
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
im-center-server/src/main/java/cn/axzo/im/group/support/GroupRateLimiter.java
View File

@ -68,11 +68,9 @@ public class GroupRateLimiter implements InitializingBean {
}
public void acquire() {
long beginMs = System.currentTimeMillis();
rateLimiter.acquire();
long deltaMs = System.currentTimeMillis() - beginMs;
if (deltaMs > 1000)
notification.send("{} wait too long to acquire rate limiter: {}ms", name, deltaMs);
double seconds = rateLimiter.acquire();
if (seconds > 1)
notification.send("{} wait too long to acquire rate limiter: {} seconds", name, seconds);
}
}