연결 가이드

연결 URI의 부분

다음 예시에서는 샘플 연결 URI의 각 부분을 설명합니다.

이 예에서는 표준 연결 문자열 형식을 지정하는 프로토콜에 mongodb을 사용합니다. 배포서버의 유연성을 높이고 클라이언트를 재구성하지 않고도 서버를 교대로 변경할 수 있는 기능을 원하는 경우 DNS 시드 목록 연결 형식을 사용할 수도 있습니다.

연결 문자열의 다음 부분에는 데이터베이스 사용자 이름과 암호 기반 인증을 사용하는 경우 암호가 포함됩니다. user의 값을 데이터베이스 사용자 이름으로, pass의 값을 비밀번호로 교체하세요. 사용자 이름과 비밀번호가 필요하지 않은 인증 메커니즘을 사용하는 경우 연결 URI에서 이 부분을 생략합니다.

연결 문자열의 다음 부분은 MongoDB 인스턴스의 호스트 이름 또는 IP 주소 및 포트를 지정합니다. 앞의 예에서는 sample.host을 호스트 이름으로, 27017을 포트로 사용합니다. 이 값을 MongoDB 인스턴스의 포인트 정보로 바꿉니다.

연결 문자열의 마지막 부분은 연결 및 인증 옵션을 지정합니다. 위의 예에서는 maxPoolSize=20 및 w=majority의 두 가지 연결 옵션을 설정했습니다. 연결 옵션에 대해 자세히 알아보려면 이 가이드의 연결 옵션 섹션을 참조하세요.

연결 예시

MongoDB에 연결하려면 클라이언트를 만들어야 합니다. 클라이언트는 연결을 관리하고 데이터베이스 명령을 실행합니다.

ClientOptions 객체를 Connect() 생성자에 전달하여 연결 문자열과 기타 클라이언트 옵션을 사용하는 클라이언트를 만들 수 있습니다.

연결 URI를 지정하려면 이를 새 ClientOptions 인스턴스를 반환하는 ApplyURI() 메서드에 전달하세요. 다른 옵션을 설정하려면 options 패키지에서 관련 도우미 메서드를 호출하세요.

연결 옵션에 대한 자세한 내용은 Connection Options(연결 옵션) 섹션을 참조하십시오. 클라이언트 생성에 대한 자세한 내용은 클라이언트 및 Connect()에 대한 API 설명서를 참조하십시오.

새 서버 버전으로 업그레이드할 때 호환성이 손상되는 변경을 방지하기 위해 Stable API 버전을 옵션으로 설정할 수 있습니다. Stable API 기능에 대해 자세히 알아보려면 Stable API 페이지를 참조하세요.

다음 코드는 Atlas 연결 문자열과 Stable 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 Server에 연결하기

개발 목적으로 로컬 머신에서 MongoDB 서버를 실행해야 하는 경우 다음 단계를 완료하세요.

1. MongoDB Server의 Community 또는 Enterprise 버전을 다운로드하세요.

2. MongoDB 서버를 설치하고 구성합니다.

3. 서버를 시작합니다.

MongoDB Server를 성공적으로 시작한 후에는 드라이버 연결 코드에 연결 문자열을 지정하세요.

MongoDB Server가 로컬에서 실행되는 경우 연결 문자열("mongodb://localhost:<port>")을 사용할 수 있습니다. 여기서 <port>는 서버가 들어오는 연결을 수신하도록 구성한 포트 번호입니다.

다른 호스트 이름이나 IP 주소를 지정하려면 연결 문자열에 대한 서버 매뉴얼 항목을 참조하세요.

서버에 연결할 수 있는지 여부를 테스트하려면 앞의 코드 예시에서 연결 문자열을 localhost 연결 문자열로 바꿉니다.

복제본 세트에 연결

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 옵션이 있는 Client에서 Timeout 옵션을 설정하는 방법을 보여줍니다.

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)