使用Resilience4j RateLimiter为RxJava3 Flowable降速未生效问题求助

你遇到的限速失效问题，核心是完全误解了Resilience4j官方提供的RateLimiterOperator的作用粒度：

• 这个算子的许可消耗是订阅级别的，也就是说，只会在下游发起订阅请求时，向RateLimiter申请1次许可。只要拿到这1个许可，整个流后续发射的所有元素都会被直接放行，算子不会对流中的每一个单独的元素做许可校验和扣减。
• 对应你当前的代码：下游发起订阅时，RateLimiter在第一个刷新周期内有5个可用许可，算子仅申请扣减1个许可就直接放开了整条流的链路。剩下的100个元素由上游Flowable.interval(1ms)按自身节奏发射，本身只需要100ms左右就能全部发完，加上日志打印开销，不到200ms就全部处理完成，和你配置的"每秒最多放行5个元素"的规则没有任何关联。

注：这种订阅级限流的设计，本来是用来限制"每秒最多发起多少次远程调用/方法执行"的，和你需要的"限制每秒最多处理多少个流元素"是完全不同的场景。

• 不要把RateLimiterOperator当成通用的流元素限速工具，它的设计目标是包裹"单次执行的业务逻辑"，比如用流包装一个HTTP调用、一个数据库查询，这个场景下每一次订阅对应一次业务执行，扣减1个许可，限速逻辑是完全生效的。
• 如果需要对持续推送的元素流做逐元素限速，直接使用默认算子一定无法达到预期效果。

要实现逐元素的速率控制，需要在流的串行处理逻辑中，对每一个元素单独申请并扣减RateLimiter许可，参考实现如下：

@Test
public void simpleReactiveWithRateLimiter() {
    RateLimiterConfig rateLimiterConfig = RateLimiterConfig.custom()
        .limitForPeriod(5) // 每周期最多放行5个元素
        .limitRefreshPeriod(Duration.ofSeconds(1)) // 每1秒刷新一次许可
        .timeoutDuration(Duration.ofMillis(100)) // 申请许可最多等待100ms
        .build();
    RateLimiterRegistry rateLimiterRegistry = RateLimiterRegistry.of(rateLimiterConfig);
    RateLimiter rateLimiter = rateLimiterRegistry.rateLimiter("tenPerSec", rateLimiterConfig);
    Flowable.interval(1, TimeUnit.MILLISECONDS)
        .takeWhile(f -> f < 100)
        // 必须用concatMap保证串行处理，一次仅处理一个元素
        .concatMap(item -> {
            // 对每个元素单独申请1个许可
            boolean acquired = rateLimiter.acquirePermission(rateLimiterConfig.getTimeoutDuration());
            if (!acquired) {
                // 申请超时未拿到许可时，抛出和原生算子一致的异常
                return Flowable.error(new RequestNotPermitted(rateLimiter));
            }
            return Flowable.just(item);
        })
        .blockingSubscribe(i -> log.info("Received {}", i));
}

• 逐元素申请许可时，必须使用concatMap这类串行执行的操作符，不能使用并发执行的flatMap——否则并发场景下会同时申请多个许可，导致实际放行速率超过配置阈值。
• 如果需要调整限速的粒度，可以在申请许可时传入对应的permitCount，比如每个元素需要消耗3个许可，就调用rateLimiter.acquirePermission(3, timeoutDuration)。
• 这种实现下的实际运行效果：100个元素会被按照"每秒5个"的节奏逐步放行，总耗时约20秒，完全符合配置的限速规则。

内容的提问来源于stack exchange，提问作者Darek