/ /

Conectar

Docs Home

/ /

driver de Kotlin corrutina

Conectar

Docs Home

Librerías de clientes

Kotlin

driver de Kotlin corrutina

Conectar

Especificar la configuración de MongoClient

Overview

En esta guía, puedes aprender sobre los diferentes ajustes para controlar el comportamiento de tu MongoClient.

Las siguientes secciones describen configuraciones comúnmente utilizadas:

MongoClientSettings
Configuración del clúster
Configuración de socket
Configuración del grupo de conexiones
Configuración del servidor
Configuración TLS/SSL

MongoClientSettings

Puede controlar el comportamiento de su MongoClient creando y pasando un objeto MongoClientSettings al método MongoClient.create().

Para crear un objeto MongoClientSettings, utiliza el método MongoClientSettings.builder() y encadena métodos para especificar tus configuraciones. Después de encadenarlos, utilice el método build() para crear el objeto MongoClientSettings.

La siguiente tabla describe todos los métodos que puedes encadenar para modificar el comportamiento de tu conexión:

Método	Descripción
`addCommandListener()`	Agrega un listener para eventos de comando.
`applicationName()`	Establece el nombre lógico de la aplicación utilizando `MongoClient`.
`applyConnectionString()`	Aplica las configuraciones del `ConnectionString` dado al generador. Si omite este método, el controlador intenta conectarse a `localhost`.
`applyToClusterSettings()`	Aplica el `ClusterSettings.Builder` bloque y luego establece la configuración del clúster.
`applyToConnectionPoolSettings()`	Aplica el `ConnectionPoolSettings.Builder` bloque y luego establece la configuración del grupo de conexiones.
`applyToServerSettings()`	Aplica el bloque `ServerSettings.Builder` y luego configura los ajustes del servidor.
`applyToSocketSettings()`	Aplica el bloque `SocketSettings.Builder` y luego establece la configuración del socket.
`applyToSslSettings()`	Aplica el `SslSettings.Builder` bloque y luego establece la configuración TLS/SSL.
`autoEncryptionSettings()`	Establece la configuración de cifrado automático.
`codecRegistry()`	Establece el registro de códecs. Establece el registro de códecs.
`commandListenerList()`	Establece los escuchas de comandos.
`compressorList()`	Establece los compresores que se usarán para comprimir mensajes en el servidor.
`credential()`	Establece la credencial.
`readConcern()`	Establece el nivel de consistencia de lectura.
`readPreference()`	Configura la preferencia de lectura.
`retryReads()`	Si el controlador debe volver a intentar la lectura si ocurre un error de red.
`retryWrites()`	Si el controlador debe volver a intentar escribir si ocurre un error de red.
`serverApi()`	Establece la API del servidor que se utilizará al enviar comandos al servidor.
`streamFactoryFactory()`	Establece la fábrica que se utilizará para crear un `StreamFactory`.
`uuidRepresentation()`	Establece la representación UUID que se utilizará al codificar instancias de UUID y decodificar valores binarios BSON con el subtipo 3.
`writeConcern()`	Configura el nivel de confirmación de escritura

Ejemplo

En este ejemplo, se muestra la especificación de un ConnectionString:

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyConnectionString(ConnectionString("<your connection string>"))
        .build()
)

Tip

Cada configuración tiene un método. Rara vez applyConnectionString() se necesitan en la configuración, por lo que debería usar este método como se muestra en el ejemplo anterior.

Nota

Orden de encadenamiento

Algunas opciones de la configuración se asignan a una opción de cadena de conexión. Si especificas las mismas opciones en tu configuración y en la cadena de conexión, el orden en que las encadenas determina la opción que utiliza el driver. El driver usa la última configuración que lee.

Por ejemplo, este snippet contiene configuraciones con los siguientes tiempos para que el driver se conecte a un socket disponible:

La cadena de conexión especifica dentro de 2 SECONDS
El ajustes del socket especifica dentro de 5 SECONDS

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyConnectionString(ConnectionString("mongodb+srv:/<db_username>:<db_password>@<hostname>:<port>?connectTimeoutMS(2000)"))
        .applyToSocketSettings{ builder ->
            builder.connectTimeout(5, TimeUnit.SECONDS)
        }
        .build()
)

Dado que el controlador lee las opciones de configuración del socket en último lugar, se espera que el controlador se conecte a un socket disponible dentro de 5 SECONDS antes de que se agote el tiempo de espera.

Tip

Registra tu configuración

