MongoDB에 연결

몽고클라이언트

0} 클래스를 사용하여 MongoDB에 연결하고 통신할 수 있습니다.MongoClient

MongoClients.create() 0} 메서드를 사용하여 을 MongoClient 구성합니다.

최대 연결 수와 같은 모든 리소스 사용량 제한은 개별 MongoClient 인스턴스에 적용됩니다.

0}의 동작을 제어하는 데 사용할 수 있는 다양한 설정에 대해 알아보려면 MongoClient MongoClient 설정에 대한가이드를 참조하세요 .

연결 URI

연결 URI는 드라이버가 MongoDB 배포에 연결하는 데 사용하는 일련의 지침을 제공합니다. 이는 MongoDB에 연결하는 방법과 연결된 동안 작동하는 방법에 대해 드라이버에 지시합니다. 다음 그림에서는 샘플 연결 URI의 각 부분을 설명합니다.

이 예시에서는 DNS SRV 레코드가 있는 MongoDB deployment에 연결합니다. 자세한 내용은 DNS 시드 목록 연결 형식 문서를 참조하세요. 이 형식은 배포 유연성을 제공하고 클라이언트를 재구성하지 않고도 서버를 순환적으로 변경할 수 있는 기능을 제공합니다.

DNS SRV 주소가 없는 인스턴스 또는 복제본 세트에 연결하는 경우 프로토콜에 표준 연결 문자열 형식을 지정하는 mongodb를 사용해야 합니다.

암호 기반 인증 메커니즘을 사용하는 경우 프로토콜 다음에는 연결 문자열에 자격 증명이 포함됩니다. user의 값을 사용자 이름으로 바꾸고 pass를 비밀번호로 바꿉니다. 인증 메커니즘에 자격 증명이 필요하지 않은 경우 연결 URI에서 이 부분을 생략합니다.

연결 URI의 다음 부분은 호스트 이름 또는 IP 주소를 지정하고 그 뒤에 MongoDB 인스턴스의 포트를 지정합니다. 이 예에서 sample.host 은 호스트 이름을 나타내고 27017 은 포트 번호입니다. 이 값을 MongoDB 인스턴스의 포인트 정보로 바꿉니다.

연결 URI의 마지막 부분에는 연결 옵션이 매개변수로 포함되어 있습니다. 이 예시에서는 두 가지 연결 옵션을 설정합니다: maxPoolSize=20 및 w=majority. 연결 옵션에 대한 자세한 내용은 이 가이드의 연결 옵션 섹션으로 건너뜁니다.

Atlas 연결 예시

Atlas에서 MongoDB deployment에 연결하려면 클라이언트를 생성합니다. MongoClientSettings 객체를 MongoClients.create() 생성자에 전달하여 연결 문자열과 기타 클라이언트 옵션을 사용하는 클라이언트를 만들 수 있습니다.

MongoClientSettings 0} 객체를 인스턴스화하려면 빌더 메서드를 사용하여 연결 문자열 및 기타 클라이언트 옵션을 지정한 다음 build() 메서드를 호출하세요. 연결 URI를 지정하려면 applyConnectionString() 메서드를 빌더에 연결하세요.

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

다음 코드는 Atlas의 MongoDB deployment에 연결할 때 연결 문자열과 Stable API 클라이언트 옵션을 지정하고 연결이 성공했는지 확인하는 방법을 보여줍니다.

package fundamentals;
import com.mongodb.*;
import org.bson.BsonDocument;
import org.bson.BsonInt64;
import org.bson.Document;
import org.bson.conversions.Bson;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoDatabase;
public class MongoClientConnectionExample {
    public static void main(String[] args) {
        // Replace the placeholder with your Atlas connection string
        String uri = "<connection string>";
        // Construct a ServerApi instance using the ServerApi.builder() method
        ServerApi serverApi = ServerApi.builder()
                .version(ServerApiVersion.V1)
                .build();
        MongoClientSettings settings = MongoClientSettings.builder()
                .applyConnectionString(new ConnectionString(uri))
                .serverApi(serverApi)
                .build();
        // Create a new client and connect to the server
        try (MongoClient mongoClient = MongoClients.create(settings)) {
            MongoDatabase database = mongoClient.getDatabase("admin");
            try {
                // Send a ping to confirm a successful connection
                Bson command = new BsonDocument("ping", new BsonInt64(1));
                Document commandResult = database.runCommand(command);
                System.out.println("Pinged your deployment. You successfully connected to MongoDB!");
            } catch (MongoException me) {
                System.err.println(me);
            }
        }
    }
}

MongoDB에 연결하는 다른 방법

Atlas에서 호스팅되지 않는 단일 MongoDB 배포서버 또는 복제본 세트에 연결하는 경우, 다음 섹션에서 연결 방법을 확인하세요.

ConnectionString connectionString = new ConnectionString("mongodb://host1:27017,host2:27017,host3:27017/");
MongoClient mongoClient = MongoClients.create(connectionString);

ServerAddress seed1 = new ServerAddress("host1", 27017);
ServerAddress seed2 = new ServerAddress("host2", 27017);
ServerAddress seed3 = new ServerAddress("host3", 27017);
MongoClientSettings settings = MongoClientSettings.builder()
        .applyToClusterSettings(builder ->
               builder.hosts(Arrays.asList(seed1, seed2, seed3)))
        .build();
MongoClient mongoClient = MongoClients.create(settings);