连接指南

连接URI的各个部分

以下示例解释了示例连接URI的各个部分

在本示例中，我们使用使用mongodb作为协议，该协议指定了标准连接字符串格式。如果您需要更大的部署灵活性和在无需重新配置客户端的情况下更换服务器的能力，您还可以使用DNS种子列表连接格式。

连接字符串的下一部分包含您的数据库用户名以及如果您使用基于密码的认证，您的密码。将user的值替换为您数据库用户名，将pass的值替换为您密码。如果您使用不需要用户名和密码的认证机制，则省略此部分连接URI。

连接字符串的下一部分指定了MongoDB实例的主机名或IP地址以及端口号。在前面的示例中，我们使用sample.host作为主机名，使用27017作为端口号。将这些值替换为您MongoDB实例的对应值。

连接字符串的最后一部分指定了连接和认证选项。在示例中，我们设置了两个连接选项：maxPoolSize=20和w=majority。要了解更多关于连接选项的信息，请阅读本指南中的连接选项部分。

连接示例

要连接到MongoDB，您必须创建一个客户端。客户端管理您的连接并运行数据库命令。

您可以通过将 ClientOptions 对象传递给 Connect() 方法来创建使用您的连接字符串和其他客户端选项的客户端。

要指定您的连接 URI，将其传递给 ApplyURI() 方法，该方法返回一个新的 ClientOptions 实例。要设置其他任何选项，请从 options 包中的相关辅助方法调用。

有关连接选项的更多信息，请参阅 连接选项部分。有关创建客户端的更多信息，请参阅 Client 和 Connect().

您可以将稳定API版本设置为选项，以避免在升级到新服务器版本时出现破坏性更改。有关稳定API功能的更多信息，请参阅稳定API页面。

以下代码演示了如何创建一个客户端，该客户端使用Atlas连接字符串和稳定API版本，连接到MongoDB，并验证连接是否成功

// Connects to MongoDB and sets a Stable API version
package main
import (
	"context"
	"fmt"
	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)
// Replace the placeholder with your Atlas connection string
const uri = "<connection string>"
func main() {
	// Use the SetServerAPIOptions() method to set the Stable API version to 1
	serverAPI := options.ServerAPI(options.ServerAPIVersion1)
	opts := options.Client().ApplyURI(uri).SetServerAPIOptions(serverAPI)
	// Create a new client and connect to the server
	client, err := mongo.Connect(context.TODO(), opts)
	if err != nil {
		panic(err)
	}
	defer func() {
		if err = client.Disconnect(context.TODO()); err != nil {
			panic(err)
		}
	}()
	// Send a ping to confirm a successful connection
	var result bson.M
	if err := client.Database("admin").RunCommand(context.TODO(), bson.D{{"ping", 1}}).Decode(&result); err != nil {
		panic(err)
	}
	fmt.Println("Pinged your deployment. You successfully connected to MongoDB!")
}

连接到本地机器上的MongoDB服务器

如果您必须出于开发目的在本地机器上运行MongoDB服务器，请完成以下步骤

1. 下载MongoDB服务器的社区或企业版本。

2. 安装和配置 MongoDB服务器。

3. 启动服务器。

成功启动您的MongoDB服务器后，在驱动程序连接代码中指定您的连接字符串。

如果您的MongoDB服务器在本地运行，您可以使用连接字符串 "mongodb://localhost:"，其中 是您配置服务器监听传入连接的端口号。

如果您想指定不同的主机名或IP地址，请参阅我们服务器手册中关于 连接字符串 的条目。

为了测试您是否可以连接到服务器，请将上述代码示例中的连接字符串替换为您的本地连接字符串。

连接到副本集

MongoDB副本集部署是一组相互连接的实例，它们存储相同的数据集。此配置提供了数据冗余和高数据可用性。

要连接到副本集部署，指定每个实例的主机名和端口号，用逗号分隔，并在连接字符串中将副本集名称作为 replicaSet 参数的值。在以下示例中，主机名分别是 host1、host2 和 host3，端口号均为 27017。副本集名称为 myRS。

mongodb://host1:27017,host2:27017,host3:27017/?replicaSet=myRS

连接到副本集时，驱动程序默认执行以下操作

• 给定任何成员的地址时，发现所有副本集成员。

• 将操作发送到适当的成员，例如对 主节点 的写入指令。

单次超时设置

您可以在您的 Client 上设置单个 Timeout 选项，以使用 SetTimeout() 方法或指定连接URI字符串中的 timeoutMS 选项来控制单个操作可以执行的时间。如果未为针对同一实体的操作设置上下文，则 Database、Collection、Session、ChangeStream 和 Bucket 实例继承自 Client 的 Timeout 选项。

如果将具有截止时间的上下文传递到操作中，驱动程序将使用该上下文截止时间进行操作。如果没有上下文截止时间，则驱动程序将从给定上下文派生新的上下文，并使用在 Client 上设置的 Timeout 选项。

以下代码演示了如何使用SetTimeout选项在客户端上设置超时选项。

opts := options.Client().SetTimeout(5 * time.Second)

以下示例演示了如何使用URI选项设置单个超时，并执行继承此设置的运算操作。

uri := "mongodb://user:pass@sample.host:27017/?timeoutMS=5000"
client := mongo.Connect(context.TODO(), uri)
coll := client.Database("<db>").Collection("<collection>")
...
coll.InsertOne(context.Background(), doc)