知識の準備

RabbitMQ

RabbitMQ は、AMQP に基づいた完全な再利用可能なエンタープライズメッセージングシステムです。

MQ

MQ は、メッセージキュー (MQ) の略で、アプリケーション間の通信方法です。
PythonによるRabbitMQ動作グラフィックコードの詳細説明
メッセージキューはパブリッシュ/サブスクライブモデルを使用して動作します。メッセージ送信者は、メッセージを処理した後、分散メッセージキューにメッセージを送信し、分散メッセージキューからメッセージを取得して処理を続行します。メッセージ送信者とメッセージ受信者の間には直接的な結合がないことがわかります。メッセージ送信者は分散メッセージキューにメッセージを送信するとメッセージの処理を終了しますが、メッセージ受信者は分散メッセージキューからメッセージを取得するだけで済みます。メッセージキュー。メッセージの送信元が不明なまま処理されます。
メッセージキュー通信により、サービスフィンガーAとサービスフィンガーB間の結合度を低く保ち、柔軟なビジネス展開を実現します。

pika

pika は、RabbitMQ チームによって作成された公式 Python AMQP ライブラリです。

インストール起動

$ brew install rabbitmq$ usr/local/sbin/rabbitmq-server

ログイン後にコピー

pikaのインストール

pip install pika

ログイン後にコピー

動作例

Hello World

送信者

# coding: utf-8import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(&#39;localhost&#39;))
channel = connection.channel()

channel.queue_declare(queue=&#39;hello&#39;)

channel.basic_publish(exchange=&#39;&#39;,
                      routing_key=&#39;hello&#39;,
                      body=&#39;Hello, World!&#39;)print &#39;send msg: Hello World!&#39;connection.close()

ログイン後にコピー

受信者

# coding: utf-8import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(&#39;localhost&#39;))
channel = connection.channel()

channel.queue_declare(queue=&#39;hello&#39;)def callback(ch, method, properties, body):
    print &#39;receive msg: %s&#39; % body

channel.basic_consume(callback,
                      queue=&#39;hello&#39;,
                      no_ack=False)print &#39;waiting for msg...&#39;channel.start_consuming()

ログイン後にコピー

実行結果:

# sender.py 运行2次send msg: Hello World!# receiverwaiting for msg...
receive msg: Hello, World!
receive msg: Hello, World!

ログイン後にコピー

コンシューマはメッセージを処理した後、終了せず、引き続き後続の処理を行うことができますメッセージ。

以上がPythonによるRabbitMQ動作グラフィックコードの詳細説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。