Comment puis-je vérifier si une file d'attente de messages RabbitMQ existe ou non?

Question

Comment puis-je vérifier si une file d'attente de messages existe déjà ou non?

J'ai 2 applications différentes, l'une créant une file d'attente et l'autre lisant de cette file d'attente. Donc, si j'exécute le client qui lit d'abord dans la file d'attente, il se bloque. Donc, pour éviter cela, je voudrais d'abord vérifier si la file d'attente existe ou non.

est ici l'extrait de code de la façon dont je l'ai lu la file d'attente:

QueueingBasicConsumer <ConsumerName> = new QueueingBasicConsumer(<ChannelName>); 
<ChannelName>.BasicConsume("<queuename>", null, <ConsumerName>); 
BasicDeliverEventArgs e = (BasicDeliverEventArgs)<ConsumerName>.Queue.Dequeue(); 

Answer 1

Ne pas pris la peine de vérifier.

queue.declare est une opération idempotente. Donc, si vous l'exécutez une fois, deux fois, N fois, le résultat sera toujours le même.

Si vous souhaitez vous assurer que la file d'attente existe, déclarez-la simplement avant de l'utiliser. Assurez-vous de le déclarer avec la même durabilité, l'exclusivité, la suppression automatique à chaque fois, sinon vous obtiendrez une exception.

Si vous avez réellement besoin de vérifier si une file d'attente existe (vous ne devriez normalement pas le faire), faites une déclaration passive de la file d'attente. Cette opération réussit si la file d'attente existe ou échoue dans une erreur si ce n'est pas le cas.

Answer 2

Cela ne fonctionnera pas dans les situations où il y a quelqu'un d'autre (autre application) responsable de la déclaration q. Et je ne pouvais tout simplement pas connaître tous les paramètres du q, juste le nom.

Je préférerais utiliser passiveDeclare et vérifier la IOException que q n'existe pas

Answer 3

Actuellement, vous pouvez savoir que les informations et beaucoup plus throught RabbitMQ Management HTTP API.

Par exemple, pour savoir si une file d'attente est en cours à ce moment, vous pouvez appeler l'interface GET /api/queues/vhost/name de l'API.

Answer 4

Utilisez QueueDeclare() pour effectuer cela comme suggéré. En outre, nous avons toujours fait en sorte que le consommateur de la file d'attente soit le propriétaire de la file d'attente et publions toujours dans les échanges qui sont créés et détenus par les éditeurs. Les consommateurs lient ensuite leurs files d'attente aux échanges auxquels ils souhaitent recevoir du trafic et utilisent un filtre de clé de route approprié pour le trafic qu'ils souhaitent. De cette façon, les éditeurs ne sont pas pris en compte par les consommateurs pour les files d'attente non durables, et les consommateurs sont libres d'aller et venir avec des files d'attente durables ou non durables mappées avec les clés de routage appropriées. Il en résulte un système facile à administrer et permet d'utiliser l'administration Web pour créer une file d'attente durable et la lier à un échange, obtenir du trafic, la dissocier, puis inspecter le contenu de la file pour comprendre le trafic et la charge venir à travers l'échange.