MongoDB에 연결

전제 조건

이 가이드의 코드 예제를 실행하려면 다음 구성 요소를 설정해야 합니다.

• 연결할 MongoDB deployment 가 실행 어야 합니다. 예를 예시, 독립형 배포서버 에 연결하려면 실행 독립형 배포서버 에 액세스 이 있어야 합니다.

• 프로젝트 에 설치된 드라이버 종속성. 운전자 를 설치하는 방법을 학습 보려면 설치 가이드 를 참조하세요.

• 다음 가져오기 문:

  import com.mongodb.reactivestreams.client.MongoClients;
  import com.mongodb.reactivestreams.client.MongoClient;
  import com.mongodb.MongoClientSettings;
  import com.mongodb.ConnectionString;
  import com.mongodb.ServerAddress;
  import com.mongodb.MongoCredential;
  import java.util.Arrays;

몽고클라이언트

MongoClient 인스턴스 는 데이터베이스 에 대한 연결 풀을 나타냅니다. 여러 개의 동시 작업을 실행 하는 경우에도 MongoClient 인스턴스 는 하나만 필요합니다.

독립형 MongoDB 배포에 연결

다음 예제는 단일 MongoDB deployment에 연결하는 여러 가지 방법을 보여줍니다.

다음과 같은 방법으로 단일 MongoDB deployment 에 연결할 수 있습니다.

• 매개 변수 없이 MongoClient 객체를 인스턴스화하여 포트 27017 의 로컬 호스트에서 실행 중인 MongoDB 서버에 연결합니다.

  MongoClient mongoClient = MongoClients.create();

• 포트 27017 의 지정된 호스트에서 실행 중인 MongoDB 인스턴스에 연결하려면 hostname 를 명시적으로 지정합니다.

  MongoClient mongoClient = MongoClients.create(
     MongoClientSettings.builder()
         .applyToClusterSettings(builder ->
             builder.hosts(Arrays.asList(new ServerAddress("hostOne"))))
         .build());

• hostname 및 port 을 명시적으로 지정합니다.

  MongoClient mongoClient = MongoClients.create(
     MongoClientSettings.builder()
         .applyToClusterSettings(builder ->
             builder.hosts(Arrays.asList(new ServerAddress("hostOne", 27018))))
         .build());

• ConnectionString 을(를) 지정합니다.

  MongoClient mongoClient = MongoClients.create("mongodb://hostOne:27017");

복제본 세트에 연결

복제본 세트에 연결하려면 MongoClients.create() 메서드에 하나 이상의 멤버를 지정해야 합니다. 복제본 세트에 대해 자세히 알아보려면 MongoDB Server 매뉴얼의 복제 를 참조하세요.

ConnectionString 에 멤버를 지정하여 MongoDB 복제본 세트 에 연결할 수 있습니다.

다음 예시 에서는 복제본 세트 의 세 멤버를 지정하는 방법을 보여줍니다.

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

다음 예에서는 복제본 세트 이름과 함께 복제본 세트의 멤버와 replicaSet 옵션을 지정하는 방법을 보여 줍니다.

MongoClient mongoClient = MongoClients.create("mongodb://host1:27017,host2:27017,host3:27017/?replicaSet=myReplicaSet");

다음 예시 에서는 모든 복제본 세트 멤버에 해당하는 ServerAddress 인스턴스 목록을 지정하는 방법을 보여줍니다.

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

샤딩된 클러스터에 연결

샤드 클러스터에 연결하려면 mongos 인스턴스를 MongoClients.create() 메서드에 하나 이상 지정합니다. 샤드 클러스터에 대해 자세히 알아보려면 MongoDB Server 매뉴얼의 샤딩 을 참조하세요.

다음과 같은 방법으로 단일 mongos 인스턴스에 연결할 수 있습니다.

• ConnectionString 에 호스트 이름과 포트를 지정합니다.

  MongoClient mongoClient = MongoClients.create( "mongodb://localhost:27017" );

• localhost:27017에서 mongos 가 실행 중인 경우 연결 string 을 제외합니다.

  MongoClient mongoClient = MongoClients.create();

다음과 같은 방법으로 여러 mongos 인스턴스에 연결할 수 있습니다.

• 호스트 이름과 포트를 포함할 ConnectionString 을(를) 지정합니다.

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

• 각 인스턴스에 해당하는 ServerAddress 객체 목록을 지정합니다.

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

연결 옵션

ConnectionString 유형이나 MongoClientSettings 유형 또는 둘 다를 사용하여 연결 설정을 지정할 수 있습니다.

예를 예시 연결 string 에 TLS/SSL 및 인증 설정을 지정할 수 있습니다.

MongoClient mongoClient = MongoClients.create("mongodb://user1:pwd1@host1/?authSource=db1&ssl=true");

MongoClientSettings 인스턴스 를 사용하여 TLS/SSL을 지정하고 MongoCredential 유형을 사용하여 인증 정보를 저장 수도 있습니다.

String user; // the username
String database; // the name of the database in which the user is defined
char[] password; // the password as a character array
// ...
MongoCredential credential = MongoCredential.createCredential(user, database, password);
MongoClientSettings settings = MongoClientSettings.builder()
    .credential(credential)
    .applyToSslSettings(builder -> builder.enabled(true))
    .applyToClusterSettings(builder ->
        builder.hosts(Arrays.asList(new ServerAddress("host1", 27017))))
    .build();
MongoClient mongoClient = MongoClients.create(settings);

경우에 따라 연결 string 을 프로그래밍 구성과 결합해야 할 수도 있습니다.

ConnectionString connectionString = new ConnectionString("mongodb://host1:27107,host2:27017/?ssl=true");
CommandListener myCommandListener = ...;
MongoClientSettings settings = MongoClientSettings.builder()
    .addCommandListener(myCommandListener)
    .applyConnectionString(connectionString)
    .build();
MongoClient mongoClient = MongoClients.create(settings);