README

Yii 2.0 队列扩展

Yii 2.0 的非阻塞队列管理器

#####安装: php composer.phar require argayash/yii2-queue "dev-hakaton-tass"

#####配置

'components' => [
    'queue' => [
        'class' => \yii\queue\components\QueueComponent::className(),
        'queueName' => 'default-queue',
        'timeout' => 50, // optional
        'workers' => [
            'test' => [
                'class' => \yii\queue\components\WorkerComponent::className(),
                'action' => [
                    'class' => \console\controllers\TestController::className(),
                ]
            ],
            ...
        ],
        'channels' => [
            'default' => [
                'class' => \yii\queue\components\ChannelComponent::className(),
                    'driver' => [
                        'class' => \yii\queue\drivers\MysqlConnection::className(),
                        'connection' => 'db'
                    ]
                ]
            ],
            ...
        ]
    ]
]

使用前请应用迁移

./yii migrate/up --migrationPath=@vendor/argayash/yii2-queue/migrations

###使用方法

将消息推送到队列

Yii::$app->queue->getChannel('default')->push(
    new MessageModel([
        'worker' => 'test',
        'method' => 'actionSayHello',
        'arguments' => [
            'say' => 'hello!'
        ]
    ])
);

运行队列工作守护进程（控制台应用程序）

\Yii::$app->queue->startDaemon();