RabbitMQ 入门教程(PHP版) 第五部分:通过主题进行消息分发（Topics）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了RabbitMQ 入门教程(PHP版) 第五部分:通过主题进行消息分发（Topics），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1974字，纯文字阅读大概需要3分钟。

内容图文

对于 Message 的 routing_key 字符串格式是有限制的：以点号"."分割的字符表，如php.laravel，并且长度不能超过 255 个字节。

对于 routing_key 而言，有两个特殊字符：

• *：代表任意单词
• #：代表0个或多个单词

 

Topic Exchange 与其他 Exchange 的转化：

• routing_key 是 #，会接收所有 Message，此时等同于 Fanout Exchange；
• routing_key 不包含 # 或 *，则等同于 Direct Exchange

整合代码

emit_log_topic.php

<?php

/**
 * 发送消息
 */

$exchangeName = 'topic_logs';
$topic = empty($argv[1]) ? 'anonymous.info' : $argv[1]; // 主题
$message = empty($argv[2]) ? 'Hello World!' : $argv[2];

// 建立TCP连接
$connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => '5672',
    'vhost' => '/',
    'login' => 'guest',
    'password' => 'guest'
]);
$connection->connect() or die("Cannot connect to broker!\n");

$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchangeName);
$exchange->setType(AMQP_EX_TYPE_TOPIC);
$exchange->declareExchange();

$exchange->publish($message, $topic);
echo "Message is sent: " . $message . "\n";
$connection->disconnect();

receive_logs_topic.php

<?php

/**
 * 接收消息
 */

$exchangeName = 'topic_logs';
$topic = $argv[1];

// 建立TCP连接
$connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => '5672',
    'vhost' => '/',
    'login' => 'guest',
    'password' => 'guest'
]);
$connection->connect() or die("Cannot connect to broker!\n");

$channel = new AMQPChannel($connection);

$exchange = new AMQPExchange($channel);
$exchange->setName($exchangeName);
$exchange->setType(AMQP_EX_TYPE_TOPIC);
$exchange->declareExchange();

$queue = new AMQPQueue($channel);
$queue->setFlags(AMQP_EXCLUSIVE);
$queue->declareQueue();
$queue->bind($exchangeName, $topic);

echo "Waiting for logs...\n";
while (TRUE) {
    $queue->consume('processLogs');
}

$connection->disconnect();

function processLogs($envelope, $queue) {
    $logs = $envelope->getBody();
    var_dump("Received: " . $logs);
    $queue->ack($envelope->getDeliveryTag()); // 手动发送ACK应答
}

先运行脚本：

php receive_logs_topic.php *.laravel

然后再运行另外一个脚本：

php emit_log_topic.php php.laravel

 

效果展示：

 

内容总结

以上是互联网集市为您收集整理的RabbitMQ 入门教程(PHP版) 第五部分:通过主题进行消息分发（Topics）全部内容，希望文章能够帮你解决RabbitMQ 入门教程(PHP版) 第五部分:通过主题进行消息分发（Topics）所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---