译-PHP RabbitMQ チュートリアル-4

ルーティング (ルーティング)

(php-amqplib を使用)

前回のチュートリアルでは、ログ メッセージを多くの受信者にブロードキャストすることができました。複数の受信者にメッセージをブロードキャストするための単純なログ システムを作成しました。

このチュートリアルでは、機能を追加します。たとえば、メッセージのサブセットのみをサブスクライブできるようにし、重大なエラー メッセージのみをログに送信できるようにします。ファイル (ディスク容量を節約するため) を作成しながら、コンソールにすべてのログ メッセージを出力することもできます。

今回は、メッセージの一部だけを聞くことができるようにする機能を追加します。たとえば、すべてのメッセージをコンソールに出力しながら、致命的なエラー メッセージのみをログ ファイル (ディスク) に保存するように指示できます。

バインディング

前の例では、すでにバインディングを作成していました。次のようなコードを思い出してください。

前の例では、すでにバインディングを作成していました。次のように覚えているかもしれません:

$channel->queue_bind($queue_name, 'logs');

バインディングはエクスチェンジとキューの間の関係です。これは単に次のように読むことができます: キューはこのエクスチェンジからのメッセージに関心があります。

エクスチェンジとキューの間。関係はバンドルと呼ばれます。これは単純に、「このキューはこの特定の交換からのメッセージに関心がある」と理解できます。

バインディングは、$channel::basic_publish パラメーターとの混同を避けるために、これをバインディング キーと呼びます。これは、キーを使用してバインディングを作成する方法です。

バインディングは次のようになります。 set 追加の routing_key パラメータ。 $channel:basic_publish パラメータとの混同を避けるため、これをバンディング キーと呼びます。これは、キーを含むバンドルを作成する方法です。

$binding_key = 'black';$channel->queue_bind($queue_name, $exchange_name, $binding_key);

バインディング キーの意味は交換タイプによって異なります バインディング キーの意味は交換タイプによって異なります。以前に使用されていたファンアウト タイプの交換器は、この値を単純に無視します。

直接交換

前のチュートリアルのログ システムは、すべてのメッセージをすべてのコンシューマにブロードキャストします。たとえば、ログ メッセージをディスクに書き込むスクリプトを拡張して、メッセージを重大度に基づいてフィルタリングできるようにしたいと考えています。重大なエラーのみを受信し、警告や情報ログ メッセージでディスク領域を浪費しません。

以前のログ システムは、すべてのメッセージをすべてのコンシューマーにブロードキャストしました。これを拡張して、重大度に基づいてメッセージをフィルタリングできるようにしたいと考えています。たとえば、ログ永続スクリプトで致命的なエラーのみを永続化し、警告や情報 (info) メッセージでディスク領域を無駄にしないようにしたい場合があります。

私たちはファンアウト エクスチェンジを使用していましたが、柔軟性はあまりありません - マインドレス ブロードキャストのみが可能です。

私たちはファンアウト エクスチェンジを使用していましたが、柔軟性はあまりありません - マインドレス ブロードキャストのみが可能です。放送。

代わりに直接交換を使用します。直接交換の背後にあるルーティング アルゴリズムは単純です。メッセージは、バインディング キーがメッセージのルーティング キーと正確に一致するキューに送られます。

代わりに、直接交換デバイスを使用します。方向性交換器の背後にあるアルゴリズムは単純です。メッセージは、メッセージ ルーティング キーとキュー バインディング キーが正確に一致するキューにプッシュされます。

これを説明するために、次の設定を考えてみましょう。

この設定では、2 つのキューがバインドされている直接交換 X がわかります。最初のキューはオレンジ色のバインディング キーでバインドされており、2 番目のキューには 2 つのバインディングがあり、1 つはバインディング キーです。バインディング キーは黒で、もう 1 つは緑です。

この構造では、スイッチ X に 2 つのキューがバンドルされていることがわかります。最初のキューはオレンジのバインディング キーでバインドされ、2 番目のキューには 2 つのバインディングがあります。最初のキューは黒のバインド キーを使用し、もう 1 つは緑のバインディング キーを使用します。このような設定では、メッセージが交換にパブリッシュされます。ルーティング キーがオレンジのメッセージはキュー Q1 にルーティングされます。ルーティング キーが黒または緑のメッセージは Q2 に送られます。他のメッセージはすべて破棄されます。

