1. Locust压测工具概述

Locust是一款开源的负载测试工具，用Python编写，支持分布式压测场景。与传统的JMeter等工具不同，Locust采用代码定义用户行为模式，允许测试人员用Python编写复杂的压测逻辑。其核心特点是：

• 基于事件驱动的异步IO架构（gevent）
• 支持百万级并发模拟
• 提供实时Web UI监控
• 完全可扩展的分布式设计

我在电商大促前的全链路压测中，曾用Locust成功模拟过20万/秒的订单创建峰值。相比其他工具，Locust的轻量级架构和Python生态集成让它成为API和微服务压测的首选方案。

2. 核心架构解析

2.1 事件驱动模型

Locust底层使用gevent实现协程调度，每个虚拟用户（User）实际运行在greenlet微线程中。这种设计使得单机就能支撑数千并发连接。典型的工作流程：

from locust import HttpUser, task class WebsiteUser(HttpUser): @task def load_test(self): self.client.get("/api/order") # 每个请求都是非阻塞的

关键点：gevent通过monkey patch替换了标准库的阻塞IO调用，所有网络请求自动变为异步

2.2 分布式运行原理

Locust采用master-worker架构：

1. Master节点：负责协调测试、收集数据
2. Worker节点：实际执行压测脚本

启动命令示例：

# Master节点 locust -f script.py --master # Worker节点（可启动多个） locust -f script.py --worker --master-host=192.168.1.100

实测中发现，单个8核16G的worker节点大约能稳定支撑8000个并发用户。

3. 完整压测实战

3.1 测试场景设计

以电商下单接口为例，构建阶梯式压力模型：

from locust import LoadTestShape class SpikeShape(LoadTestShape): stages = [ {"duration": 60, "users": 1000, "spawn_rate": 50}, # 预热阶段 {"duration": 300, "users": 5000, "spawn_rate": 100}, # 平稳阶段 {"duration": 60, "users": 10000, "spawn_rate": 200} # 峰值冲击 ]

3.2 自定义指标采集

通过事件钩子扩展监控维度：

from locust import events @events.request.add_listener def track_response_time(request_type, name, response_time, response_length, **kwargs): if response_time > 1000: # 记录慢请求 log_slow_requests(name, response_time) @events.test_stop.add_listener def generate_report(**kwargs): export_to_prometheus()

4. 性能调优技巧

4.1 资源瓶颈排查

常见性能问题及解决方案：

4.2 高级配置参数

在locust.conf中调优：

[locust] heartbeat-liveness = 3 # worker存活检测阈值 stats-history-enabled = true # 开启历史统计

5. 企业级实践方案

5.1 CI/CD集成

在Jenkins pipeline中的典型用法：

stage('Load Test') { steps { sh 'locust -f perf_test.py --headless -u 5000 -r 100 -t 10m' perfReport sourceDataFiles: 'stats_history.csv' } }

5.2 监控大盘配置

推荐使用Grafana+Prometheus构建实时监控视图：

1. 通过locust-prometheus导出指标
2. 配置告警规则：
   • 当P99>500ms时触发预警
   • 错误率>1%时停止测试

6. 真实踩坑记录

1. Cookie共享问题
   默认情况下所有User共享Cookie，需要通过self.client.cookies.clear()在任务间清理状态

2. DNS缓存坑
   gevent的DNS解析有内存泄漏风险，建议在压测前预热DNS：

   import socket socket.gethostbyname('api.example.com')

3. 日志风暴规避
   高并发时控制日志级别：

   import logging logging.getLogger('locust').setLevel(logging.WARNING)

对于需要测试WebSocket或gRPC的场景，可以扩展locust-plugins库实现协议支持。在实际金融级压测中，我们通过自定义消息序列化模块将吞吐量提升了40%。