使用resilience4j实现节流/去抖动

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();
            }
        }
    }
}

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();
    }
}