如何录制并重放MongoDB请求？Go集成测试适配库求助

你提到的两个库均无法直接适配Mongo Go Driver的需求：

• go-replayers：仅支持HTTP/gRPC协议的录制重放，而MongoDB使用自定义BSON协议，无法直接兼容。
• copyist：针对基于database/sql接口的SQL数据库设计，Mongo Go Driver并未实现该接口，因此不适用。

针对你的需求，推荐以下可行方案：

1. 手动封装驱动接口+自定义录制重放 #

为Mongo Go Driver的核心操作（如Collection.Find、Collection.InsertOne等）定义抽象接口，在测试中通过中间层包装真实驱动，录制请求参数与响应结果并持久化到文件；重放测试时，中间层直接返回录制好的响应，无需连接真实集群。

示例核心思路：

// 定义抽象接口
type MongoCollection interface {
    Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error)
    InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
    // 按需添加其他操作方法
}

// 录制用的包装类
type RecordingCollection struct {
    realColl *mongo.Collection
    recorder *FileRecorder // 自定义录制器，负责序列化请求/响应到文件
}

// 实现Find方法并录制
func (rc *RecordingCollection) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error) {
    // 录制请求参数
    req := &FindRequest{Filter: filter, Options: opts}
    // 调用真实驱动
    res, err := rc.realColl.Find(ctx, filter, opts...)
    // 录制响应结果
    rc.recorder.Record("Find", req, res, err)
    return res, err
}

// 重放用的包装类
type ReplayCollection struct {
    records map[string][]Record // 加载录制好的记录
}

// 实现Find方法并返回录制的响应
func (rc *ReplayCollection) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error) {
    // 匹配录制的请求
    req := &FindRequest{Filter: filter, Options: opts}
    record := rc.matchRecord("Find", req)
    // 返回录制的响应和错误
    return record.Res.(*mongo.Cursor), record.Err
}

2. 网络层流量录制重放（复杂度较高） #

使用mitmproxy、tcpdump等工具捕获MongoDB的网络流量，通过协议解析工具还原请求与响应，测试时重放流量。这种方式需要熟悉MongoDB的BSON协议细节，适合对底层网络有了解的场景。

3. 临时容器替代真实集群（非严格重放，但高效） #

使用Testcontainers或dockertest启动临时MongoDB容器，测试前导入预定义的数据集快照，测试完成后销毁容器。虽然不是请求级别的录制重放，但能保证测试环境的一致性，避免依赖真实集群，是集成测试中常用的替代方案。

内容的提问来源于stack exchange，提问作者Aleksandar Jelić