RabbitMQ

Un article de Wikipédia, l'encyclopédie libre.
Aller à : navigation, rechercher
RabbitMQ
Logo

Développeur Pivotal Software (en)Voir et modifier les données sur Wikidata
Écrit en ErlangVoir et modifier les données sur Wikidata
Type Agent de messagesVoir et modifier les données sur Wikidata
Licence Mozilla Public LicenseVoir et modifier les données sur Wikidata
Site web www.rabbitmq.comVoir et modifier les données sur Wikidata

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[1].

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[2] :

#!/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[2] :

#!/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. https://www.rabbitmq.com/#getstarted
  2. a et b « RabbitMQ - RabbitMQ tutorial - "Hello world!" », sur www.rabbitmq.com (consulté le 22 novembre 2017)