PythonでRabbitMQを操作してみる（1）

CDN のコンテンツと稼働状況を管理および監視する分散システムを Python を使用して実装したいと考えていたため、偶然、Yu Feng 氏の「RabbitMQ を選択する理由」など、多くの人に勧められました。等々。

MQ という言葉が登場したとき、私は MQ とは何か、つまり Message Queue (メッセージ キュー) について数時間かけて読みました。名前が示すように、メッセージ キュー、メッセージで満たされたキュー、キュー、データ構造名詞は、先入れ先出しの特性を持つデータ構造です。メッセージ キューはメッセージを配信するために使用されるだけなので、その重要性は何なのか、そのアプリケーション シナリオは何なのか、どのような特徴があるのか​​、独自の利点は何なのか、なぜ使用する必要があるのか​​など、一連の疑問が生じます。私の心には。

何度も検索した結果、メッセージキューはアプリケーション間で情報を転送するための通信方法であるという表面的な理解に達しました。たとえば、複数のサーバーのログを分析する必要がある場合、各サーバーで 1 つのプロセスを使用してデータ (必要な情報) を Mysql データベース テーブルに書き込み、その後、そのデータを読み取るための複数のプロセスを作成できます。分析はあまり良くありませんが、すぐにこの設計の醜さが明らかになりました... 複数のプログラムでキューからデータを取得して処理したいですか?問題ありません。プログラムの数をハードコードしました...何ですか?また、圧力が動的に増減するときに、プログラムが動的に圧力を分散できるようにしますか?これは、非常に人気のある「RabbitMQ+Python Introduction to Classic Rabbit and Rabbit Nest」の例です。考えてみてください。CDN が大量のデータを送信すると、データの配布、処理、すべてが問題になります。しかし、Rabbit がこれらをどのように実装しているのかはまだ理解できません。

概念的に言うと、RabbitMQ は AMPQ (Advanced Message Protocol Queuing) の標準実装です。AMQP に詳しくない人は RabbitMQ のドキュメントを理解できないと言われています。しかし、重要な概念をしっかりと理解することしかできません。 RabbitMQ の実装原理モデル全体を次の図に示します。これは、実際にはルーティング タスク分散キューを備えたプロデューサーおよびコンシューマー モデルです。図に示すように、プロデューサは対応する情報を生成してルータに送信し、ルータは情報内のキー情報に基づいて情報を異なるメッセージ キューに配布し、コンシューマは異なるメッセージ キュー内のデータを読み取ります。の。

ブローカー: 簡単に言えば、これはメッセージキューサーバーエンティティです。
Exchange: メッセージスイッチ。どのメッセージがどのキューにルーティングされるかに従ってルールを指定します。
キュー: メッセージキューキャリア、各メッセージは 1 つ以上のキューに入れられます。
バインディング：バインディング、その機能は、ルーティングルールに従ってExchangeとQueueをバインドすることです。
ルーティング キー: ルーティング キーワード、Exchange はこのキーワードに基づいてメッセージを配信します。
vhost: 仮想ホスト。ブローカーで複数の vhost を開いて、異なるユーザーの権限を分離できます。
プロデューサー：メッセージプロデューサーはメッセージを届けるプログラムです。
コンシューマ: メッセージコンシューマは、メッセージを受け入れるプログラムです。
チャネル: クライアントの各接続で複数のチャネルを確立でき、各チャネルがセッション タスクを表します。

メッセージキューの使用手順は大まかに以下のとおりです。

(1) クライアントはメッセージキューサーバーに接続し、チャネルを開きます。
(2) クライアントは交換を宣言し、関連する属性を設定します。
(3) クライアントはキューを宣言し、関連する属性を設定します。
(4) クライアントはルーティング キーを使用して、Exchange と Queue の間のバインディング関係を確立します。
(5)クライアントは交換するメッセージを配信します。

RabbitMQ の一般的なプロセスと利点を理解した後、Fedora で RabbitMQ を試し始めました。

RabbitMQ公式Webサイトによると、インストールはここからダウンロードする必要があります

rpm --import http://www.rabbitmq.com/rabbitmq-signing-key-public.asc yum install rabbitmq-server-3.3.0-1.noarch.rpm

chkconfig rabbitmq-server on

/sbin/service rabbitmq-server stop/start

grep beam.smp /var/log/audit/audit.log | audit2allow -M mypolsemodule -i mypol.pp/sbin/service rabbitmq-server start

pip install pika

#!/usr/bin/env pythonimport pikaconnection = pika.BlockingConnection(pika.ConnectionParameters(              
 'localhost'))channel = connection.channel()

channel.queue_declare(queue='sayhello')

channel.basic_publish(exchange='',                        
routing_key='hello',                                    
body='hello world')print "Sent ‘hello world'"

connection.close()

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()