README

此包为 Yii2 提供队列组件（基于 urbanindo/yii2-queue 的分支）。

更新：无服务器负载 + 更好的说明文档，以开始使用此包。

安装

安装此扩展的首选方式是通过 Composer。

运行以下命令，添加

"repositories": [{
    "type": "package",
    "package": {
      "name": "vlodkow/yii2-queue",
      "version": "1.3.7",
      "source": {
        "url": "git@github.com:vlodkow/yii2-queue.git",
        "type": "git",
        "reference": "1.3.7"
      }
    }
  }],
  "require": {
    "vlodkow/yii2-queue": "1.3.*"
  }

到您的 composer.json 文件的 require 部分。

要使用 Redis 队列或 RabbitMQ，您必须分别添加 yiisoft/yii2-redis:* 或 videlalvaro/php-amqplib: 2.5.*。

设置

安装后，第一步是设置控制台控制器（config/console.php）。

return [
    // ...
    'controllerMap' => [
        'queue' => 'Vlodkow\Yii2\Queue\Console\Controller',
        'sleep' => 2,
        'rocket_chat_url' => ''
    ],
];

对于任务工作者，设置一个新模块，例如 task，并在配置中声明它（config/console.php）。

'modules' => [
    'task' => [
        'class' => 'app\modules\task\Module',
    ]
]

然后设置队列组件。不要忘记在组件中设置运行任务的模块名称（config/console.php 和 config/web.php）。例如，使用 AWS SQS 的队列

'components' => [
    'queue' => [
        'class' => 'Vlodkow\Yii2\Queue\Queues\SqsQueue',
        'module' => 'task',
        'url' => 'https://sqs.ap-southeast-1.amazonaws.com/123456789012/queue',
		'config' => [
			'key' => 'AKIA1234567890123456',
			'secret' => '1234567890123456789012345678901234567890',
			'region' => 'ap-southeast-1',
			'version' => 'latest'
        ],
    ]
]

或使用数据库队列

'components' => [
    'db' => [
        //the db component
    ],
    'queue' => [
        'class' => 'Vlodkow\Yii2\Queue\Queues\DbQueue',
        'db' => 'db',
        'tableName' => 'queue',
        'module' => 'task',
    ]
]

用法

从 db.sql 文件导入 mysql 表

创建工作者

创建工作者与创建控制台或网页控制器相同。在任务模块中创建一个控制器，该控制器扩展 Vlodkow\Yii2\Queue\Worker\Controller

例如。

class FooController extends Vlodkow\Yii2\Queue\Worker\Controller {

    public function actionBar($param1, $param2){
        echo $param1;
    }
}

为了防止作业从队列中删除（例如，当作业未完成时），在操作中返回 false。作业将在下一次机会时再次运行。

例如。

class FooController extends Vlodkow\Yii2\Queue\Worker\Controller {

    public function actionBar($param1, $param2){
        try {
        } catch (\Exception $ex){
            \Yii::error('Ouch something just happened');
            return false;
        }
    }
}

运行监听器

要运行监听器，运行上述配置中设置的命令行。如果控制器映射为 queue，则运行。

yii queue/listen

发布作业

要从源代码发布作业，请放置如下内容。

use Vlodkow\Yii2\Queue\Job;

$route = 'foo/bar';
$data = ['param1' => 'foo', 'param2' => 'bar'];
Yii::$app->queue->post(new Job(['route' => $route, 'data' => $data]));

作业也可以从控制台发布。第二个参数中的数据是 JSON 字符串。

yii queue/post 'foo/bar' '{"param1": "foo", "param2": "bar"}'

作业也可以作为匿名函数发布。请小心使用此方法。

Yii::$app->queue->post(new Job(function(){
    echo 'Hello World!';
}));

延迟事件

在此队列中，有一个名为 延迟事件 的功能。基本上，我们可以使用此功能，通过队列延迟执行某些事件后的进程。

要使用此功能，向组件中添加行为并实现定义的事件处理器。

    public function behaviors() {
        return array_merge([
            [
                'class' => \Vlodkow\Yii2\Queue\Behaviors\DeferredEventBehavior::class,
                'events' => [
                    self::EVENT_AFTER_VALIDATE => 'deferAfterValidate',
                ]
            ]
        ]);
    }

    public function deferAfterValidate(){
        //Do something here.
    }

注意由于减少消息大小，通常在触发事件时传递的 $event 对象将不会传递给延迟事件。此外，调用方法的对象仅是克隆对象，因此它不会在原始对象中具有行为和事件。

对于 ActiveRecord 类，由于 SuperClosure 在序列化 PDO 时的限制，无法传递对象，因此应使用 \Vlodkow\Yii2\Queue\Behaviors\ActiveRecordDeferredEventBehavior 替代行为。区别在于调用延迟事件处理器时调用的对象。

由于无法传递原始对象，调用对象将重新从表中使用主键检索。对于 afterDelete 事件，由于相应的行不再存在于表中，调用对象是新的对象，其属性是从原始对象的属性分配的。

Web 端点

我们可以通过将 \Vlodkow\Yii2\Queue\Web\Controller 添加到控制器映射来使用 Web 端点。

例如

    'controllerMap' => [
        'queue' => [
            /* @var $queue Vlodkow\Yii2\Queue\Web\Controller */
            'class' => 'Vlodkow\Yii2\Queue\Web\Controller',
        ]
    ],

要发布此内容，请使用以下命令。

curl -XPOST http://example.com/queue/post --data route='test/test' --data data='{"data":"data"}'

要限制对控制器的访问，我们可以使用 \yii\filters\AccessControl 过滤器。

例如，要按 IP 地址进行过滤，可以使用如下内容。

    'controllerMap' => [
        'queue' => [
            /* @var $queue Vlodkow\Yii2\Queue\Web\Controller */
            'class' => 'Vlodkow\Yii2\Queue\Web\Controller',
            'as access' => [
                'class' => '\yii\filters\AccessControl',
                'rules' => [
                    [
                        'allow' => true,
                        'ips' => [
                            '127.0.0.1'
                        ]
                    ]
                ]
            ]
        ]
    ],

测试

要运行测试，在根目录中执行以下操作。

./vendor/bin/phpunit

路线图

添加更多队列提供者，如MemCache、IronMQ、RabbitMQ。

vlodkow / yii2-queue

维护者

详细信息