rabbitmqrabbitmqを使い始める

備考

バージョン

Ubuntu ServerにRabbitMQをインストールする

RabbitMQを実際にインストールする前の簡単な注意：Ubuntu 14.04のErlangパッケージにはRabbitMQでSSLを使用している場合に問題があるため、Ubuntuパッケージのメンテナが提供するバージョンより新しいバージョンをインストールする必要がありますので、 https： Erlang 17.0以降の場合は/www.erlang-solutions.com/resources/download.htmlを参照してください 。

RabbitMQをパッケージリポジトリリストに追加する：

echo 'deb http://www.rabbitmq.com/debian/ testing main' |
    sudo tee /etc/apt/sources.list.d/rabbitmq.list
 

署名キーを追加します。

wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc |
    sudo apt-key add -
 

次に、更新してインストールします。

sudo apt-get update && sudo apt-get install rabbitmq-server
 

RabbitMQ「Hello World」

このコードは、2つのメッセージをキューに送信するプロデューサと、そのキューからすべてのメッセージを受け取るコンシューマを作成します。

producer.pyのコード（pika 0.10.0 Pythonクライアントを使用）：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='queueName')

channel.basic_publish(exchange='',
                      routing_key='queueName',
                      body='Hello')
channel.basic_publish(exchange='',
                      routing_key='queueName',
                      body='World!')
print("Message sent")
connection.close()
 

consumer.pyのコード：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='queueName')

def callback(ch, method, properties, body):
    print("Received message: %r" % body)

channel.basic_consume(callback,
                      queue='queueName',
                      no_ack=True)

print('Waiting for messages...')
channel.start_consuming()
 

出力は次のとおりです。

$ python receive.py
Waiting for messages...
Received message: 'Hello'
Received message: 'World!'
 

その他の例は、RabbitMQのチュートリアルページで他の言語で利用できます。

PDF - Download rabbitmq for free