El control de simultaneidad es una función disponible en Pub/Sub biblioteca cliente de alto nivel. También puedes implementar tu propio control de simultaneidad cuando uses una biblioteca de bajo nivel.
La compatibilidad con el control de simultaneidad depende del lenguaje de programación de la biblioteca cliente. Para implementaciones de lenguaje que admiten subprocesos paralelos, como C++, Go y Java, las bibliotecas cliente hacen una elección predeterminada para la cantidad de subprocesos.
Es posible que esta opción no sea óptima para tu aplicación. Por ejemplo, si tu aplicación de suscriptor no mantiene el ritmo del volumen de mensajes entrantes y no está vinculada a la CPU, debes aumentar el conteo de subprocesos. En el caso de las operaciones de procesamiento de mensajes con uso intensivo de CPU, podría ser conveniente reducir la cantidad de subprocesos.
Parámetros de configuración de control de simultaneidad
Los valores predeterminados para las variables de control de simultaneidad y los nombres del
variables pueden diferir entre las bibliotecas cliente. Por ejemplo, en el cliente Java
, los métodos para configurar el control de simultaneidad son
setSystemExecutorProvider()
, setExecutorProvider()
y setParallelPullCount()
.
setParallelPullCount() te permite decidir cuántas transmisiones abrir. Puedes abrir más transmisiones si tu cliente suscriptor puede controlar más datos que los que se envían en una sola transmisión, que es de 10 MBps.
setExecutorProvider() te permite personalizar el proveedor del ejecutor que se usa para procesar mensajes. Por ejemplo, puedes cambiar el proveedor del ejecutor a uno que muestra un único ejecutor compartido con un número limitado de subprocesos en varios clientes suscriptores. Esta configuración ayuda a limitar la cantidad de conversaciones creadas.
setSystemExecutorProvider() te permite personalizar el proveedor de ejecutores que se usa para la administración de asignaciones. Por lo general, no configuras este valor, a menos que quieras usar el mismo proveedor de ejecutores en
setExecutorProvider
ysetSystemExecutorProvider
. Por ejemplo, puedes usar el mismo proveedor de ejecutores si tienes varias suscripciones de baja capacidad de procesamiento. Si usas el mismo valor, se limitará la cantidad de subprocesos. en el cliente.
La cantidad total de subprocesos que se usan para el control de simultaneidad depende del proveedor del ejecutor que se pasa en la biblioteca cliente y del recuento de extracción en paralelo.
Muestras de código para el control de simultaneidad
C++
Antes de probar esta muestra, sigue las instrucciones de configuración de C++ en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para C++.
Go
Antes de probar esta muestra, sigue las instrucciones de configuración de Go en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Go.
Java
Antes de probar esta muestra, sigue las instrucciones de configuración de Java en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Java.
Ruby
Antes de probar esta muestra, sigue las instrucciones de configuración de Ruby en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Ruby.
¿Qué sigue?
Lee sobre otras opciones de entrega que puedes configurar para una suscripción:
Controla las fallas de los mensajes con la política de reintentos de suscripción
Cómo reenviar mensajes que no se pudieron entregar a un tema de mensajes no entregados
Cómo volver a reproducir mensajes confirmados anteriormente o borrar definitivamente mensajes
Extiende el tiempo de acuse de recibo con la administración de arrendamientos