请教一个 springcloud gateway 限流的问题 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
auto
V2EX    Java

请教一个 springcloud gateway 限流的问题

  •  1
     
  •   auto 2021-12-07 14:36:27 +08:00 2895 次点击
    这是一个创建于 1454 天前的主题,其中的信息可能已经有所发展或是发生改变。
    现在小弟通过 springcloud gateway 的 filter 中进行 ip 限流,但是在本地( idea )测试的时候发现,用 jemeter 1 秒 20 次并发请求接口,通过网关的时候,filter 中一次最多只能 8 个线程并发进入 filter 方法,其余的都会等这 8 个执行完毕以后再开始,这样就会导致我设置 1s 最多 10ci 并发的控制失效。请问这个是为啥啊
    第 1 条附言    2021-12-07 16:11:47 +08:00
    在 jemeter 发出 20 个并发请求以后,就会连续打印 8 个 log.info 中的内容,然后就会等待,直到这 8 个线程结束后才又接收请求
    第 2 条附言    2021-12-07 16:15:36 +08:00
    在 jemeter 发出 20 个并发请求以后,就会连续打印 8 个 log.info 中的内容,然后就会等待,直到这 8 个线程结束后才又接收请求
    12 条回复    2021-12-08 14:50:29 +08:00
    auto
        1
    auto  
    OP
       2021-12-07 14:37:53 +08:00
    贴个代码:
    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());
    .....省略部分
    }
    devswork
        2
    devswork  
       2021-12-07 16:19:04 +08:00
    用自带的 RequestRateLimiterGatewayFilterFactory 进行限流
    auto
        3
    auto  
    OP
       2021-12-07 16:47:37 +08:00
    @devswork 默认用的 redistemplate ,项目中用的 redission ,两者一起用有点问题,所以换了种方案。
    auto
        4
    auto  
    OP
       2021-12-07 16:48:21 +08:00
    @devswork RequestRateLimiterGatewayFilterFactory 用的 redistemplate
    ouyc
        5
    ouyc  
       2021-12-07 17:01:43 +08:00
    看下 CPU 多少核心的,开始测试时核心是不是都跑满了
    rapperx2
        6
    rapperx2  
       2021-12-07 17:17:35 +08:00
    应该是 cpu 打满导致的
    zt5b79527
        7
    zt5b79527  
       2021-12-07 17:48:03 +08:00
    @auto 同一个项目里 redistemplate 、redission 应该可以同时存在,只要别 A 存的数据 B 去取,就应该不影响
    securityCoding
        8
    securityCoding  
       2021-12-08 00:09:42 +08:00 via Android
    lua 脚本发出来
    auto
        9
    auto  
    OP
       2021-12-08 14:11:41 +08:00
    @zt52875287 当时测试的时候,高并发下 RequestRateLimiterGatewayFilterFactory 用的 redistemplate 似乎一直占着 redis 连接,导致项目中其他地方使用的 redission 重试几次以后超时报错了。想过重写 RequestRateLimiterGatewayFilterFactory 的 RedisRateLimiter ,但是有点麻烦就换了种简单的方法
    auto
        10
    auto  
    OP
       2021-12-08 14:16:15 +08:00
    @ouyc 电脑 8 核的 cpu ,本地 springboot 自带的 tomcat 映射的线程数等于本机 cpu 核数?
    ouyc
        11
    ouyc  
       2021-12-08 14:47:37 +08:00
    @auto 再怎么设置线程数,能同时跑的也只有 CPU 核心数。你这压测的和程序在同一台机子,不好判断 CPU 是怎么分配的。
    PS:最好找台生产环境的配置部署测试
    ouyc
        12
    ouyc  
       2021-12-08 14:50:29 +08:00
    @auto 如果只是测试限流,可以试下在网关写一个测试接口,请求了就返回,防止接口耗时过长
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     2785 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 28ms UTC 14:04 PVG 22:04 LAX 06:04 JFK 09:04
    Do have faith in what you're doing.
    ubao msn snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86