RabbitMQの利用方法

本ページではRabbitMQの利用方法について説明します。

インストール

1.RabbitMQをインストールします。

# rpm -Uvh http://ftp.jaist.ac.jp/pub/Linux/Fedora/epel/6/i386/epel-release-6-8.noarch.rpm  
# wget -O /etc/yum.repos.d/epel-erlang.repo http://repos.fedorapeople.org/repos/peter/erlang/epel-erlang.repo  
# yum install erlang  
# rpm -Uvh  http://www.rabbitmq.com/releases/rabbitmq-server/vX.X.X/rabbitmq-server-X.X.X-1.noarch.rpm  

2.RabbitMQの管理コンソールを有効化します。

※rabbitmqserver=【RabbitMQをインストールしたホスト】と読み替えてください。

# sudo rabbitmqctl stop_app  
# sudo service rabbitmq-server stop  
# ps -elf | grep rabbit
表示されたプロセスIDに対して以下のコマンドを実行
# kill [プロセスID]  
# rabbitmq-plugins enable rabbitmq_management
# service rabbitmq-server start
  →  /var/lib/rabbitmq/mnesia/rabbit@rabbitmqserver-plugins-expand/rabbitmq_management-X.X.X/priv/www/cli 配下にrabbitmqadminが生成される。

3.RabbitMQのキューを設定します。

# cd /var/lib/rabbitmq/mnesia/rabbit@rabbitmqserver-plugins-expand/rabbitmq_management-X.X.X/priv/www/cli  
# chmod +x rabbitmqadmin  
# ./rabbitmqadmin -P 15672 -u guest -p guest declare exchange name=Message0 type=direct auto_delete=false internal=false durable=true  
# ./rabbitmqadmin -P 15672 -u guest -p guest declare exchange name=Message1 type=direct auto_delete=false internal=false durable=true  
# ./rabbitmqadmin -P 15672 -u guest -p guest declare queue name=Message0 node=rabbit@rabbitmqserver auto_delete=false durable=true  
# ./rabbitmqadmin -P 15672 -u guest -p guest declare queue name=Message1 node=rabbit@rabbitmqserver auto_delete=false durable=true  
# ./rabbitmqadmin -P 15672 -u guest -p guest declare binding source=Message0 destination_type=queue destination=Message0 routing_key=  
# ./rabbitmqadmin -P 15672 -u guest -p guest declare binding source=Message1 destination_type=queue destination=Message1 routing_key=  

起動手順

# service rabbitmq-server start  

終了手順

# service rabbitmq-server stop