Para registrar la configuración de la instancia MongoClient, configura el registrador llamado org.mongodb.driver.client en el nivel INFO.

Para aprender más sobre el registro con el driver MongoDB Kotlin, consulta la guía de registro.

Configuración del clúster

Encadene el método applyToClusterSettings() para modificar el comportamiento del controlador al interactuar con su clúster MongoDB.

La siguiente tabla describe todos los métodos que puedes encadenar a tus parámetros para modificar el comportamiento del controlador:

Método

Descripción

addClusterListener()

Agrega un listener para eventos relacionados con el clúster.

applyConnectionString()

Usa los parámetros de un objeto ConnectionString.

applySettings()

Utiliza la configuración de clúster especificada en un objeto ClusterSettings.

hosts()

Establece todas las ubicaciones especificadas de un servidor Mongo.

localThreshold()

Define la cantidad de tiempo que puede tomar un viaje de ida y vuelta a un servidor y aún ser elegible para la selección de servidor.

mode()

Define cómo conectarse a un servidor MongoDB.

requiredClusterType()

Establece el tipo de clúster requerido para el clúster.

requiredReplicaSetName()

Establece el nombre del set de réplicas requerido para el clúster.

serverSelectionTimeout()

Establece el tiempo máximo para seleccionar un nodo primario antes de lanzar una excepción por tiempo de espera.

serverSelector()

Agrega un selector de servidor para aplicar antes de la selección del servidor.

srvHost()

Establece el nombre de host que se utilizará para buscar un registro DNS SRV para encontrar los hosts de MongoDB.

Al configurar srvHost, el driver no procesa ningún registro TXT asociado al host.

Si deseas habilitar el procesamiento de registros TXT, debes especificar el host SRV en la cadena de conexión utilizando el método applyConnectionString().

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyConnectionString(ConnectionString("mongodb+srv://host1.acme.com"))
        .build()
)

srvMaxHosts()

Sets the maximum number of hosts the driver can connect to when using
the DNS seedlist (SRV) connection protocol, identified by the
mongodb+srv connection string prefix.

Throws an exception if you are not using the SRV connection protocol.

Ejemplo

Este ejemplo especifica que el driver debe conectarse directamente a un servidor, independientemente del tipo de clúster MongoDB al que pertenezca:

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyToClusterSettings{ builder ->
            builder.mode(ClusterConnectionMode.SINGLE)
        }
        .build()
)

Tip

Esto es similar al directConnection parámetro que puedes especificar en la URI de tu conexión.Consulta "Opciones de conexión" para obtener más información.

Configuración de socket

Encadene el método applyToSocketSettings() para modificar el comportamiento del controlador al conectarse y comunicarse con su servidor MongoDB.

La siguiente tabla describe todos los métodos que puedes encadenar a tus parámetros para modificar el comportamiento del controlador:

Método	Descripción
`applyConnectionString()`	Usa los parámetros de un objeto `ConnectionString`.
`applySettings()`	Utiliza los ajustes de socket especificados en un objeto `SocketSettings`.
`applyToProxySettings()`	Aplica el bloque `ProxySettings.Builder` y luego establece el campo `proxySettings`.
`connectTimeout()`	Establece el tiempo máximo para conectarse a un socket disponible antes de lanzar una excepción por tiempo de espera.
`readTimeout()`	Establece el tiempo máximo para leer un socket disponible antes de generar una excepción de tiempo de espera.
`receiveBufferSize()`	Establece el tamaño del búfer del socket al recibir.
`sendBufferSize()`	Establece el tamaño del búfer del socket al enviar.

Ejemplo

Este ejemplo especifica el siguiente comportamiento del controlador en un socket de MongoDB:

Para conectarse a un socket disponible dentro de 10 SECONDS
Para leer de un socket disponible dentro de 15 SECONDS

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyConnectionString(ConnectionString("<your connection string>"))
        .applyToSocketSettings{ builder ->
            builder
                .connectTimeout(10, TimeUnit.SECONDS)
                .readTimeout(15, TimeUnit.SECONDS)
        }
        .build()
)

Configuración del grupo de conexiones

Encadena el método applyToConnectionPoolSettings() para modificar la forma en que el driver administra su grupo de conexiones.

La siguiente tabla describe todos los métodos que puedes encadenar a tus parámetros para modificar el comportamiento del controlador:

