Le contrôle de simultanéité est une fonctionnalité disponible dans la bibliothèque cliente de haut niveau Pub/Sub. Vous pouvez également mettre en œuvre votre propre contrôle de simultanéité lorsque vous utilisez une bibliothèque de bas niveau.
La compatibilité du contrôle de simultanéité dépend du langage de programmation de la bibliothèque cliente. Pour les implémentations de langages compatibles avec les threads parallèles, tels que C++, Go et Java, les bibliothèques clientes font un choix par défaut pour le nombre de threads.
Ce choix n'est peut-être pas optimal pour votre application. Par exemple, si votre application d'abonné n'arrive pas à gérer le volume des messages entrants et qu'elle n'est pas liée au processeur, vous devez augmenter le nombre de threads. Pour les opérations de traitement des messages nécessitant une utilisation intensive du processeur, il peut être judicieux de réduire le nombre de threads.
Configurations du contrôle de simultanéité
Les valeurs par défaut des variables de contrôle de simultanéité et les noms des variables peuvent différer d'une bibliothèque cliente à l'autre. Par exemple, dans la bibliothèque cliente Java, les méthodes de configuration du contrôle de simultanéité sont setSystemExecutorProvider()
, setExecutorProvider()
et setParallelPullCount()
.
setParallelPullCount() vous permet de décider du nombre de flux à ouvrir. Vous pouvez ouvrir davantage de flux si votre client abonné peut traiter plus de données que celles envoyées sur un seul flux, soit 10 Mbit/s.
setExecutorProvider() vous permet de personnaliser le fournisseur d'exécuteur utilisé pour traiter les messages. Par exemple, vous pouvez remplacer le fournisseur d'exécuteur par un fournisseur qui renvoie un seul exécuteur partagé avec un nombre limité de threads sur plusieurs clients abonnés. Cette configuration permet de limiter le nombre de threads créés.
setSystemExecutorProvider() vous permet de personnaliser le fournisseur d'exécuteurs utilisé pour la gestion du bail. En règle générale, vous ne configurez cette valeur que si vous souhaitez utiliser le même fournisseur d'exécuteur dans
setExecutorProvider
etsetSystemExecutorProvider
. Par exemple, vous pouvez utiliser le même fournisseur d'exécuteurs si vous disposez d'un certain nombre d'abonnements à faible débit. L'utilisation de la même valeur limite le nombre de threads dans le client.
Le nombre total de threads utilisés pour le contrôle de simultanéité dépend du fournisseur d'exécuteurs transmis dans la bibliothèque cliente et du nombre d'extractions parallèles.
Exemples de code pour le contrôle de simultanéité
C++
Avant d'essayer cet exemple, suivez les instructions d'installation dans le langage C++ qui se trouvent sur la page Démarrage rapide : utiliser des bibliothèques clientes. Pour en savoir plus, consultez la documentation de référence sur l'API Pub/Sub pour C++.
Go
Avant d'essayer cet exemple, suivez les instructions d'installation dans le langage Go qui se trouvent sur la page Démarrage rapide : utiliser des bibliothèques clientes. Pour en savoir plus, consultez la documentation de référence sur l'API Pub/Sub pour Go.
Java
Avant d'essayer cet exemple, suivez les instructions d'installation dans le langage Java qui se trouvent sur la page Démarrage rapide : utiliser des bibliothèques clientes. Pour en savoir plus, consultez la documentation de référence sur l'API Pub/Sub pour Java.
Ruby
Avant d'essayer cet exemple, suivez les instructions d'installation dans le langage Ruby qui se trouvent sur la page Démarrage rapide : utiliser des bibliothèques clientes. Pour en savoir plus, consultez la documentation de référence sur l'API Pub/Sub pour Ruby.
Étapes suivantes
Découvrez les autres options de distribution que vous pouvez configurer pour un abonnement:
Gérer les échecs de messages avec une stratégie de nouvelle tentative d'abonnement
Transférer les messages non distribués vers un sujet de lettres mortes
Rouvrir des messages déjà confirmés ou les supprimer définitivement