The Advanced Message Queuing Protocol (AMQP) is an open standard application layer protocol for message-oriented middleware. The defining features of AMQP are message orientation, queuing, routing (including point-to-point and publish-and-subscribe), reliability and security.
RabbitMQ is 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.
RabbitMQ comes with default built-in settings which will most likely be sufficient for running your RabbitMQ server effectively. If it runs fine, then you probably don’t need any configuration at all. Mostly CloudStack and Openstack used RabbitMQ to exchange messages.
RabbitMQ offers a variety of features to let you trade off performance with reliability, including persistence, delivery acknowledgements, publisher confirms, and high availability.
Messages are routed through exchanges before arriving at queues. RabbitMQ features several built-in exchange types for typical routing logic. For more complex routing you can bind exchanges together or even write your own exchange type as a plugin.
Several RabbitMQ servers on a local network can be clustered together, forming a single logical broker.
For servers that need to be more loosely and unreliably connected than clustering allows, RabbitMQ offers a federation model.
Highly Available Queues
Queues can be mirrored across several machines in a cluster, ensuring that even in the event of hardware failure your messages are safe.
RabbitMQ supports messaging over a variety of messaging protocols.
There are RabbitMQ clients for almost any language you can think of.
RabbitMQ ships with an easy-to use management UI that allows you to monitor and control every aspect of your message broker.
If your messaging system is misbehaving, RabbitMQ offers tracing support to let you find out what’s going on.
RabbitMQ ships with a variety of plugins extending it in different ways, and you can also write your own.
RabbitMQ Installation on CentOS
Download Erlang Yum Repos RPM
#rpm -ivh epel-release-6-8.noarch.rpm
#yum install erlang
Download and Install RabbitMQ
#rpm -ivh rabbitmq-server-3.3.5-1.noarch.rpm
Start and verify RabbitMQ
Set RabbitMQ to start on boot and start it up immediately:
#chkconfig rabbitmq-server on
Install RabbitMQ management console
#rabbitmq-plugins enable rabbitmq_management
Login RabbitMQ Web UI
Username is “guest”,
password is “guest”
Create RabbitMQ new user account and update password with admin permissions
#rabbitmqctl add_user demo demo
#rabbitmqctl set_user_tags demo administrator
#rabbitmqctl set_permissions -p / demo “.*” “.*” “.*”
Output from the server is sent to a RABBITMQ_NODENAME.log file in the RABBITMQ_LOG_BASE directory. Additional log data is written to RABBITMQ_NODENAME-sasl.log.
join_cluster <clusternode> [–ram]
change_cluster_node_type disc | ram
add_user <username> <password>
change_password <username> <newpassword>
set_user_tags <username> <tag> …
list_vhosts [<vhostinfoitem> …]
set_permissions [-p <vhostpath>] <user> <conf> <write> <read>
clear_permissions [-p <vhostpath>] <username>
list_permissions [-p <vhostpath>]
set_parameter [-p <vhostpath>] <component_name> <name> <value>
clear_parameter [-p <vhostpath>] <component_name> <key>
list_parameters [-p <vhostpath>]
set_policy [-p <vhostpath>] [–priority <priority>] [–apply-to <apply-to>]
<name> <pattern> <definition>
clear_policy [-p <vhostpath>] <name>
list_policies [-p <vhostpath>]
list_queues [-p <vhostpath>] [<queueinfoitem> …]
list_exchanges [-p <vhostpath>] [<exchangeinfoitem> …]
list_bindings [-p <vhostpath>] [<bindinginfoitem> …]
list_connections [<connectioninfoitem> …]
list_channels [<channelinfoitem> …]
list_consumers [-p <vhostpath>]
=ERROR REPORT==== 5-Dec-2014::09:13:20 ===
closing AMQP connection <0.31492.1> (192.168.120.10:38738 -> 192.168.120.25:5672):
“PLAIN login refused: user ‘guest’ can only connect via localhost”,
You should update rabbitmq host ip address instead of localhost (127.0.0.1)
Error: Cannot retrieve metalink for repository: epel. Please verify its path and try again
change http instead of https in your repo file.
sudo sed -i “s/mirrorlist=https/mirrorlist=http/” /etc/yum.repos.d/epel.repo
Try to update again.