Semaphore在Java爬虫中作为本地并发节流器，控制单实例并发数，需与K8s HPA等外部系统协同实现弹性伸缩，不可跨Pod共享，许可数应动态配置并匹配连接池。
Java 中用 Semaphore 构建具备弹性伸缩能力的高并发爬虫引擎，核心不是靠它单独实现“弹性伸缩”，而是把它作为**本地并发节流器**，配合外部调度系统（如 Kubernetes HPA 或自研指标采集+扩缩逻辑）协同工作。Semaphore 本身不感知集群、不触发扩容，但它能稳定控制单个爬虫实例内的并发请求数，避免过载，为上层弹性决策提供可靠基础。
用 Semaphore 精准限流单机并发量
爬虫常受限于目标站点反爬策略、本地带宽、连接池资源等。直接开几百线程极易被封或崩溃。Semaphore 是最轻量、低开销的并发数控制器：
- 初始化时设定合理许可数，例如
new Semaphore(10)表示最多 10 个请求同时发出 - 每个爬取任务（如下载一个页面）前调用
semaphore.acquire()，获取许可后才发起 HTTP 请求 - 无论成功或失败，必须在
finally块中调用semaphore.release()，确保许可及时归还 - 可搭配
tryAcquire(long timeout, TimeUnit)设置超时，防止某个请求卡死长期占用许可
与外部弹性机制解耦协作
Semaphore 只管“本机别跑冒烟”，真正的弹性伸缩需由外部系统驱动：
- 在 Kubernetes 中，通过 Prometheus 抓取爬虫 Pod 的关键指标（如平均响应延迟、错误率、Semaphore 当前可用许可数
availablePermits()） - 配置 Custom Metrics 的 HPA，例如当
http_requests_per_second > 80且avg_latency_ms > 2000时触发扩容 - 每个新 Pod 启动后，自身 Semaphore 自动生效，无需中心协调——这是无状态设计的关键
- 缩容时，K8s 优雅终止 Pod，正在运行的任务可完成，许可自然释放，不会中断进行中的请求
避免常见误用，保障稳定性
实际部署中，几个细节容易导致弹性失效或资源浪费：
立即学习“Java免费学习笔记（深入）”；
- 别把 Semaphore 当全局锁：它只作用于当前 JVM 实例，跨 Pod 不共享。不要试图用它协调整个集群的并发数
-
许可数不能硬编码：应从配置中心或环境变量读取（如
SPIDER_CONCURRENCY=8），便于不同环境动态调整 -
区分 IO 密集型与 CPU 密集型阶段：解析 HTML、提取字段可能耗 CPU，此时可另设一个 CPU-bound Semaphore（如
new Semaphore(Runtime.getRuntime().availableProcessors())） - 配合连接池使用：HttpClient 或 OkHttp 的连接池最大空闲数、总连接数，应与 Semaphore 许可数大致匹配，避免许可已满但连接池还有余量，造成资源错配
结合熔断与退避提升弹性韧性
单纯限流不够，面对目标站不稳定，需叠加保护策略：
- 当连续 N 次请求失败（如 429 或超时），临时降低本机 Semaphore 许可数（调用
reducePermits()），进入“休眠模式” - 后台定时任务定期检查目标站健康度，恢复许可数（
release()多次或重建 Semaphore） - 与 Resilience4j 的 CircuitBreaker 配合：熔断开启时，直接拒绝新任务，不再尝试 acquire，减少无效等待
