Map map = new HashMap<>();
for (int i = 0; i < 100; i++) {
map.put("account",IdUtils.genRandomNum(8));
map.put("password",IdUtils.genRandomNum(5));
HttpUtils.sendPost("http://localhost:8087/user/login", map);
System.out.println(i);
}
于是加一個(gè)簡(jiǎn)單的請(qǐng)求限流 順便學(xué)習(xí)相關(guān)技能
先引用相關(guān)jar包
io.github.forezp
distributed-limit-core
1.0.2
本地限流在配置文件 application.properties 中添加配置
limit.type: local
需要限流的Controller方法上添加注解
@Limit(identifier = "forezp", limtNum = 1, seconds = 5)
完事... 能達(dá)到需求了就ok
這里限流針對(duì)的是單個(gè)請(qǐng)求的簡(jiǎn)單限流，最好還是針對(duì)ip做限流
其他限流方式
令牌桶算法：
說(shuō)實(shí)話沒(méi)理解...
public class RateLimiterDemo {
private static RateLimiter limiter = RateLimiter.create(5);
public static void exec() {
limiter.acquire(1);
try {
// 處理核心邏輯
TimeUnit.SECONDS.sleep(1);
System.out.println("--" + System.currentTimeMillis() / 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
漏桶算法示例：
public class CountRateLimiterDemo1 {
private static AtomicInteger count = new AtomicInteger(0);
public static void exec() {
if (count.get() >= 5) {
System.out.println("請(qǐng)求過(guò)多！"+System.currentTimeMillis()/1000);
} else {
count.incrementAndGet();
try {
//處理核心邏輯
TimeUnit.SECONDS.sleep(1);
System.out.println("--"+System.currentTimeMillis()/1000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
count.decrementAndGet();
}
}
}
}
記錄下代碼，方面下次使用。
詳情請(qǐng)閱讀原作者：點(diǎn)我
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://www.ezyhdfw.cn/yun/76856.html
