Personalizar selección de servidor

Overview

Todos los controladores de MongoDB siguen un algoritmo definido al seleccionar un servidor desde el que leer o escribir. Al usar el ClusterSettings propiedad de un objeto MongoClientSettings, puede personalizar este algoritmo para elegir el servidor que funcione mejor para su aplicación.

Algoritmo de selección de servidor

Cuando el driver de Kotlin Sync ejecuta una operación de lectura, realiza los siguientes pasos, en orden, para seleccionar una implementación de MongoDB:

1. Selecciona todos los servidores de la lista de servidores conocidos adecuados para la operación solicitada, excluyendo aquellos que el controlador considera no disponibles o problemáticos.

   1. Para lecturas, selecciona todos los servidores que coinciden con la preferencia de lectura activa

   2. Para escrituras, selecciona todos los servidores escribibles

2. Llama a la función de selección de servidor definida por el usuario, si el usuario proporciona una, y pasa la lista del paso anterior

3. Aplica la configuración de conexión localThreshold a la lista de servidores devueltos por la función

4. Selecciona como máximo dos servidores aleatorios de la lista de servidores que coinciden con los criterios anteriores y luego selecciona el servidor con menos operaciones concurrentes pendientes

Cuando el controlador de sincronización de Kotlin ejecuta una operación de escritura, comienza seleccionando todos los servidores con permisos de escritura de la lista de servidores conocidos, no solo aquellos que coinciden con la preferencia de lectura activa. Los pasos restantes son idénticos a los de la lista anterior.

Para obtener más información sobre el algoritmo de selección del servidor MongoDB, consulte Algoritmo de selección de servidor en el manual del servidor MongoDB.

Implementar lógica de selección de servidor personalizada

Puede implementar su propia lógica de selección de servidores personalizada creando una clase que implemente la interfaz ServerSelector. El siguiente ejemplo muestra una clase de selección de servidores personalizada simple que selecciona servidores con un valor type de ServerType.REPLICA_SET_SECONDARY:

class CustomServerSelector : ServerSelector {
    override fun select(cluster: ClusterDescription): List<ServerDescription> {
        return cluster.serverDescriptions.filter { it.type == ServerType.REPLICA_SET_SECONDARY }
    }
}

Utiliza el método applyToClusterSettings() para pasar una instancia de esta clase a tu MongoClientSettings. El siguiente ejemplo muestra cómo crear un MongoClient con una instancia de la clase de selector de servidor personalizada del ejemplo anterior:

val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("<connection URI>"))
    .applyToClusterSettings { builder ->
        builder.serverSelector(CustomServerSelector())
    }
    .build()
val mongoClient = MongoClient.create(settings)

Utilice la configuración para configurar la selección del servidor

Puede especificar las siguientes configuraciones de selección de servidor en su objeto MongoClient o en su URI de conexión:

readPreference=primaryPreferred
&maxStalenessSeconds=90
&readPreferenceTags=dc:ny,rack:1

Documentación de la API

Para obtener más información sobre las clases y métodos utilizados en esta guía, consulta la siguiente documentación de la API:

• MongoClient

• MongoClientSettings

• Selector de servidor

• Preferencia de lectura