Yii2 queue的隊(duì)列使用詳解

第Yii2queue的隊(duì)列使用詳解'class'=\yii\queue\redis\Queue::class,

'aslog'=\yii\queue\LogBehavior::class,//錯(cuò)誤日志默認(rèn)為console/runtime/logs/app.log

'redis'='redis',//連接組件或它的配置

'channel'='queue',//Queuechannelkey

];

File作為驅(qū)動(dòng)

return[

'bootstrap'=[

'queue',//把這個(gè)組件注冊到控制臺(tái)

'components'=[

'queue'=[

'class'=\yii\queue\file\Queue::class,

'aslog'=\yii\queue\LogBehavior::class,//錯(cuò)誤日志默認(rèn)為console/runtime/logs/app.log

'path'='@runtime/queue',

];

3.新建frontend/components/DownloadJob

classDownloadJobextendsBaseObjectimplements\yii\queue\JobInterface

public$url;

public$file;

publicfunctionexecute($queue)

file_put_contents($this-file,file_get_contents($this-url));

4.控制臺(tái)

控制臺(tái)用于監(jiān)聽和處理隊(duì)列任務(wù)。

cmd下監(jiān)聽隊(duì)列

yiiqueue/listen

5.添加到隊(duì)列

將任務(wù)添加到隊(duì)列:

Yii::$app-queue-push(newfrontend\components\DownloadJob([

'url'='/image.jpg',

'file'='/tmp/image.jpg',

將任務(wù)推送到隊(duì)列中延時(shí)5分鐘運(yùn)行:

Yii::$app-queue-delay(5*60)-push(newfrontend\components\DownloadJob([

'url'='/image.jpg',

'file'='/tmp/image.jpg',

6.測試

執(zhí)行5中的程序，控制臺(tái)監(jiān)聽到，便會(huì)后臺(tái)自動(dòng)下載/image.jpg到本地為/tmp/image.jpg

啟動(dòng)worker

可以使用Supervisor或Systemd來啟動(dòng)多進(jìn)程worker，也可以使用Cron，我們這里主要說一下Supervisor

centos7supervisor的使用

1.安裝supervisor

yumupdate

yuminstallepel-release

yuminstall-ysupervisor

#開機(jī)啟動(dòng)

systemctlenablesupervisord

systemctlstartsupervisord

2.supervisor命令

supervisorctlstatus查看進(jìn)程狀態(tài)

supervisorctlreload重啟supervisord

supervisorctlstart|stop|restart啟動(dòng)關(guān)閉重啟進(jìn)程

3.添加配置文件

Supervisor配置文件通常在/etc/supervisord.d目錄下.你可以創(chuàng)建一些配置文件在這里.

注：文件名是.ini結(jié)尾

下面就是個(gè)例子:

[program:yii-queue-worker]

process_name=%(program_name)s_%(process_num)02d

command=/usr/bin/php/var/www/my_project/yiiqueue/listen--verbose=1--color=0

autostart=true

autorestart=true

user=www-data

numprocs=4

redirect_stderr=tr