如何用Golang及MongoDriver解决IBM MongoDB的认证命令错误

看起来你遇到了一个挺棘手的间歇性认证问题——连接和Ping都正常，但偶尔读写操作会抛出认证失败的错误，而且相同配置在Python里完全没问题。结合你的环境（Go 1.13.6，Mongo驱动1.2.1，IBM MongoDB服务），我整理了几个可能的原因和对应的解决方案：

1. 首先修正MongoDB URI的格式错误 #

你的MONGO_DB_URI格式存在明显问题：

mongodb://username:password:port,host/dbname?authSource=admin&replicaSet=replset&connect=direct&alias=default

正确的URI格式应该是mongodb://<username>:<password>@<host>:<port>/<dbname>?xxx——你把@写成了:，导致驱动无法正确解析用户名密码和主机地址。虽然Python驱动可能对格式错误有更好的兼容性，但Go驱动的老版本（1.2.1）对格式要求更严格，这很可能是间歇性认证失败的根源。

修正后的URI示例：

mongodb://username:password@host:port/dbname?authSource=admin&replicaSet=replset&connect=direct&alias=default

2. 显式指定认证机制（适配IBM Cloud MongoDB） #

IBM Cloud的MongoDB服务通常使用SCRAM-SHA-1或SCRAM-SHA-256作为认证机制，而老版本的Go Mongo驱动可能默认使用的认证机制不匹配。你可以在创建client时显式指定认证信息，而不是完全依赖URI解析：

func ConnectDatabase() *mongo.Client {
    username := os.Getenv("MONGO_USER")
    password := os.Getenv("MONGO_PASS")
    uri := os.Getenv("MONGO_DB_URI")
    
    clientOptions := options.Client().ApplyURI(uri)
    // 显式设置认证凭证
    clientOptions.SetAuth(options.Credential{
        AuthSource:    "admin",
        Username:      username,
        Password:      password,
        AuthMechanism: "SCRAM-SHA-1", // 如果IBM用的是SHA-256就改成"SCRAM-SHA-256"
    })

    ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    defer cancel() // 别忘了取消上下文，避免资源泄漏
    
    client, err := mongo.Connect(ctx, clientOptions)
    if err != nil {
        log.Fatal(err)
    }

    ctxPing, cancelPing := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancelPing()
    err = client.Ping(ctxPing, readpref.Primary()) // Ping时指定主节点偏好，更准确
    if err != nil {
        log.Fatal(err)
        return nil
    }

    fmt.Println("Connected to MongoDB!")
    return client
}

3. 升级Mongo Go驱动版本 #

你使用的驱动版本1.2.1是2019年的老版本，存在不少已知的连接池和认证相关的bug，比如连接池中的空闲连接失效后重新认证失败的问题。升级到较新的v1.x稳定版本（比如v1.12.x或更高）可以大概率解决这类间歇性问题。

执行升级命令：

go get go.mongodb.org/mongo-driver/mongo@v1.12.1

4. 确保全局Client的正确使用 #

从你的代码来看，client应该是全局变量——一定要保证整个应用只创建一次Mongo Client，不要重复调用ConnectDatabase()创建多个client。重复创建会导致连接池混乱，进而引发认证问题。

另外，避免在操作时使用context.TODO()，尽量传递带超时的上下文，比如：

func FindAll(collectionName string, query bson.M, ctx context.Context) (*mongo.Cursor, error) {
    collection := client.Database("dbname").Collection(collectionName)
    return collection.Find(ctx, query)
}

调用时：

ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
defer cancel()
cur, err := mongo.GetCollection("collection_name").Find(ctx, createQuery())
if err != nil {
    log.Println(err.Error())
}

5. 调整连接池配置（可选） #

老版本驱动的默认连接池配置可能不适合IBM的MongoDB服务，你可以调整连接池的参数，避免空闲连接被服务端回收后无法重新认证：

clientOptions.SetMaxPoolSize(50)
clientOptions.SetMinPoolSize(10)
clientOptions.SetMaxConnIdleTime(10 * time.Minute) // 延长空闲连接超时时间
clientOptions.SetConnectTimeout(5 * time.Second)

验证步骤 #

1. 先修正URI格式，测试是否还会出现问题；
2. 如果问题依旧，显式指定认证机制；
3. 最后考虑升级驱动版本——这是解决老版本bug最彻底的方法。

内容的提问来源于stack exchange，提问作者Ebubekir Tabak