Método	Descripción
`addConnectionPoolListener()`	Agrega un listener para eventos relacionados con el pool de conexiones.
`applyConnectionString()`	Usa los parámetros de un objeto `ConnectionString`.
`applySettings()`	Utiliza la configuración del grupo de conexiones especificada en un objeto `ConnectionPoolSettings`.
`maintenanceFrequency()`	Establece la frecuencia para ejecutar un trabajo de mantenimiento.
`maintenanceInitialDelay()`	Establece el tiempo de espera antes de ejecutar el primer trabajo de mantenimiento.
`maxConnectionIdleTime()`	Establece el tiempo máximo que una conexión puede estar inactiva antes de que se cierre.
`maxConnectionLifeTime()`	Establece el tiempo máximo que una conexión agrupada puede estar activa antes de cerrarse.
`maxWaitTime()`	Establece el tiempo máximo para esperar a una conexión disponible.
`maxSize()`	Establece la cantidad máxima de conexiones asociadas con un pool de conexiones.
`minSize()`	Establece la cantidad mínima de conexiones asociadas a un grupo de conexiones.

Nota

Estas configuraciones maxSize y minSize se aplican a cada servidor del clúster al que conecta el controlador.

Por ejemplo, suponga que conecta el controlador a un clúster con tres servidores mongos. Esto significa que puede haber como máximo maxSize conexiones y como mínimo minSize conexiones a cada mongos servidor.

Ejemplo

Este ejemplo especifica el siguiente comportamiento del controlador en un grupo de tipos Connection:

El hilo para esperar como máximo 10 SECONDS por una conexión disponible
Tener como máximo 200 conexiones asociadas al pool

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyConnectionString(ConnectionString("<your connection string>"))
        .applyToConnectionPoolSettings{ builder ->
            builder
                .maxWaitTime(10, TimeUnit.SECONDS)
                .maxSize(200)
        }
        .build()
)

Configuración del servidor

Encadena el método applyToServerSettings() para modificar el comportamiento del controlador al monitorizar cada servidor MongoDB.

La siguiente tabla describe todos los métodos que puedes encadenar a tus parámetros para modificar el comportamiento del controlador:

Método	Descripción
`addServerListener()`	Agrega un oyente para eventos relacionados con el servidor.
`addServerMonitorListener()`	Agrega un escuchador para eventos relacionados con el monitor del servidor.
`applyConnectionString()`	Usa los parámetros de un objeto `ConnectionString`.
`applySettings()`	Utiliza la configuración del servidor especificada en un objeto `ServerSettings`.
`heartbeatFrequency()`	Establece el intervalo para que un monitor de clúster intente acceder a un servidor.
`minHeartbeatFrequency()`	Establece el intervalo mínimo para las comprobaciones de supervisión del servidor.
`serverMonitoringMode()`	Especifica qué protocolo de supervisión del servidor utiliza el controlador.

Ejemplo

Este ejemplo especifica el siguiente comportamiento del controlador en un servidor MongoDB:

El intervalo mínimo para las comprobaciones de monitorización del servidor debe ser al menos 700 MILLISECONDS
El monitor del clúster intenta alcanzar un servidor cada 15 SECONDS

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyConnectionString(ConnectionString("<your connection string>"))
        .applyToServerSettings{ builder ->
            builder
                .minHeartbeatFrequency(700, TimeUnit.MILLISECONDS)
                .heartbeatFrequency(15, TimeUnit.SECONDS)
        }
        .build()
)

Configuración TLS/SSL

Encadene el método applyToSslSettings() para modificar el comportamiento del controlador al usar TLS/SSL para asegurar una conexión entre su aplicación y MongoDB.

La siguiente tabla describe todos los métodos que puedes encadenar a tus parámetros para modificar el comportamiento del controlador:

Método	Descripción
`applyConnectionString()`	Usa los parámetros de un objeto `ConnectionString`.
`applySettings()`	Utiliza la configuración TLS/SSL especificada en un objeto `SslSettings`.
`context()`	Establece el `SSLContext` para usar cuando habilites TLS/SSL.
`enabled()`	Si se debe habilitar TLS/SSL. (Debe habilitar esto para los clústeres de Atlas).
`invalidHostNameAllowed()`	Si permitir o no una discrepancia entre el nombre de host del servidor y el especificado por el certificado TLS.

Ejemplo

Este ejemplo especifica que el controlador debe habilitar TLS/SSL al conectarse a MongoDB:

val mongoClient = MongoClient.create(
    MongoClientSettings.builder()
        .applyConnectionString(ConnectionString("<your connection string>"))
        .applyToSslSettings{ builder ->
            builder.enabled(true)
        }
        .build()
)

Volver

Pools de conexiones

Solución de problemas de conexión