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 控制并发数。
立即学习“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();
}
}
}
输出效果：
- 前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 实现限流简单高效，适合中小型项目或作为基础组件嵌入复杂系统中。掌握其原理和使用方式，能有效提升系统的稳定性与容错能力。
