Pools de conexiones

Overview

En esta guía, puedes aprender cómo el driver Go utiliza pools de conexiones para gestionar las conexiones con una implementación de MongoDB y cómo puedes configurar la configuración del pool de conexiones en tu aplicación.

Un pool de conexiones es una caché de conexiones abiertas a la base de datos que mantiene el controlador de Go. Cuando su aplicación solicita una conexión a MongoDB, el controlador Go obtiene sin problemas una conexión del grupo, realiza operaciones y devuelve la conexión al grupo 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 pool de conexiones

Cada Client instancia tiene una pool de conexiones incorporada para cada servidor en su topología de MongoDB. Si no configura la opción minPoolSize, los pools de conexiones abren sockets on-demand. Estos sockets admiten operaciones de MongoDB simultáneas, o goroutines, en tu aplicación.

Cuando se instancia una nueva instancia de Client, se abren dos sockets por servidor en tu topología de MongoDB para supervisar el estado del servidor.

Por ejemplo, un cliente conectado a un set de réplicas de tres nodos abre seis sockets de supervisión. Si la aplicación usa la configuración por defecto para maxPoolSize y solo query el nodo primario (por defecto), entonces puede haber como máximo 106 sockets abiertos y 100 conexiones en el pool de conexiones. Si la aplicación utiliza un preferencias de lectura para query los nodos secundarios, sus agrupaciones también pueden aumentar y puede haber 306 conexiones totales.

Para mayor eficiencia, crea un cliente para cada proceso y reutilízalo en todas las operaciones. Evite crear un nuevo cliente para cada solicitud porque esto aumentará la latencia.

Si los sockets se cierran debido a errores 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.

Configura un pool 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.

Selecciona el Connection String o ClientOptions pestaña 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 pools de conexión

Los pools de conexiones tienen un límite de velocidad que permite a cada pool de conexiones crear, como máximo, el valor de maxConnecting conexiones en paralelo en cualquier momento. Cualquier nueva goroutine deja de esperar en los siguientes casos:

• Una de las goroutines existentes termina de crear una conexión, o una conexión existente se registra de nuevo en el pool.

• 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 administrar su cola de operaciones. Las operaciones pueden esperar cualquier cantidad de tiempo, a menos que defina la opción waitQueueTimeoutMS.

Una operación que espera más del tiempo definido por waitQueueTimeoutMS para un socket genera un error de conexión. Utilice 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 llamas 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 pool.

Información Adicional

Para más información sobre el uso de un pool de conexiones, consulta la documentación de la pool de conexiones en el manual de servidor.