iry / async-queue
一个简单的PHP异步队列库。
v1.0.1
2023-01-13 15:43 UTC
Requires
- php: >=5.4.0
- ext-json: *
README
中文简体 / English
自述文件
一个简单的PHP异步队列库。
安装
composer require iry/queue
使用
1. 队列配置
创建一个类实现以下方法即可。示例 一个项目中可以有多个队列,请为每个队列创建一个配置(Setting)
namespace MyNamespace;//这您的项目应用的命名空间 //创建一个队列配置(Setting)) class MySetting extends \iry\queue\Setting{ function storage(); // 返回异步任务存储驱动 function tempPath(){} //[可选] //function beforeCreate($name, $client);// 任务入队前回调, return false 阻止任务继续入队 //[可选] //function afterCreate($id);//任务成功入队后回调 //[可选] //function i18n(){} //默认 en-US 系统自带 en-US,zh-CN or file://你的绝对路径 }
2. 新任务入队/创建新任务 (客户端)
用于产生队列任务
use iry\queue\Client Client::m(\MyNamespace\MySetting::class)->create($name,$args,$tags ,$execTime)
create($name, $args, $customID ,$tags ,$execTime, $unique=true) 代码示例
3. 监听并处理队列任务,仅支持CLI模式 (服务端)
请在你的应用的CLI模式下执行
use iry\queue\Service new Service()->listen()