RabbitMQ

Un article de Wikipédia, l'encyclopédie libre.
Sauter à la navigation Sauter à la recherche

RabbitMQ est un logiciel d'agent de messages open source qui implémente le protocole Advanced Message Queuing (AMQP). Le serveur RabbitMQ est écrit dans le langage de programmation Erlang.

En 2018, il est utilisé dans plus de 35 000 entreprises[2].

Exemples[modifier | modifier le code]

Cette section propose des exemples de programmes écrits en Python pour l'envoi et la réception de messages à l'aide d'une file d'attente.

Envoi[modifier | modifier le code]

Envoi d'un message dans une queue[3] :

#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()

Réception[modifier | modifier le code]

Envoi du message[3] :

#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
print(' [*] Waiting for messages. To exit press CTRL+C')
def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
channel.basic_consume(callback, queue='hello', no_ack=True)
channel.start_consuming()

Articles Connexes[modifier | modifier le code]

Références[modifier | modifier le code]

  1. « Release 3.7.7 » (consulté le 23 juillet 2018)
  2. https://www.rabbitmq.com/#getstarted
  3. a et b « RabbitMQ - RabbitMQ tutorial - "Hello world!" », sur www.rabbitmq.com (consulté le 22 novembre 2017)