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 limiter.callExternalApi(Thread.currentThread().getName())).start(); } }}
输出效果：
Pic Copilot
AI时代的顶级电商设计师，轻松打造爆款产品图片
158 查看详情 前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 实现限流简单高效，适合中小型项目或作为基础组件嵌入复杂系统中。掌握其原理和使用方式，能有效提升系统的稳定性与容错能力。
以上就是Java如何使用Semaphore实现资源限流_Java高并发限流策略实例的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1057763.html
微信扫一扫 
支付宝扫一扫 
