使用resilience4j实现节流/去抖动

Resilience4j 是一个轻量级的容错库，专为 Java 8 和函数式编程设计。它提供了诸如断路器、限流器、重试和去抖动等功能，以帮助开发者构建更健壮和弹性的应用程序。

节流（Throttling）

节流是一种控制操作频率的策略，确保在一定时间内只执行有限数量的操作。这在处理高并发请求或防止资源过载时非常有用。

基础概念

节流器（Throttler）：限制操作执行速率的组件。
令牌桶算法：常见的节流算法，通过维护一个令牌桶来控制请求速率。

优势

防止系统过载。
平滑流量高峰。
提高系统的稳定性和响应性。

类型

固定窗口计数器：在固定时间窗口内允许固定数量的请求。
滑动窗口计数器：更精确地控制请求速率，考虑了时间窗口内的请求分布。
令牌桶：通过生成和消耗令牌来控制请求速率。

应用场景

API 请求限制。
数据库查询限制。
文件上传/下载速度限制。

示例代码

import io.github.resilience4j.throttle.Throttle;
import io.github.resilience4j.throttle.ThrottleConfig;
import io.github.resilience4j.throttle.ThrottleRegistry;

import java.time.Duration;
import java.util.function.Supplier;

public class ThrottlingExample {
    public static void main(String[] args) {
        // 配置节流器
        ThrottleConfig config = ThrottleConfig.custom()
                .limitForPeriod(10) // 每秒允许10个请求
                .limitRefreshPeriod(Duration.ofSeconds(1)) // 每秒刷新一次限制
                .timeoutDuration(Duration.ofSeconds(1)) // 超时时间
                .build();

        ThrottleRegistry registry = ThrottleRegistry.of(config);
        Throttle throttle = registry.throttle("myThrottle");

        Supplier<String> restrictedCall = Throttle.decorateSupplier(throttle, () -> "Hello World");

        for (int i = 0; i < 20; i++) {
            try {
                System.out.println(restrictedCall.get());
            } catch (Exception e) {
                System.out.println("Throttled!");
            }
            try {
                Thread.sleep(100); // 模拟请求间隔
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

去抖动（Debouncing）

去抖动是一种防止频繁触发操作的策略，通常用于处理连续事件（如窗口调整、滚动、键盘输入等），确保只有在事件停止一段时间后才执行操作。

基础概念

去抖动器（Debouncer）：延迟执行操作直到一段时间内没有新的触发。
延迟时间：在这段时间内如果没有新的触发，则执行操作。

优势

减少不必要的计算和资源消耗。
提高应用程序的性能和响应性。

类型

简单去抖动：固定延迟时间后执行操作。
带立即执行的去抖动：首次触发立即执行，后续触发延迟执行。

应用场景

搜索框输入建议。
窗口调整大小后的布局计算。
按钮点击防抖。

示例代码

import io.github.resilience4j.debounce.Debouncer;
import io.github.resilience4j.debounce.DebouncerConfig;
import io.github.resilience4j.debounce.DebouncerRegistry;

import java.time.Duration;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.function.Supplier;

public class DebouncingExample {
    public static void main(String[] args) {
        // 配置去抖动器
        DebouncerConfig config = DebouncerConfig.custom()
                .waitDuration(Duration.ofSeconds(1)) // 延迟1秒执行
                .build();

        DebouncerRegistry registry = DebouncerRegistry.of(config);
        Debouncer debouncer = registry.deboncer("myDebouncer");

        ExecutorService executor = Executors.newSingleThreadExecutor();

        Supplier<String> debouncedCall = Debouncer.decorateSupplier(debouncer, () -> "Hello World");

        for (int i = 0; i < 5; i++) {
            final int index = i;
            executor.submit(() -> {
                System.out.println("Triggered " + index);
                debouncedCall.get();
            });
            try {
                Thread.sleep(200); // 模拟触发间隔
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        executor.shutdown();
    }
}