文档章节

RabbitMQ+PHP 教程四(Routing)用yii2测试通过

hansonwong
 hansonwong
发布于 11/16 13:35
字数 1388
阅读 10
收藏 0

开始

在本教程中,我们将为它添加一个特性——我们将只可能订阅消息的一个子集。例如,我们只能够将关键错误消息直接指向日志文件(以节省磁盘空间),同时仍然能够打印控制台上的所有日志消息。

绑定(Bindings)

在前面的示例中,我们已经创建绑定。您可能还记得代码:

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

绑定是交换和队列之间的一种关系。这可以简单地理解为:队列对来自此交换的消息感兴趣。

绑定可以采取额外的routing_key参数。避免混淆和$channel::basic_publish参数我们要叫它绑定key。这就是我们如何用键创建绑定的原因:

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

绑定键的含义取决于交换类型。我们以前使用的fanout交换将忽略了它的值。

Direct exchange

我们以前的教程中的日志系统将所有消息广播给所有消费者。我们希望扩展这一点,允许基于其一定严重性程度来过滤消息。例如,我们可能希望将日志消息写入到磁盘的脚本只接收关键错误,而不会在警告或信息日志消息上浪费磁盘空间。

我们使用的是fanout交换机,这并不能给我们带来很大的灵活性——它只能进行无意识的广播。

我们将使用direct交换机替代。direct交换机背后的路由算法很简单-消息传递到队列,其绑定键完全匹配消息的路由键。

为了说明这一点,请考虑以下设置:

在这个设置中,我们可以看到两个队列绑定到它的direct交换机X。第一个队列与绑定键orange绑定,第二个绑定有两个绑定,一个绑定键black,另一个绑定green

在这样的设置中,将路由消息发送到Exchange的路由密钥orange将被路由到队列Q1。带有blackgreen路由键的消息将转到Q2。所有其他消息都将被丢弃。

多个绑定 (Multiple bindings)

用相同的绑定键绑定多个队列是完全合法的。在我们的示例中,我们可以在绑定绑定键XQ1之间添加一个绑定。在这种情况下,direct交换机将表现为fanout交换机,并将消息发送到所有匹配队列。将带有路由键black的消息发送给Q1Q2

Emitting logs

我们将使用这个模型作为我们的日志系统。我们将把消息发送给direct交换机,而不是fanout交换机。我们将提供日志严重性作为路由键。这样,接收脚本将能够选择它想要接收的严重性。让我们先专注于发布日志。

和以往一样,我们需要首先创建一个交换:

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

我们已经准备好发送消息了:

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

为了简化事情,我们会假设严重错误有可以是info, warning, error的一种。

订阅 (Subscribing)

接收消息将与前面的教程一样,只有一个例外——我们将为我们感兴趣的每个严重性创建一个新的绑定。

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

代码都放在一起:

emit_log_direct.php源码:

<?php
/**
 * @link http://www.yiiframework.com/
 * @copyright Copyright (c) 2008 Yii Software LLC
 * @license http://www.yiiframework.com/license/
 */

namespace app\commands;

use yii\console\Controller;

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

/**
 * This command echoes the first argument that you have entered.
 *
 * This command is provided as an example for you to learn how to create console commands.
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @since 2.0
 */
class EmitLogDirecController extends Controller
{

    public function actionIndex(array $argv)
    {
        $connection = new AMQPStreamConnection('localhost', 5672, 'admin', 'admin');
        $channel = $connection->channel();

        
        $channel->exchange_declare('direct_logs', 'direct', false, false, false);
        $severity = isset($argv[0]) && !empty($argv[0]) ? $argv[0] : '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();
    }
}

 

receive_logs_direct.php源码:

<?php
/**
 * @link http://www.yiiframework.com/
 * @copyright Copyright (c) 2008 Yii Software LLC
 * @license http://www.yiiframework.com/license/
 */

namespace app\commands;

use yii\console\Controller;

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

/**
 * This command echoes the first argument that you have entered.
 *
 * This command is provided as an example for you to learn how to create console commands.
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @since 2.0
 */
class ReceiveLogsDirectController extends Controller
{

