Java如何使用Semaphore实现资源限流_Java高并发限流策略实例-java教程-PHP中文网

Java如何使用Semaphore实现资源限流_Java高并发限流策略实例

P粉602998670

发布： 2025-11-30 04:17:19

原创

735人浏览过

Semaphore是Java中用于控制并发访问资源的工具，通过许可机制限制线程数量。示例中用tryAcquire实现API调用限流，最多3个并发，超出则拒绝；可结合超时避免阻塞。适用于连接池、接口限流等场景，需确保release在finally执行，适合轻量级限流需求。

java如何使用semaphore实现资源限流_java高并发限流策略实例

在高并发场景下，控制对共享资源的访问数量是保障系统稳定的关键。Java 提供了 Semaphore（信号量）工具类，可以有效实现资源的限流控制。它通过维护一组许可来限制同时访问特定资源的线程数量，适用于数据库连接池、接口调用频率控制、服务降级等场景。

什么是Semaphore？

Semaphore 是 java.util.concurrent 包中的一个同步工具，用于控制同时访问某一资源的线程数量。它内部维护了一组许可（permits），线程在访问资源前必须先获取许可，使用完成后释放许可。若没有可用许可，线程将被阻塞直到其他线程释放许可。

常用方法包括：

acquire()：获取一个许可，如果无可用许可则阻塞。
acquire(int permits)：获取指定数量的许可。
release()：释放一个许可。
release(int permits)：释放指定数量的许可。
tryAcquire()：尝试获取许可，立即返回是否成功，不阻塞。

使用Semaphore实现接口调用限流

假设我们有一个外部API接口，最多允许 3 个线程同时调用，超出则等待或拒绝。可以通过 Semaphore 控制并发数。

立即学习“Java免费学习笔记（深入）”；

示例代码：

import java.util.concurrent.Semaphore;

public class ApiRateLimiter {
    // 定义信号量，最多允许3个并发访问
    private static final Semaphore semaphore = new Semaphore(3);

    public void callExternalApi(String requestId) {
        if (!semaphore.tryAcquire()) {
            System.out.println("请求 " + requestId + " 被限流，当前并发已达上限");
            return;
        }

        try {
            System.out.println("请求 " + requestId + " 开始执行");
            // 模拟API调用耗时
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            semaphore.release();
            System.out.println("请求 " + requestId + " 执行完成，释放许可");
        }
    }

    public static void main(String[] args) {
        ApiRateLimiter limiter = new ApiRateLimiter();

        // 模拟10个并发请求
        for (int i = 1; i <= 10; i++) {
            new Thread(() -> limiter.callExternalApi(Thread.currentThread().getName())).start();
        }
    }
}

登录后复制

输出效果：

开拍

用AI制作口播视频

289

查看详情

前3个请求会立即执行。
后续请求因无可用许可，tryAcquire() 返回 false，直接被拒绝。
若使用 acquire()，则请求会等待，直到有线程释放许可。

结合超时机制避免无限等待

为防止线程长时间阻塞，可使用带超时的获取方式：

if (semaphore.tryAcquire(3, TimeUnit.SECONDS)) {
    try {
        // 执行业务逻辑
    } finally {
        semaphore.release();
    }
} else {
    System.out.println("请求超时，未能获取许可");
}

登录后复制

这种方式更适合对响应时间敏感的服务，避免因资源紧张导致请求堆积。