Pools de conexiones

Overview

En esta guía, puede aprender cómo el controlador Go usa grupos de conexiones para administrar conexiones a una implementación de MongoDB y cómo puede configurar los ajustes del grupo de conexiones en su aplicación.

Un pool de conexiones es un caché de conexiones de base de datos abiertas, mantenido por el controlador de Go. Cuando su aplicación solicita una conexión a MongoDB, el controlador de Go obtiene una conexión del pool sin problemas, realiza operaciones y la devuelve al pool para su reutilización.

Los pools de conexiones ayudan a reducir la latencia de la aplicación y el número de veces que se crean nuevas conexiones mediante el driver Go.

Crear un grupo de conexiones

Cada Client La instancia tiene un grupo de conexiones integrado para cada servidor en su topología de MongoDB. Si no configura la opción minPoolSize, los grupos de conexiones abren sockets bajo demanda. Estos sockets admiten operaciones simultáneas de MongoDB, o goroutines, en su aplicación.

Cuando se crea una nueva instancia Client, se abren dos sockets por servidor en su topología MongoDB para monitorear el estado del servidor.

Por ejemplo, un cliente conectado a un conjunto de réplicas de tres nodos abre seis sockets de monitorización. Si la aplicación usa la configuración predeterminada para maxPoolSize y solo consulta el nodo principal (predeterminado), puede haber como máximo 106 sockets abiertos y 100 conexiones en el grupo de conexiones. Si la aplicación usa un preferencia de lectura para consultar los nodos secundarios, sus grupos también crecen y puede haber 306 conexiones en total.

Para mayor eficiencia, cree un cliente para cada proceso y reutilícelo para todas las operaciones. Evite crear un cliente nuevo para cada solicitud, ya que esto aumentará la latencia.

Si los sockets se cierran debido a algún error de red, lo que provoca que el número total de sockets (tanto en uso como inactivos) caiga por debajo del mínimo, se abren más sockets hasta que se alcanza el mínimo.

Configurar un grupo de conexiones

Puedes especificar la configuración de tu pool de conexión utilizando una cadena de conexión o los métodos options.Client.

Seleccione el Connection String o la pestaña ClientOptions para ver la sintaxis correspondiente:

// Connection string with connection pool options
const uri = "mongodb://localhost:27017/?maxPoolSize=50&minPoolSize=10&maxIdleTimeMS=30000"

// Creates a new client and connects to the server
client, err := mongo.Connect(options.Client().ApplyURI(uri))
if err != nil {
	log.Fatal(err)
}

// Sets client options with connection pool settings
clientOptions := options.Client().
	ApplyURI(uri).
	SetMaxPoolSize(50).
	SetMinPoolSize(10).
	SetMaxConnIdleTime(30 * time.Second)
// Creates a new client and connects to the server
client, err := mongo.Connect(clientOptions)
if err != nil {
	log.Fatal(err)
}

Optimizar los grupos de conexiones

Los grupos de conexiones tienen una tasa limitada, de modo que cada uno solo puede crear, como máximo, maxConnecting conexiones en paralelo en cualquier momento. Cualquier nueva goroutine deja de esperar en los siguientes casos:

• Una de las goroutine existentes termina de crear una conexión, o una conexión existente se devuelve al grupo.

• La capacidad del controlador para reutilizar conexiones existentes mejora debido a los límites de velocidad en la creación de conexiones.

El controlador no limita el número de operaciones que pueden esperar a que los sockets estén disponibles, por lo que es responsabilidad de la aplicación gestionar su cola de operaciones. Las operaciones pueden esperar cualquier tiempo, a menos que se defina la opción waitQueueTimeoutMS.

Una operación que espera más tiempo del definido por waitQueueTimeoutMS para un socket genera un error de conexión. Use esta opción si es más importante limitar la duración de las operaciones durante un pico de carga que completar cada operación.

Desconectando

Cuando se llama a Client.Disconnect() desde cualquier goroutine, el controlador cierra todos los sockets inactivos y luego cierra todos los sockets a medida que se devuelven al grupo.

Información Adicional

Para obtener más información sobre el uso de un grupo de conexiones, consulte la documentación del grupo de conexiones en el manual del servidor.