K8S集群进行分布式负载测试

在Kubernetes集群中进行分布式负载测试通常涉及以下步骤：

1. 创建一个部署（Deployment）或者状态集（StatefulSet）定义你的应用容器镜像。
2. 创建服务（Service）以使你的应用可以被负载测试工具访问。
3. 使用分布式负载测试工具，如Locust、JMeter或者K6等。

以下是一个简单的示例，使用Deployment和Service部署一个应用，并使用Locust进行分布式负载测试。

首先，创建一个Deployment和Service定义文件：

apiVersion: apps/v1
kind: Deployment
metadata:
  name: example-app
spec:
  replicas: 3
  selector:
    matchLabels:
      app: example-app
  template:
    metadata:
      labels:
        app: example-app
    spec:
      containers:
      - name: example-app
        image: your-image/example-app:latest
        ports:
        - containerPort: 80
 
---

apiVersion: v1
kind: Service
metadata:
  name: example-app-service
spec:
  selector:
    app: example-app
  ports:
    - protocol: TCP
      port: 80
      targetPort: 80
  type: LoadBalancer

然后，使用Locust进行分布式负载测试。创建一个Locust文件（例如locustfile.py）：

from locust import HttpUser, TaskSet, task
 
class WebsiteTasks(TaskSet):
    @task
    def index(self):
        self.client.get("/")
 
class WebsiteUser(HttpUser):
    tasks = [WebsiteTasks]
    min_wait = 5000
    max_wait = 15000

最后，运行Locust负载测试。在含有Locust文件的目录下执行：

locust --host=http://example-app-service-loadbalancer-ip

替换example-app-service-loadbalancer-ip为你的Service的外部IP或者DNS名。使用Web界面配置用户数和每秒请求数（RPS），然后启动测试。