1、契约压测概述

什么是契约压测

契约压测（Contract Load Testing）是一种将服务契约与性能压测相结合的测试方法。它要求压测脚本严格遵循服务提供方定义的接口契约（如 OpenAPI / Swagger、gRPC Proto、Thrift IDL），在构造请求、校验响应、模拟负载时，所有行为都与契约中的字段类型、边界值、必填约束、状态码定义保持一致。

与传统的“凭经验写压测脚本”不同，契约压测的核心主张是：压测脚本本身就是契约的忠实实现。任何偏离契约的请求构造或响应断言，都会导致压测结果失真，甚至引发误判。

契约压测 vs 功能测试

契约压测与功能测试虽然都依赖契约，但目标、执行方式和关注点截然不同。下表从六个关键维度进行对比：

契约压测在微服务中的价值

在微服务架构中，服务间依赖复杂，单个接口的性能瓶颈可能被上游调用链放大。契约压测在以下四个场景中具有不可替代的价值：

1. 契约一致性保障： 压测脚本与生产代码使用同一份契约定义，避免“压测通过、上线失败”的契约偏差问题。
2. 容量规划依据： 基于契约的精确请求模型，压测结果可直接换算为生产环境的预估容量，支撑扩缩容决策。
3. SLA 验证： 在压测过程中持续监控 P99 延迟、错误率、吞吐量，验证服务是否满足约定的性能 SLA。
4. 回归防护： 每次契约变更后，自动触发契约压测，快速发现因契约升级导致的性能退化。

契约压测在微服务调用链中的位置

下图展示了契约压测在微服务调用链中的典型介入点：压测引擎通过契约仓库获取服务契约，构造合法请求，对目标服务施加负载，同时收集性能指标。

契约压测的典型工作流程

一次完整的契约压测通常包含以下六个步骤，每个步骤都与契约紧密相关：

Go 语言中的契约压测实践

在 Go 生态中，契约压测通常结合 testing 包与第三方契约工具实现。以下是一个基于 oapi-codegen 生成的客户端代码进行压测的简化示例：

package loadtest

import (
    "testing"
    "time"
    "net/http"
    "github.com/deepmap/oapi-codegen/pkg/testutil"
)

// 契约压测：验证 /api/v1/users 端点在 100 QPS 下的表现
func TestContractLoad_GetUsers(t *testing.T) {
    // 1. 从契约生成客户端（假设已通过 oapi-codegen 生成）
    client := NewAPIClient("http://target-service:8080")

    // 2. 定义压测参数
    concurrency := 10
    duration := 30 * time.Second
    qps := 100

    // 3. 启动并发请求
    results := make(chan testutil.Result, concurrency*100)
    for i := 0; i < concurrency; i++ {
        go func() {
            ticker := time.NewTicker(time.Second / time.Duration(qps/concurrency))
            defer ticker.Stop()
            for range ticker.C {
                // 4. 按契约构造请求
                resp, err := client.GetUsersWithResponse(nil)
                if err != nil {
                    results <- testutil.Result{Error: err}
                    continue
                }
                // 5. 校验响应契约（状态码、结构）
                if resp.StatusCode() != http.StatusOK {
                    t.Errorf("unexpected status: %d", resp.StatusCode())
                }
                results <- testutil.Result{
                    StatusCode: resp.StatusCode(),
                    Duration:   resp.HTTPResponse().Duration,
                }
            }
        }()
    }

    // 6. 收集并分析结果
    time.Sleep(duration)
    close(results)
    // 此处可接入 prometheus / influxdb 记录指标
}