go语言连接Mongodb副本集的代码

以下是使用 Go 语言连接 MongoDB 副本集的代码示例：

package main

import (
	"context"
	"fmt"
	"time"

	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
	"go.mongodb.org/mongo-driver/mongo/readpref"
)

func main() {
	// 设置连接选项
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()

	// 设置副本集的连接选项
	uri := "mongodb://host1:port1,host2:port2,host3:port3/?replicaSet=rs0"
	clientOptions := options.Client().ApplyURI(uri)

	// 连接 MongoDB
	client, err := mongo.Connect(ctx, clientOptions)
	if err != nil {
		fmt.Println("Failed to connect MongoDB:", err)
		return
	}

	// 检查连接是否可用
	err = client.Ping(ctx, readpref.Primary())
	if err != nil {
		fmt.Println("Failed to ping MongoDB:", err)
		return
	}

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

其中，`uri` 变量需要设置为你的 MongoDB 副本集的连接字符串，具体格式为：

mongodb://host1:port1,host2:port2,host3:port3/?replicaSet=rs0

其中 `host1:port1`, `host2:port2`, `host3:port3` 是你的 MongoDB 副本集的主机名和端口号，`rs0` 是你的副本集名称。