Wikipedista:Pavel.mlejnek/Pískoviště

RabbitMQ

[[Soubor:Soubor:RabbitMQLogo.png|200px|alt=Logo|Logo]]
Vývojář	Pivotal Software
Aktuální verze	3.5.5 (Šablona:Release date)
Operační systém	Multiplatformní
Vyvíjeno v	Erlang
Typ softwaru	AMQP, message-oriented middleware
Licence	Mozilla Public License
Web	www.rabbitmq.com

RabbitMQ is an open source message broker software (sometimes called message-oriented middleware) that implements the Advanced Message Queuing Protocol (AMQP). The RabbitMQ server is written in the Erlang programming language and is built on the Open Telecom Platform framework for clustering and failover. Client libraries to interface with the broker are available for all major programming languages.

Rabbit Technologies Ltd., develops and provides support for RabbitMQ. Rabbit Technologies started as a joint venture between LShift and CohesiveFT in 2007, and was acquired in April 2010 by SpringSource, a division of VMware. The project became part of GoPivotal in May 2013.

Zdrojový kód je zveřejněn pod licencí Mozilla Public License. Projekt se skládá z těchto částí:

• The RabbitMQ exchange server itself
• Gateways for HTTP, Streaming Text Oriented Messaging Protocol (STOMP), and MQTT protocols
• AMQP client libraries for Java, .NET Framework, and Erlang. (AMQP clients for other languages are available from other vendors.)
• A plug-in platform for custom additions, with a pre-defined collection of supported plug-ins, including:
  • A "Shovel" plug-in that takes care of moving or copying (replicating) messages from one broker to another.
  • A "Federation" plug-in that enables efficient sharing of messages between brokers (at the exchange level).
  • A "Management" plug-in that enables monitoring and control of brokers and clusters of brokers.

Příklady

This section gives sample programs written in python for sending and receiving messages using a queue.

Sending

The following code fragment establishes a connection, makes sure the recipient queue exists, then sends a message and finally closes the connection.

#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('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()

Receiving

Similarly, the following program receives messages from the queue and prints them on the screen:

#!/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()

See also

• Advanced Message Queuing Protocol (AMQP)
• ØMQ
• RabbitMQ creators CohesiveFT use Rabbit in VNS3

Reference

Further reading

• Joern Barthel. Getting started with AMQP and RabbitMQ [online]. InfoQ, 2009-09-13. Dostupné online. 
• Peter Cooper. RabbitMQ - A Fast, Reliable Queuing Option for Rubyists [online]. RubyInside, 2009-04-09. Dostupné online. 
• (2008-09-25) "RabbitMQ: An Open Source Messaging Broker That Just Works"., Google Tech Talks. 

Externí odkazy

• Oficiální webové stránky
• Evaluation for Second Life by Linden Labs
• Using RabbitMQ, Spring AMQP, and Spring Integration
• http://www.rabbitmq.com/getstarted.html
• http://www.rabbitmq.com/tutorials/tutorial-one-python.html