この構造では、ルーティング キーがオレンジのメッセージはスイッチに送信されます。黒と緑のルーティング キーを持つメッセージはキュー Q1 にルーティングされ、他のメッセージはすべて破棄されます。

複数のバインディング

It is perfectly legal to bind multiple queues with the same binding key. In our example we could add a binding between X and Q1 with binding key black. In that case, the direct exchange will behave like fanout and will broadcast the message to all the matching queues. A message with routing key black will be delivered to both Q1 and Q2.

用相同的binding key捆绑多个队列毛问题没有。我们的例子中，我们可以用黑色来建立X和Q1之间的捆绑。这种情况下，定向交换器的行为就回像fanout交换器一样，广播消息到所有匹配的队列。Q1和Q2都会收到带有routing key黑色的消息。

Emitting logs（日志发布）

We'll use this model for our logging system. Instead of fanout we'll send messages to a direct exchange. We will supply the log severity as a routing key. That way the receiving script will be able to select the severity it wants to receive. Let's focus on emitting logs first.

我们将应用这种模式到我们的日志系统。与fanout交换器不同的是我们发送消息到指定的交换器。用日志严重等级来作为

routing key。 那样的话接收脚本就可以根据严重等级来选择想要接收的消息。我们先来把发布日志搞定。

As always, we need to create an exchange first:

老样子，先要创建一个交换器：

$channel->exchange_declare('direct_logs', 'direct', false, false, false);

And we're ready to send a message:

准备发射！！！??消息 - -#

$channel->exchange_declare('direct_logs', 'direct', false, false, false);$channel->basic_publish($msg, 'direct_logs', $severity);

To simplify things we will assume that 'severity' can be one of 'info', 'warning', 'error'.

简单起见，我们假定严重等级可以是info,warning,error中的一个。

Subscribing（订阅）

Receiving messages will work just like in the previous tutorial, with one exception - we're going to create a new binding for each severity we're interested in.

接收消息就跟之前一样，但有一点不同??我们得为每一个感兴趣的严重等级创建一个捆绑。

foreach($severities as $severity) {    $channel->queue_bind($queue_name, 'direct_logs', $severity);}

Putting it all together（合体！！！还来？？哈哈）

The code for emit_log_direct.php class:

emit_log_direct.php类代码：

channel();$channel->exchange_declare('direct_logs', 'direct', false, false, false);$severity = $argv[1];if(empty($severity)) $severity = "info";$data = implode(' ', array_slice($argv, 2));if(empty($data)) $data = "Hello World!";$msg = new AMQPMessage($data);$channel->basic_publish($msg, 'direct_logs', $severity);echo " [x] Sent ",$severity,':',$data," \n";$channel->close();$connection->close();?>

The code for receive_logs_direct.php:

receive_logs_direct.php代码：

channel();$channel->exchange_declare('direct_logs', 'direct', false, false, false);list($queue_name, ,) = $channel->queue_declare("", false, false, true, false);$severities = array_slice($argv, 1);if(empty($severities )) {    file_put_contents('php://stderr', "Usage: $argv[0] [info] [warning] [error]\n");    exit(1);}foreach($severities as $severity) {    $channel->queue_bind($queue_name, 'direct_logs', $severity);}echo ' [*] Waiting for logs. To exit press CTRL+C', "\n";$callback = function($msg){  echo ' [x] ',$msg->delivery_info['routing_key'], ':', $msg->body, "\n";};$channel->basic_consume($queue_name, '', false, true, false, false, $callback);while(count($channel->callbacks)) {    $channel->wait();}$channel->close();$connection->close();?>

If you want to save only 'warning' and 'error' (and not 'info') log messages to a file, just open a console and type:

如果你想仅存储warning和error的消息到日志文件，就打开控制台输入：

$ php receive_logs_direct.php warning error > logs_from_rabbit.log

If you'd like to see all the log messages on your screen, open a new terminal and do:

要想在屏幕上查看所有的消息，打开一个新窗口输入：

$ php receive_logs_direct.php info warning error [*] Waiting for logs. To exit press CTRL+C

And, for example, to emit an error log message just type:

对了，例如，要发布错误消息就输入：

$ php emit_log_direct.php error "Run. Run. Or it will explode." [x] Sent 'error':'Run. Run. Or it will explode.'

(Full source code for (emit_log_direct.php source) and (receive_logs_direct.php source))

emit_log_direct.php和receive_logs_direct.php的源码

Move on to tutorial 5 to find out how to listen for messages based on a pattern.

下回呢我们讲讲如何基于模式来收听消息。