Table of Contents
Introduction
In this tutorial, I will witten about RabbitMQ: Install, configuration, and example. RabbitMQ is a message broker, written in Erlang. Now, let’s go to the RabbitMQ tutorial for beginners.
It is transferring data ( messages) between several services: one service adds a message to the queue, the other receives these messages.
How to install and Run use RabbitMQ
Debian/Ubuntu
# apt install rabbitmq-server
Centos
# yum -y install epel-release
# yum -y install erlang socat
# wget https://www.rabbitmq.com/releases/rabbitmq-server/v3.6.10/rabbitmq-server-3.6.10-1.el7.noarch.rpm
# rpm --import https://www.rabbitmq.com/rabbitmq-release-signing-key.asc
# rpm -Uvh rabbitmq-server-3.6.10-1.el7.noarch.rpm
Docker
# docker run docker pull rabbitmq
RabbitMQ tutorial for beginners
Rabbitmq-plugins
The Documentation here
To view active plugin use list
$ sudo rabbitmq-plugins list
Show activate the plugin RabbitMQ Management
$ sudo rabbitmq-plugins enable rabbitmq_management
Active plugins are stored in a file /etc/rabbitmq/enabled_plugins
$ cat /etc/rabbitmq/enabled_plugins
HTTP API
The documention here
rabbitmq_management active API support on port 15672
# netstat -nplt | grep 15672
Example check it
# curl -i -u guest:guest localhost:15672/api/overview
rabbitmqadmin
Document here
rabbitmqctl
The Documentation here. It is mainly for managing nodes in a cluster – adding, deleting, rebooting, managing logs.
# rabbitmqctl status
View users
# rabbitmqctl list_users
WEB UI
After activating the plugin, the web interface for managing the server on port 15672.
Add a new user And the rights to everything. User access is guest denied by default.
# rabbitmqctl add_user test test
# rabbitmqctl set_user_tags test administrator
# rabbitmqctl set_permissions -p / test ".*" ".*" ".*"
There are three basic concepts for RabbitMQ
- producer: the client doing the sending of the message
- queue: the actual message queue
- consumer: the client receiving messages from the queue
- exchange: receives messages from the producer, and sends them to queues according to its type
Example
To work with RabbitMQ, AMQP (Advanced Message Queuing Protocol) support is required. we will install for python pika
$ sudo yum install python-pika
Sending a message
To create a script for the producer.
#!/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()
Run the script
$ ./producerScript.py
check with rabbitmqadmin
# rabbitmqadmin get queue='hello'
List of queues with rabbitmqctl
# rabbitmqctl list_queues
Receiving a message
The second script – consumertest.py- will receive a message from the queue
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
channel.basic_consume(callback,
queue='hello',
no_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
Run it
# ./consumer.py
We check the queue – now it’s empty here
# rabbitmqctl list_queues
Conclusion
Through the article, RabbitMQ tutorial for beginners. I hope will this your helpful. Thank you for reading the DevopsRoles page!