3

我尝试使用 golang 驱动程序连接到 mongodb Atlas。

tlsConfig := &tls.Config{}

var mongoURI = "mongodb+srv://admin:password@prefix.mongodb.net:27017/dbname"
dialInfo, err := mgo.ParseURL(mongoURI)
if err != nil {
    panic(err)
}
dialInfo.DialServer = func(addr *mgo.ServerAddr) (net.Conn, error) {
    conn, err := tls.Dial("tcp", addr.String(), tlsConfig)
    return conn, err
}

session, err := mgo.DialWithInfo(dialInfo)
if err != nil {
    println("error")
    log.Fatal(err)
}
_ = session
c := session.DB("Token").C("_Users")
user := &User{firstName: "username"}
err = c.Insert(user)
if err != nil {
    println("error Again")
}

我没有收到未连接的错误。我想知道可能是什么原因。任何帮助表示赞赏。

我尝试使用以下代码创建 DialInfo

    dialInfo := &mgo.DialInfo{
    Addrs:     []string{"prefix.mongodb.net:27017"},
    Database:  "dbname",
    Mechanism: "SCRAM",
    Timeout:   10 * time.Second,
    Username:  "admin",
    Password:  "passwrd",
}

现在我没有可访问的服务器

4

1 回答 1

4

我只能看到代码开始了，然后什么都没有

正如您所知道的，这是因为默认情况下DialInfo的超时时间为零。该调用将永远阻塞，等待建立连接。您还可以使用以下命令指定超时：

dialInfo.Timeout = time.Duration(30)
session, err := mgo.DialWithInfo(dialInfo)

现在我没有可访问的服务器

这是因为globalsign/mgo目前还不支持 SRV连接字符串 URI。见问题 112。您可以使用非 srv 连接 URI 格式（MongoDB v3.4），请参阅相关问题StackOverflow: 41173720。

如果您想使用 SRV 连接 URI 进行连接，则可以使用mongo-go-driver ，例如：

mongoURI := "mongodb+srv://admin:password@prefix.mongodb.net/dbname?ssl=true&retryWrites=true"

client, err := mongo.NewClient(options.Client().ApplyURI(mongoURI))
if err != nil {
    log.Fatal(err)
}
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
err = client.Connect(ctx)
defer client.Disconnect(ctx)

if err != nil {
    log.Fatal(err)
}
database := client.Database("go")
collection := database.Collection("atlas")

以上示例兼容当前版本 v1.0.0

于 2018-08-29T02:23:16.243 回答