    public function actionIndex(array $argv)
    {
        $connection = new AMQPStreamConnection('localhost', 5672, 'admin', 'admin');
        $channel = $connection->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();
    }
}

如果您只想保存warningerror(不包含info)日志消息到文件,只需打开控制台并键入:

php yii receive-logs-direct/index info,warning,error

如果您想查看屏幕上的所有日志消息,请打开一个新的终端并执行:

 php yii receive-logs-direct/index info,warning,error
 [*] Waiting for logs. To exit press CTRL+C

例如,触发错误日志消息:

php yii emit-log-direc/index error "Run. Run. Or it will explode."
[x] Sent error:Hello World!

结果如下:

(全部源码 emit_log_direct.php source and receive_logs_direct.php source)

 

翻译来自 RabbitMQ - RabbitMQ tutorial - Routing

本文转载自:https://segmentfault.com/a/1190000013488291

共有 人打赏支持
hansonwong
粉丝 4
博文 149
码字总数 32310
作品 0
广州
私信 提问
YII2 rest 风格接口

下载yii2rest程序,下载地址:https://github.com/iiYii/yii2-rest-demo 打开命令行客户端,前提是php加入环境变量。 进入YII项目目录,windows下输入yii migrate初始化数据库。 初始化成功后...

风清扬-深圳
2015/12/21
641
0
Yii2 源码分析 - 入口文件执行流程

以 yii 2.0.14 高级版的 frontend 为例,从 frontend/web/index.php 开始 入口文件看着就这么几行,简单的很,那他是怎么通过这几行来运行应用的呢?先看 Yii.php 内的逻辑 接下来,就是重头...

botkenni
05/03
0
0
选择 Yii 2 框架的 7 个理由

去年,SitePoint网站发布了一篇文章重点介绍了一些顶尖的PHP开发框架。 排名第四的是Yii(发音同Yee)框架。 那时Yii框架最新的版本是1.1.14。最近,Yii 2.0版发布了,你可以在产品中使用2.0...

oschina
2014/10/16
18K
66
Yii2 模块化调用Module失败

一、错误信息如下: Unknown Class – yii\base\UnknownClassException Unable to find 'app\modules\user\UserModule' in file: E:\www\test\basic/modules/user/UserModule.php. Namespac......

joson_chan
2015/09/23
4.3K
1
用yii2实现youtube风格的错误处理页面

最近yii2开发组成员Alexander Makarov写了一篇blog,关于youtube网站报错信息页面的分析。 当我们的程序在生产阶段的时候,不能将程序的信息暴露出来,这会给黑客破解网站的机会。youtube网站...

abei2017
05/21
0
0

没有更多内容

加载失败,请刷新页面

加载更多

[springBoot系列]--springBoot注解大全

一、注解(annotations)列表 @SpringBootApplication:包含了@ComponentScan、@Configuration和@EnableAutoConfiguration注解。其中@ComponentScan让spring Boot扫描到Configuration类并把它加......

Jack088
8分钟前
0
0
tomcat编译超过64k大小的jsp文件报错原因

  今天遇到一个问题,首先是在tomcat中间件上跑的web项目,一个jsp文件,因为代码行数实在是太多了,更新了几个版本之后编译报错了,页面打开都是报500的错误,500的报错,知道http协议返回...

SEOwhywhy
30分钟前
2
0
flutter http 请求客户端

1、pubspec文件管理Flutter应用程序的assets(资源,如图片、package等)。 在pubspec.yaml中,通过网址“https://pub.dartlang.org/packages/http#-installing-tab-”确认版本号后,将http(0...

渣渣曦
30分钟前
0
0
Django基本命令及moduls举例

一、Django基本命令 1.创建项目 django-admin.py startproject mysite 创建后的项目结构:- mysite - mysite #对整个程序进行配置 - init #导入包专用- settings ...

枫叶云
45分钟前
7
0
zabbix安装

rpm -ivh http://repo.webtatic.com/yum/el6/latest.rpm 安装jdk rpm -ivh (自行在网上下载rpm包) 安装php并修改相应参数 yum -y install php56w php56w-gd php56w-mysqlnd php56w-bcmath......

muoushi
46分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部