线上压测需用CountDownLatch实现齐发式并发、CyclicBarrier支持多轮脉冲爆发、Semaphore控制瞬时并发上限,并须绕开直连生产库、未标识流量、监控缺失及无熔断等风险。

在线上压测中模拟瞬间高并发流量冲击,核心是用好 Java 并发工具类(如 CountDownLatch、CyclicBarrier、Semaphore)精准控制线程启动时机和并发强度,避免流量“摊开”成匀速请求,失去“瞬时打满”的压测意义。
用 CountDownLatch 实现“齐发式”并发启动
这是最常用也最直观的方式:让所有线程就位后,统一收到“开始”信号再同时发起请求。
关键点:
- 主线程创建
CountDownLatch latch = new CountDownLatch(1); - 每个压测线程启动后立即调用
latch.await()阻塞等待; - 所有线程就绪后(可通过另一个计数器确认),主线程调用
latch.countDown()—— 瞬间唤醒全部线程; - 配合
ExecutorService控制线程数,例如Executors.newFixedThreadPool(500)模拟 500 并发用户。
注意:线程创建+阻塞本身有微小耗时,500 线程通常能在毫秒级内完成齐发,满足“瞬间冲击”要求。
用 CyclicBarrier 实现多轮同步爆发
当需要反复触发多波次高并发(比如每秒来一波 300 请求,持续 10 秒),CyclicBarrier 更合适——它支持重用,且能自然卡住每轮的起始点。
示例逻辑:
- 初始化
CyclicBarrier barrier = new CyclicBarrier(300, () -> { /* 可选:记录本轮开始时间 */ }); - 每个线程执行任务前调用
barrier.await(); - 当第 300 个线程到达,屏障打开,全部线程同时执行 HTTP 请求;
- 下一轮循环继续,无需重建 barrier。
相比 CountDownLatch,它更适合“脉冲式”压测场景,也更容易统计每轮响应延迟。
用 Semaphore 控制瞬时并发上限 + 流量整形
单纯齐发可能超出下游承载能力,或想模拟“带限流保护的突发流量”,可用 Semaphore 做细粒度并发闸门。
典型用法:
- 初始化
Semaphore semaphore = new Semaphore(200),表示最多允许 200 个请求同时在途; - 每个线程在发请求前调用
semaphore.acquire()(可设超时避免死等); - 请求完成后立即
semaphore.release(); - 配合定时任务或循环,持续提交新线程,但实际并发数被严格限制在 200 内。
这种方式不追求“绝对同时”,而是稳定维持目标并发水位,更贴近真实业务突发中的系统表现。
线上压测必须绕开的坑
工具用对只是第一步,线上环境要格外谨慎:
- 禁止直连生产数据库:压测流量必须走影子库、读写分离只读库,或加特殊 header 触发 mock 返回;
-
标识压测流量:所有请求带上
X-Test-Mode: true等标头,网关/中间件据此隔离日志、降级非核心逻辑; - 监控先行:启动前确保 CPU、GC、DB 连接数、慢 SQL、接口 P99 延迟等指标已接入监控面板,能实时看到冲击反应;
- 快速熔断机制:代码里嵌入简单阈值判断(如连续 5 次超时 > 2s),自动停止当前线程池,防止雪崩。
不复杂但容易忽略。

















