fk/queue

基于PHP的队列执行程序

v2.0.0 2017-11-30 02:30 UTC

This package is not auto-updated.

Last update: 2024-09-14 19:31:10 UTC


README

扩展也可以作为yii扩展使用

  1. 注册为组件
# main.php
return [
    'components' => [
        'queue' => [
            'class' => 'fk\queue\wrapper\yii2\Connection',
            'logPath' => '@console/runtime/logs/queue.log',
            'engine' => 'fk\queue\engines\Redis',
        ]
    ]
]
  1. 队列进入
Yii::$app->queue->in('ls -l'); // bash> ls -l
Yii::$app->queue->in(new YiiCommand(['migrate'])); // bash> php yii migrate

您可以编写自己的XXCommand来解析命令,但最终应该返回一个bash命令。如果in的参数为空,则该命令将被忽略

  1. 控制台映射
# console\config\main.php
return [
    'controllerMap' => [
        'queue' => [
            'class' => 'fk\queue\wrapper\yii2\QueueController'
        ]
    ],
]
  1. 队列启动
php yii queue/start

命令

通过扩展\fk\queue\commands\Command并重写方法CommandInterface::parse来自定义自己的命令

<?php

class MyCommand extends \fk\queue\commands\Command
{

    public $command;

    public function parse() {
        // Parse your command with its property `command`
    }
}