オープンソースのMQの代表格であるRabbitMQを学習しています。学ぶにあたってとりあえず公式サイトのチュートリアルをこなしてみたので、自分の理解のためにも訳してみました。皆さんのお役に立てれば幸いです。
※ 公式サイトではさまざまなプログラム言語に対応していますが、とりあえずPythonでの例のみ訳しています。
前準備
この章は公式サイトのチュートリアルにはありませんが、インストールの手順をまずは書いておきます。
RabbitMQのインストール
公式サイトのドキュメントを確認のこと。以下はUbuntuの場合の手順です。
- 下記エントリを/etc/apt/sources.listに追記：
deb http://www.rabbitmq.com/debian/ testing main
- 公開鍵を登録
wget https://www.rabbitmq.com/rabbitmq-signing-key-public.asc
sudo apt-key add rabbitmq-signing-key-public.asc
- apt-get updateでパッケージリストを更新
sudo apt-get update
- インストール
sudo apt-get install rabbitmq-server
Python用ライブラリ'pika'のインストール
pipでインストールできます。
sudo pip install pika
準備ができたら、チュートリアルに入りましょう。
Tutorial 1: Hello World
※ 以下はRabbitMQ公式サイトのTutorial - Hello world! (python版)の翻訳です。意訳している部分もありますのでご了承ください。
イントロダクション
Rabbit MQはメッセージブローカーです。主なアイデアは非常にシンブルで、「メッセージを受け取って、転送する」ことです。郵便局のようなものだと考えて良いでしょう：あなたが手紙をポストに投函するとき、あなたはいずれ郵便局の配達員が手紙を宛先へ届けてくれると確信しているでしょう。Rabbit MQの役割をこの例えに当てはめると、ポスト、郵便局、配達員すべての役割を担います。
RabbitMQと郵便局の違いは、扱うのが紙ではなくデータのかたまり、すなわち__メッセージ__であることです。Rabbit MQはこれを受け取り、保管し、転送します。
RabbitMQや一般的なメッセージングシステムでは、いくつかの専門用語を用います。
-
_Producing_は送信を意味します。送信を行うプログラムは_Producer_と呼びます(以下、片仮名で"プロデューサ"と表記)。今後のチュートリアル内で登場するプログラムの解説図では、"P"という略称を使うことにします。
-
_queue_は、手紙を保管するメールボックスのようなものです(以下、片仮名で"キュー"と表記)。これはRabbit MQの内部で動作しています。あなたのアプリケーションがRabbit MQを介してメッセージを送る場合、それはただキューの中に格納されます。キューには制限なく好きなだけメッセージを格納させることができます - 本質的には無限のバッファであると言えます。複数のプロデューサから一つのキューにメッセージを送ることができ、また複数のコンシューマが一つのキューからメッセージを受け取ることができます。今後のチュートリアル内の解説図では、キュー名を上に付加した次のようなイラストを用います。
-
_Consuming_は、受信に近い意味です。メッセージの受信を待つプログラムを_Consumer_と呼びます(以下、片仮名で"コンシューマ"と表記)。 チュートリアル内の解説図では、"C"という略称を使うことにします。
プロデューサ、コンシューマ、ブローカ（RabbitMQサーバ）は同じマシンに同居させる必要はない、ということを覚えてください。実際、多くのアプリケーションではこれらを分離して配置する構成を取ります。
Hello World!
このHello Worldプログラムレイは大して複雑ではありません。メッセージを送信して、それをスクリーンに出力してみましょう。実現には、二つのプログラムが必要です：一つはメッセージを送信するプログラム、もう一つはそのメッセージを受信して出力するプログラムです。
全体のデザインは以下のようなものです：
プロデューサ(P)は"Hello"キューにメッセージを送ります。コンシューマ(C)はキューからメッセージを受け取ります。
RabbitMQのライブラリについて：
RabbitMQはオープンで汎用的なメッセージングプロトコルであるAMQP0.9.1を通信に利用します。RabbitMQに対応したクライアントはさまざまな言語で用意されています。このチュートリアルで利用するpikaは、RabbitMQチームの推奨するPythonクライアントです。
送信
送信プログラムsend.pyを作成します。(コード全文)
最初に行うことは、RabbitMQサーバとの接続を確立することです：
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
'localhost'))
channel = connection.channel()
この例ではローカルホストのブローカ（RabbitMQサーバ）に接続しています。外部のマシンのブローカに接続したい場合は、単純にlocalhostの部分にIPアドレスもしくはホスト名を指定します。
メッセージの送信を行う際には、宛先のキューがすでに存在している必要があります。もし存在しないキューにメッセージを送ってしまうと、RabbitMQはそのメッセージを捨ててしまいます。今回は、Helloという名前のキューに送ることとして、このキューを作成しましょう：
channel.queue_declare(queue='hello')
これでメッセージを送る準備ができました。Hello World!という単語だけを含んだメッセージを、Helloキューに送ろうと思います。
RabbitMQでは、メッセージはキューに直接送られるのではなく、必ずexchangeというコンポーネントを介して送られるのですが、その詳細までは今は掘り下げません（チュートリアル3で解説します）。とりあえず、空文字('')を指定することによって、デフォルトのexchangeを利用する方法を学びましょう。このexchangeは特殊で、どのキューにメッセージを送るかを直接指定することができます。送信先のキューの名前は、routing_keyパラメータに指定します：
channel.basic_publish(exchange='',
routing_key='hello',
body='Hello World!')
print(" [x] Sent 'Hello World!'")
プログラムを抜ける前に、ネットワークバッファがフラッシュされ、メッセージがきちんとRabbitMQへ送られたかを確かめる必要があります。下記のコードで、それらの処理を行ってコネクションを閉じることができます。
connection.close()
送信がうまくいかない
もしこれが初めてのRabbitMQの利用で、メッセージの送信がうまくいかなければ、なにが間違っているのか頭を掻いて悩むところでしょう。もしかしたら、ブローカ（RabbitMQサーバ）が、充分なディスクスペースを確保できずに起動しているのかもしれません（最低で1GBのスペースが必要です）。この場合RabbitMQはメッセージを受け付けません。ログファイルを確認して、必要であれば最低限必要なディスクスペースの制限の設定（disk_free_limit）の値を下げてください。configuration file documentationに設定方法が記載されています。
受信
二つ目のプログラムreceive.pyは、メッセージをキューから受け取ってスクリーンに出力します。(コード全文)
まずRabbitMQサーバに接続します。このコードはsend.pyと同様です。
次に、利用するキューが確実に存在するように、queue_declareを呼び出します。このメソッドはべき等性を保証していて、すでに指定したキューが存在していれば何もしません。そのため何度でも好きなだけ呼び出せます。（同じ名前のキューは一つしか作成されません）
channel.queue_declare(queue='hello')
なぜsend.pyのコード内で記述したキューの宣言をまた行うのか、と疑問に思うかもしれません。理由はキューが存在していない、という事態を確実に避けるためです。send.pyを必ず先に立ち上げるのであれば、（send.pyだけでキューの宣言しておけば）問題ありませんが、我々はsend.pyとreceive.py、どちらを先に立ち上げるか決めていません。こうした場合、両方のプログラムにキューの宣言（queue_declare）を記述するのは良いプラクティスです。
キューのリスティング
RabbitMQにいくつのキューがあって、どれくらいのメッセージがあるのかを確認したい場合があるでしょう。そうした場合には、rabbitmqctlツールを権限のあるユーザで実行します：
$ sudo rabbitmqctl list_queues
Listing queues ...
hello 0
...done.
キューからのメッセージの受信は少し複雑です。callback関数をキューに登録することで、処理を動かすことができます。メッセージを受信したら、いつでもcallback関数がPikaライブラリから呼び出されます。今回は、この関数ではメッセージの中身をスクリーンに出力するようにします。
def callback(ch, method, properties, body):
print(" [x] Received %r" % body)
次に、RabbitMQに対して、helloからメッセージを受け取った際にこのcallbackを呼び出すよう伝えます：
channel.basic_consume(callback,
queue='hello',
no_ack=True)
このコマンドは、登録を行うキューが存在しなければ成功しません。幸い、我々はqueue_declareをこの前に記述しているため、キューが存在することに確信が持てます。
no_ackパラメータについては、チュートリアル2で説明します。
最後に、データを待ち受けてコールバックを動かす無限ループに入ります：
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()
全体のコード
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='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()
#!/usr/bin/env python
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='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()
ターミナルから、プログラムを試してみましょう。まずはsend.pyを動かしてメッセージを送ります：
$ python send.py
[x] Sent 'Hello World!'
プロデューサプログラムであるsend.pyは送信を行うとすぐに終了します。次はメッセージを受信してみましょう:
$ python receive.py
[*] Waiting for messages. To exit press CTRL+C
[x] Received 'Hello World!'
万歳! RabbitMQを利用した最初のメッセージの送受信に成功しました。お気づきのように、reveive.pyはメッセージを受け取っても終了せず、また次のメッセージを待ち受けます。終了させるにはCtrl-Cを押してください。
今回のチュートリアルで、我々は名前付きキューを利用したメッセージの送受信の方法を学びました。チュートリアル2では、シングルなWorkキューの作成を行います。