Yii2 queue的队列使用详解
时间:2022-07-27
本文章向大家介绍Yii2 queue的队列使用详解,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
少废话主要看文档
官方文档
yii2-queue 的使用
1.安装
composer require --prefer-dist yiisoft/yii2-queue
2.配置,在 common/config/main.php 中配置
redis作为驱动
return [
'bootstrap' = [
'queue', // 把这个组件注册到控制台
],
'components' = [
'redis' = [
'class' = yiiredisConnection::class,
// ...
],
'queue' = [
'class' = yiiqueueredisQueue::class,
'as log' = yiiqueueLogBehavior::class,//错误日志 默认为 console/runtime/logs/app.log
'redis' = 'redis', // 连接组件或它的配置
'channel' = 'queue', // Queue channel key
],
],
];
File 作为驱动
return [
'bootstrap' = [
'queue', // 把这个组件注册到控制台
],
'components' = [
'queue' = [
'class' = yiiqueuefileQueue::class,
'as log' = yiiqueueLogBehavior::class,//错误日志 默认为 console/runtime/logs/app.log
'path' = '@runtime/queue',
],
],
];
3.新建 frontend/components/DownloadJob
class DownloadJob extends BaseObject implements yiiqueueJobInterface
{
public $url;
public $file;
public function execute($queue)
{
file_put_contents($this- file, file_get_contents($this- url));
}
}
4.控制台
控制台用于监听和处理队列任务。
cmd 下 监听队列
yii queue/listen
5.添加到队列
将任务添加到队列:
Yii::$app- queue- push(new frontendcomponentsDownloadJob([
'url' = 'http://example.com/image.jpg',
'file' = '/tmp/image.jpg',
]));
将任务推送到队列中延时5分钟运行:
Yii::$app- queue- delay(5 * 60)- push(new frontendcomponentsDownloadJob([
'url' = 'http://example.com/image.jpg',
'file' = '/tmp/image.jpg',
]));
6.测试
执行 5 中的程序,控制台监听到,便会后台自动 下载http://example.com/image.jpg到本地为/tmp/image.jpg
启动worker
可以使用Supervisor或Systemd 来启动多进程worker,也可以使用 Cron,我们这里主要说一下Supervisor
centos7 supervisor的使用
1.安装supervisor
yum update
yum install epel-release
yum install -y supervisor
#开机启动
systemctl enable supervisord
#启动
systemctl start supervisord
2.supervisor 命令
supervisorctl status 查看进程状态
supervisorctl reload 重启supervisord
supervisorctl start|stop|restart 启动关闭重启进程
3.添加配置文件
Supervisor 配置文件通常在 /etc/supervisord.d 目录下. 你可以创建一些配置文件在这里.
注:文件名是.ini结尾
下面就是个例子:
[program:yii-queue-worker]
process_name=%(program_name)s_%(process_num)02d
command=/usr/bin/php /var/www/my_project/yii queue/listen --verbose=1 --color=0
autostart=true
autorestart=true
user=www-data
numprocs=4
redirect_stderr=true
stdout_logfile=/var/www/my_project/log/yii-queue-worker.log
- 如何写好一份渗透测试报告?
- jqGrid 关闭刷新父页面数据
- [MyBatis]诡异的Invalid bound statement (not found)错误
- jfinal自定义freemarker标签
- Angrok 一个内网穿透服务
- Druid数据库连接池 实现数据库账号密码加密
- 【maven学习】划分模块
- 缓存策略优化
- Quartz框架应用(1)
- 6个编写优质干净代码的技巧
- 【Jfinal源码】第一章 com.jfinal.core.JFinalFilter(1)
- 【ehcache】 timeToLiveSeconds 和 timeToLiveSeconds 的区别
- 升级 CentOS7 、Redis 3.2.x 的问题
- AngularJS 中使用Swiper制作滚动图不能滑动
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 49. Vue使用axios发送Ajax请求
- UCSC-browser学习:创建自己的track hubs
- 五分钟快速搭建Serverless免费邮件服务
- 基于qiankun落地部署微前端爬”坑“记
- Android推送的群魔乱舞
- 用百度接口实现图片文字识别,并打包成安装包软件
- 视野前端(二)V8引擎是如何工作的
- 【干货】Chrome插件(扩展)开发全攻略
- 超性感的React Hooks(一):为何她独具魅力
- 超性感的React Hooks(二)再谈闭包
- Python全栈(一)基础之11.函数(3)
- Python全栈(二)数据结构和算法之1.算法和数据结构引入
- Android开发(第一行代码 第二版) 常见异常和解决办法(基于Android Studio)(一)
- Python SQLite 基本操作和经验技巧(一)
- Python字典及基本操作(超级详细)