Java用Semaphore实现限流，高并发实例详解

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

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

什么是Semaphore？

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

常用方法包括：

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

使用Semaphore实现接口调用限流

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

示例代码：

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

输出效果：

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

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

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

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

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

实际应用场景建议

Semaphore 适合以下限流场景：

• 限制数据库连接数。
• 控制对第三方服务的并发调用。
• 保护本地计算资源密集型任务（如文件解析、图像处理）。

注意点：

• 确保每次 acquire() 都对应一次 release()，建议放在 finally 块中。
• 根据实际资源容量设置许可数量，过大失去限流意义，过小影响吞吐。
• 与 Hystrix、Sentinel 等熔断限流框架相比，Semaphore 更轻量，但缺乏统计监控能力。

基本上就这些。使用 Semaphore 实现限流简单高效，适合中小型项目或作为基础组件嵌入复杂系统中。掌握其原理和使用方式，能有效提升系统的稳定性与容错能力。