Docs Menu
Docs Home
/
言語
/
Java
/
Java Reactive Streams ドライバー

MongoDB に接続する

項目一覧

  • Overview
  • 接続
  • ローカル配置
  • Atlas
  • レプリカセット
  • シャーディングされたクラスター
  • 接続オプション

Overview

このページには、 Java Reactive Streamsアプリケーションをさまざまな設定でMongoDBに接続する方法を示すコード例が含まれています。

Tip

このページの接続オプションの詳細については、各セクションに記載されているリンクを参照してください。

このページの接続例を使用するには、コード例をサンプル アプリケーションまたは独自のアプリケーションにコピーします。 <Atlas connection string>など、コード例にあるすべてのプレースホルダーを、MongoDB 配置に関連する値に置き換えてください。

重要

プロジェクトリ アクター ライブラリ

このガイドでは、プロジェクト Reactive ライブラリを使用して、 Java Reactive Streams ドライバー メソッドによって返されたPublisherインスタンスを消費します。 Project Reactive ライブラリとその使用方法の詳細については、「 使用 開始 」を 参照してください。 （Reactor ドキュメントの参照）。このガイドでは、プロジェクト Reactor ライブラリ メソッドの使用方法の詳細については、「 MongoDBへのデータの書込み」ガイドを参照してください。

次のサンプルアプリケーションを使用して、このページのコード例をテストできます。 サンプル アプリケーションを使用するには、次の手順を実行します。

  1. IDE で新しいJavaプロジェクトを作成します。

  2. Java Reactive Streams ドライバーをJavaプロジェクトにインストールします。

  3. Project React ライブラリ をインストール Javaプロジェクト。

  4. 次のコードをコピーし、 ConnectionApp.javaという名前の新しいJavaファイルに貼り付けます。

  5. このページからコード例をコピーし、 ファイル内の指定された行に貼り付けます。

1import com.mongodb.ConnectionString;
2import com.mongodb.MongoClientSettings;
3import com.mongodb.ServerApi;
4import com.mongodb.ServerApiVersion;
5
6import org.bson.BsonDocument;
7import org.bson.BsonInt64;
8import org.bson.Document;
9
10import com.mongodb.reactivestreams.client.MongoClient;
11import com.mongodb.reactivestreams.client.MongoClients;
12import com.mongodb.reactivestreams.client.MongoDatabase;
13import org.bson.conversions.Bson;
14import reactor.core.publisher.Mono;
15
16class ConnectionApp {
17    public static void main(String[] args) {
18        //start example code here
19        
20        //end example code here        
21        {
22            Bson command = new BsonDocument("ping", new BsonInt64(1));
23            MongoDatabase database = mongoClient.getDatabase("admin");
24            Publisher<Document> MonoPublisher = database.runCommand(command);
25
26            Mono.from(MonoPublisher)
27                    .doOnSuccess(x -> System.out.println("Pinged your deployment. You successfully connected to MongoDB!"))
28                    .doOnError(err -> System.out.println("Error: " + err.getMessage()))
29                    .block();
30
31            //other application code
32
33        }
34    }
35}

接続

ローカル配置

String uri = "mongodb://<hostname>:<port>/";
try (MongoClient mongoClient = MongoClients.create(uri))

Atlas

String uri = "<Atlas connection string>";
ServerApi serverApi = ServerApi.builder()
             .version(ServerApiVersion.V1)
             .build();
 MongoClientSettings settings = MongoClientSettings.builder()
             .applyConnectionString(new ConnectionString(uri))
             .serverApi(serverApi)
             .build();
 try (MongoClient mongoClient = MongoClients.create(settings))

レプリカセット

String uri = "mongodb://<replica set member>:<port>/?replicaSet=<replica set name>";
try (MongoClient mongoClient = MongoClients.create(uri))

シャーディングされたクラスター

シャーディングされたクラスターに接続するには、 mongosインスタンスをMongoClients.create()メソッドに指定します。 シャーディングされたクラスターの詳細については、サーバー マニュアルの「 シャーディング 」を参照してください。

次の方法で、単一のmongosインスタンスに接続できます。

  • 次のコードに示すように、 接続stringでホスト名とポートを指定します。

    MongoClient mongoClient = MongoClients.create( "mongodb://<hostname>:<port>" );

  • 次のコードに示すように、mongos が localhost:27017 で実行中されている場合は、接続stringを除外します。

    MongoClient mongoClient = MongoClients.create();

次の方法で複数のmongosインスタンスに接続できます。

  • 次のコードに示すように、ホスト名とポートを含むように接続stringを指定します。

    MongoClient mongoClient = MongoClients.create("mongodb://<first hostname>:<first port>,<second hostname>:<second port>");

  • 次のコードに示すように、各インスタンスに対応するServerAddressオブジェクトのリストを指定します。

    MongoClient mongoClient = MongoClients.create(
        MongoClientSettings.builder()
            .applyToClusterSettings(builder ->
                builder.hosts(Arrays.asList(
                    new ServerAddress("<first hostname>", <first port>),
                    new ServerAddress("<second hostname", <second port>))))
            .build());

接続オプション

接続stringと 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);

戻る

次のステップ

次へ

MongoClient の作成