RabbitMQ est un courtier de messages open source implémentant à l'origine le protocole AMQP avec des protocoles de messagerie supplémentaires pris en charge via une architecture de plug-in. Cette balise doit être utilisée avec des questions concernant le produit de courtier de messages du serveur RabbitMQ ou des questions concernant le code source et l'implémentation du produit RabbitMQ. Une étiquette de protocole spécifique telle que amqp ou mqtt peut également être appropriée ainsi que le système d'exploitation et le langage de programmation utilisés.
Dans l'état actuel des choses, cette question ne convient pas à notre format de questions / réponses. Nous nous attendons à ce que les réponses soient étayées par des faits, des références ou une expertise, mais cette question suscitera probablement un débat, des arguments, des sondages ou une...
On m'a demandé d'évaluer RabbitMQ au lieu de Kafka, mais j'ai eu du mal à trouver une raison pour laquelle il fait quelque chose de mieux que Kafka. Est-ce que quelqu'un sait s'il est vraiment meilleur en termes de débit, de durabilité, de latence ou de facilité
Je suis nouveau dans les courtiers de messages comme RabbitMQ que nous pouvons utiliser pour créer des tâches / files d'attente de messages pour un système de planification comme Celery . Maintenant, voici la question: Je peux créer une table dans PostgreSQL qui peut être ajoutée à de nouvelles...
J'ai installé le dernier serveur RabbitMQ (rabbitmq-server-3.3.0-1.noarch.rpm) sur une nouvelle machine virtuelle Centos 5.10 selon les instructions sur le site officiel. J'ai fait cela plusieurs fois auparavant pendant le développement et je n'ai jamais eu de problème. Cependant, cette fois, je ne...
Comment puis-je supprimer toutes les tâches en attente sans connaître le task_idpour chaque
J'ai installé rabbitmqadminet j'ai pu lister tous les échanges et files d'attente. Comment puis-je utiliser rabbitmqadminou rabbitmqctlsupprimer toutes les files
Le client Java RabbitMQ présente les concepts suivants: Connection - une connexion à une instance de serveur RabbitMQ Channel - ??? Pool de threads consommateurs - un pool de threads qui consomment les messages des files d'attente du serveur RabbitMQ File d'attente - une structure qui contient les...
Comment puis-je vérifier quelle version de rabbitmq fonctionne sur un serveur? Existe-t-il une commande pour vérifier que rabbitmq
Je commence tout juste à utiliser RabbitMQ et AMQP en général. J'ai une file de messages J'ai plusieurs consommateurs, ce que j'aimerais faire différemment avec le même message . La plupart de la documentation de RabbitMQ semble se concentrer sur le round-robin, c'est-à-dire où un seul message est...
Comment supprimer tous les messages d'une seule file d'attente à l'aide du cli? J'ai le nom de la file d'attente et je veux le
Quels ports le serveur RabbitMQ utilise-t-il ou doit-il ouvrir sur le pare-feu pour un cluster de nœuds? My /usr/lib/rabbitmq/bin/rabbitmq-envest défini en dessous duquel je suppose que sont nécessaires (35197). SERVER_ERL_ARGS="+K true +A30 +P 1048576 \ -kernel inet_default_connect_options...
J'essaie de comprendre ce que JMS et comment il est connecté à la terminologie AMQP. Je sais que JMS est une API et AMQP est un protocole. Voici mes hypothèses (et mes questions également) RabbitMQ utilise le protocole AMQP (implémente plutôt le protocole AMQP) Les clients Java doivent utiliser les...
Est-il possible d'afficher le contenu des messages RabbitMQ directement à partir de la ligne de commande? sudo rabbitmqctl list_queues répertorie les files d'attente. Y a-t-il une commande comme sudo rabbitmqctl list_queue_messages
Quels messages peuvent être stockés dans les files d'attente RabbitMQ? Seulement des cordes? Ou puis-je sélectionner le type que je souhaite stocker: int, binaire, chaîne, etc.? Quelle est la taille maximale d'un message? Combien de files d'attente ou d'échanges pourraient être créés? Ou cela...
J'ai quelques files d'attente avec RabbitMQ. Quelques-uns d'entre eux ne sont plus utiles maintenant, comment puis-je les supprimer? Malheureusement, je n'avais pas défini l' auto_deleteoption. Si je le configure maintenant, sera-t-il supprimé? Existe-t-il un moyen de supprimer ces files d'attente...
Je suis en dessous de l'exception org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - La connexion a été refusée à l'aide du mécanisme d'authentification PLAIN. Pour plus de détails, consultez le fichier journal du courtier....
Nous définissons une architecture pour collecter les informations de journal par les expéditeurs Logstash qui sont installés dans diverses machines et indexent les données dans un serveur elasticsearch de manière centralisée et utilisent Kibana comme couche graphique. Nous avons besoin d'un...