前言：
locust2.0+教程：001 - 安装和目录结构
locust2.0+教程：002 - 快速使用
locust2.0+教程：003 - headless无界面模式
locust2.0+教程：004 - 等待时间和执行权重
locust2.0+教程：005 - on_start和on_stop
locust2.0+教程：006 - @tag标签装饰器
简介：单台机器不够模拟足够多的用户时，locust支持运行在多台机器中进行压力测试。master 模式中使用--master标记来启用一个 Locust 实例。这个实例将会运行你启动测试的 Locust 交互网站并查看实时统计数据。master 节点的机器自身不会模拟任何用户。必须使用 --worker 标记启动一台到多台 LocustWoker 机器节点，与标记 --master-host 一起使用(指出master机器的IP/hostName)。
常用的做法是在一台独立的机器中运行master，在woker机器中每个处理器内核运行一个woker实例。
注意：master 和 worker 之间必须是同一个局域网，并且locust版本一致，同时需要包含一样的locust 的测试文件。master 和每一台 woker 机器，在运行分布式测试时都必须要有 locust 的测试文件。
例如：
源码locust 的测试文件：
from locust import HttpUser, between, tag, task
class QuickstartUser(HttpUser):
wait_time = between(1, 2)
@tag("tag1")
@task
def hello(self):
self.client.get("/hello")
@tag("tag2")
@task
def new(self):
self.client.get("/new")
@tag("tag3")
@task
def world(self):
self.client.get("/world")
if __name__ == '__main__':
import os
os.system("locust -f my_locust.py --web-host=172.23.32.1")
服务端sanic源码：main.py
from sanic import Sanic
import datetime
from sanic import response
app = Sanic('myapp')
@app.get('/hello')
def hello(request):
time = str(datetime.datetime.now())[:-7]
return response.json({"hello time": time})
@app.get('/new')
def new(request):
time = str(datetime.datetime.now())[:-7]
return response.json({"new time": time})
@app.get('/world')
def world(request):
time = str(datetime.datetime.now())[:-7]
return response.json({"world time": time})
if __name__ == "__main__":
app.run(host="10.0.8.9", port=8000, auto_reload=True)
启动master节点：注意这里的ip使用内网ip即可。
图片
locust -f my_locust.py --master --web-host=172.23.32.1
图片
启动worker：
locust -f my_locust.py --worker --master-host=172.23.32.1
图片
启动worker后，每新增一个，web界面都会累加一个worker：
图片
web执行压测脚本的情况：
图片
服务端sanic的响应情况：
图片
再次强调：
1、master 节点的机器自身不会模拟任何用户。
2、master 和 worker 之间必须是同一个局域网。
3、master 和 worker 安装的 locust 版本要一致。
4、同时需要包含一样的locust 的测试文件。
微信公众号：玩转测试开发
欢迎关注，共同进步，谢谢！
网友评论