Les instances de passage dans Storm n'ont pas de file d'attente de réception (seulement une file d'attente d'envoi)? Je suppose que vous parlez de boulons?
Bien que ce soit un peu vieux this article par Michael Noll donne un bon aperçu des files d'attente internes au sein des travailleurs.
Pour répondre à votre question. Le rapport entre les files d'attente ne sera pas toujours de 2: 1. Les files d'attente des perturbateurs signalent leurs métriques moyennées sur l'utilisateur configurable topology.builtin.metrics.bucket.size.secs, ce qui masquera une partie de la différence. Toutes les métriques sont également soumises à un taux d'échantillonnage, défini par la variable de configuration topology.stats.sample.rate - qui, par défaut, ne représente que 20% des tuples transférés, ce qui peut également entraîner l'extinction des nombres indiqués. De plus, en fonction du code de vos boulons, 1 ligne d'entrée peut produire plusieurs tuples de sortie, vous devrez donc en tenir compte dans tous les rapports que vous avez calculés.
Vous faites référence à la stabilité d'une équation dans votre question. Le taux d'arrivée n'est basé sur aucune équation de la théorie de la mise en file d'attente et est simplement le nombre de tuples qui sont mis dans la file d'attente dans une période de métrique.bucket divisé par la longueur de la période en secondes. Toutefois, Storm signale une mesure du temps de séjour dans la file d'attente. Ceci est basé sur une équation très simple de la théorie de la mise en file d'attente qui n'est pas fiable pour les systèmes de files d'attente instables et devrait être évitée.
merci beaucoup. Désolé pour le manque de réponse rapide. Les instances de dérivation dans Storm ont une file d'attente de réception pour recevoir les instances d'acker du formulaire en tuple. par conséquent, le nombre de tuple que le bec reçu doit être égal à envoyer. – wendyhusband