Up and Running with RabbitMQ – A Message Broker

Hi, today we are going to learn about RabbitMQ, a message broker software.

What is Message Borker?

Message broker is an intermediary program module that translates a message from the formal messaging protocol of the sender to the formal messaging protocol of the receive

– source wikipedia

It act as an intermediate between sender and receiver.

What is RabbitMQ?

RabbitMQ is an open source message broker software which implements Advanced Message Queuing Protocol (AMQP). It can act as pub-sub, routing and queuing system.

RabbitMQ Message Flow


Producer: Creates a message to send it to exchange

Broker: It consist of three parts

  • Exchange: Receive published messages and send it to appropriate queue on the basis of routing key.
  • Binding: It is a link between  queue and exchange
  • Routing key: It helps in selecting queue i.e. which message is will be send to which queue.

Consumer: Consumer consumes the message from the queue they are bind.


Development Environment

  • Ubuntu 14.04 LTS
  • Python 2.7
  • PIP (python package manager)

Follow the steps to start using RabbitMQ

# Create Directory and enter it

# Create and activate virtual environment

Don’t know how to install virtual environment, check the official doc at docs.python-guide.org.

Download requirements.txt file to install all packages in your virtual environment using following command or you can go step by step with the tutorial.

# Install RabbitMQ

Once you install rabbitmq server, it will starts running automatically

# Enable RabbiMQ management plugin

It will give you a WebUI to manage and monitor rabbitmq. By default it runs on port 15672, you can access it in your browser by going to url Default username and password for WebUI is guest and guest respectively.

# Install pika

Pika is a pure-Python implementation of the AMQP 0-9-1 protocol that tries to stay fairly independent of the underlying network support library.

– source python.org

# Create Producer (message.py)

Producer sends a string message to “messages” queue.

# Create Consumer (worker.py)

Consumer will receive message and process it. Here, consume is listening on “messages” queue.

# Run Producer and Consumer

Run producer and consumer in two different terminal in order to see sending and receiving of messages simultaneously.


When we run message.py, message got inserted into queue but since there is no consumer listening on that queue therefor it shows one message is ready for publishing as “Ready” equals to 1.

Click on messages in above UI and we can get stats about individual queues. As you can see 1 message which we sent earlier is still in queue.


# Start consumer


As soon as we start our consumer worker.py, it will receive message from queue and now you can see ready count is 0.

Sending Multiple Messages

Create a loop to send 10 bulk message in queue.

Now start two instances of your worker.py


When you start two instances of worker.py, you can see message got evenly distributed on the basis of Round Robin Algorithm.Also, same message is not delivered to multiple workers.

It’s a simple example, now we send dict as message.

Create a new file dict-message.py

In order to read message now, we have to change our worker a little bit.

Create a new file dict-message-worker.py


We use json to send and receive message. As you can see when we send dict as message in a new queue “dict_messages” , consumer listening to that queue start receiving message instantly.

Now you have fair amount of knowledge of RabbiMQ you can use it in any appropriate project like for send notification, storing logs, sending bulk emails and many more.

For further reading check rabbitmq official docs at rabbitmq.com.

That’s all for today, hope you enjoy and do try at home.

Download source code Up-and-Running-with-RabbitMQ-A-Message-Broker-tusharsharma.in.zip