1
auto OP 贴个代码:
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { log.info("==================进来了==================="); String luaScript = buildLuaScript(); ServerHttpRequest request = exchange.getRequest(); String path = request.getPath().value(); List<String> excludUrls = properties.getExcludUrls(); // 路径在不限流列表中,直接跳过 if (CollectionUtils.isNotEmpty(excludUrls) && excludUrls.contains(path)) { return chain.filter(exchange); } String ip = HostUtil.getRequesHost2(request); Thread.sleep(20000); Number count = redissonService.executeLua(luaScript, Collections.singletonList(path+"_"+ip), properties.getCount(), properties.getPeriod()); .....省略部分 } |
2
devswork 2021 年 12 月 7 日
用自带的 RequestRateLimiterGatewayFilterFactory 进行限流
|
5
ouyc 2021 年 12 月 7 日
看下 CPU 多少核心的,开始测试时核心是不是都跑满了
|
6
rapperx2 2021 年 12 月 7 日
应该是 cpu 打满导致的
|
8
securityCoding 2021 年 12 月 8 日 via Android
lua 脚本发出来
|
9
auto OP @zt52875287 当时测试的时候,高并发下 RequestRateLimiterGatewayFilterFactory 用的 redistemplate 似乎一直占着 redis 连接,导致项目中其他地方使用的 redission 重试几次以后超时报错了。想过重写 RequestRateLimiterGatewayFilterFactory 的 RedisRateLimiter ,但是有点麻烦就换了种简单的方法
|