ApsaraMQ for RabbitMQ:Connections and channels

Utiliser des connexions persistantes

Ouvrez les connexions au démarrage de l'application et conservez-les pendant tout son cycle de vie. N'ouvrez ni ne fermez les connexions pour chaque opération de publication ou de consommation.

Si votre charge de travail nécessite la création fréquente de canaux, réutilisez un ensemble stable de connexions et créez plusieurs canaux au sein de celles-ci. Pour connaître les limites relatives aux taux d'ouverture des connexions et des canaux, consultez la rubrique Limites.

Séparer les connexions producteur et consommateur

Utilisez au moins une connexion pour la production de messages et une connexion distincte pour la consommation. ApsaraMQ for RabbitMQ applique un contrôle de flux (back pressure) aux connexions qui publient plus rapidement que l'instance ne peut traiter les messages. Si les producteurs et les consommateurs partagent la même connexion, le contrôle de flux côté publication peut retarder les accusés de réception des consommateurs, ce qui dégrade le débit de consommation.

Utiliser un canal par thread

Plusieurs threads peuvent partager une connexion. Toutefois, les canaux ne sont pas thread-safe dans la plupart des bibliothèques clientes. Attribuez un canal dédié à chaque thread plutôt que de partager un canal entre plusieurs threads.

// Anti-pattern: sharing a channel across threads
Channel shared = connection.createChannel(); // Not thread-safe

// Recommended: one channel per thread
ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < 4; i++) {
    executor.submit(() -> {
        Channel ch = connection.createChannel();
        // Use ch for this thread's publish/consume operations
    });
}

Lorsque plusieurs processus partagent une connexion, évitez de l'ouvrir et de la fermer fréquemment. Dans le cas contraire, une erreur ChannelNotFind peut survenir.

Prévenir le déséquilibre de consommation

Lorsque seul un petit nombre de connexions gère un volume important de messages, la consommation peut devenir inégalement répartie entre les consommateurs. Pour éviter cela :

• Augmentez le nombre de connexions par consommateur ou ajoutez davantage de consommateurs.

• Assurez-vous que chaque consommateur établit le même nombre de connexions.

• Maintenez un total d'au moins 30 connexions de consommateurs à titre de recommandation.