Topic 模糊模式 php 版 · PHP/Python/前端/Linux 等等學習筆記

[TOC] ## 主題模式 > [參考CSDN](https://blog.csdn.net/Super_RD/article/details/70850453) ### 匹配規則 ``` * (星號) 代表任意一個單詞 # (井號) 0個或者多個單詞 ``` > 注意：上面說的是單詞不是字符。 ![UTOOLS1580704466223.png](http://yanxuan.nosdn.127.net/ff2c5c873b4fbf907b39480d5f6ff33c.png) > RoutingKey為“black.critical.high”的日志會投遞到**queue1和queue2**。 > RoutingKey為“red.critical.high”的日志會只投遞到queue2。 > RoutingKey為“white.critical.high”的日志會投遞到queue2，并且雖然queue2的兩個匹配規則都符合但只會向queue2**投遞一份**。 ### code 用法發布信息 <details> <summary>topic.php</summary> ``` /* * topic 模式 * create by superrd */ $exchangeName = 'extopic'; $routeKey1 = "black.critical.high"; $routeKey2 = "red.critical.high"; $routeKey3 = "white.critical.high"; $message1 = 'black-critical-high!'; $message2 = 'red-critical-high!'; $message3 = 'white-critical-high!'; $connection = new AMQPConnection(array('host' => '10.99.121.137', 'port' => '5672', 'vhost' => '/', 'login' => 'superrd', 'password' => 'superrd')); $connection->connect() or die("Cannot connect to the broker!\n"); try { $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); $exchange->setType(AMQP_EX_TYPE_TOPIC); $exchange->setFlags(AMQP_DURABLE); $exchange->declareExchange(); $exchange->publish($message1,$routeKey1); var_dump("[x] Sent ".$message1); $exchange->publish($message2,$routeKey2); var_dump("[x] Sent ".$message2); $exchange->publish($message3,$routeKey3); var_dump("[x] Sent ".$message3); } catch (AMQPConnectionException $e) { var_dump($e); exit(); } $connection->disconnect(); ``` </details> <br /> 監聽queue1隊列 <details> <summary>q2.php</summary> ``` /* * topic 模式 * create by superrd */ $queueName = 'queue1'; $exchangeName = 'extopic'; $routeKey = "black.critical.high"; $connection = new AMQPConnection(array('host' => '10.99.121.137', 'port' => '5672', 'vhost' => '/', 'login' => 'superrd', 'password' => 'superrd')); $connection->connect() or die("Cannot connect to the broker!\n"); $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); $exchange->setType(AMQP_EX_TYPE_TOPIC); $exchange->setFlags(AMQP_DURABLE); $exchange->declareExchange(); $queue = new AMQPQueue($channel); $queue->setName($queueName); $queue->setFlags(AMQP_DURABLE); $queue->declareQueue(); $queue->bind($exchangeName, $routeKey); //阻塞模式接收消息 echo "Message:\n"; while(True){ $queue->consume('processMessage'); //自動ACK應答 //$queue->consume('processMessage', AMQP_AUTOACK); } $conn->disconnect(); /* * 消費回調函數 * 處理消息 */ function processMessage($envelope, $q) { $msg = $envelope->getBody(); echo $msg."\n"; //處理消息 $q->ack($envelope->getDeliveryTag()); //手動發送ACK應答 } ``` </details> <br /> 監聽queue1隊列 <details> <summary>q2.php</summary> ``` /* * topic 模式 * create by superrd */ $queueName = 'queue2'; $exchangeName = 'extopic'; $routeKey1 = "#.high"; $routeKey2 = "white.critical.*"; $connection = new AMQPConnection(array('host' => '10.99.121.137', 'port' => '5672', 'vhost' => '/', 'login' => 'superrd', 'password' => 'superrd')); $connection->connect() or die("Cannot connect to the broker!\n"); $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); $exchange->setType(AMQP_EX_TYPE_TOPIC); $exchange->setFlags(AMQP_DURABLE); $exchange->declareExchange(); $queue = new AMQPQueue($channel); $queue->setName($queueName); $queue->setFlags(AMQP_DURABLE); $queue->declareQueue(); $queue->bind($exchangeName, $routeKey1); $queue->bind($exchangeName, $routeKey2); //阻塞模式接收消息 echo "Message:\n"; while(True){ $queue->consume('processMessage'); //自動ACK應答 //$queue->consume('processMessage', AMQP_AUTOACK); } $conn->disconnect(); /* * 消費回調函數 * 處理消息 */ function processMessage($envelope, $q) { $msg = $envelope->getBody(); echo $msg."\n"; //處理消息 $q->ack($envelope->getDeliveryTag()); //手動發送ACK應答 } ``` </details> <br /> > 注意: 如果`binding_key` 是 `#` . 它會接收所有的Message，不管`routing_key`是什么.