中文简体 / English
A simple asynchronous queue library.(一个简单php异步队列库)
composer require iry/queue
创建一个class 实现以下方法即可。示例 一个项目中可以有多个队列，请为每个队列创建一个配置(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://你的绝对路径
}用于产生队列任务
use iry\queue\Client
Client::m(\MyNamespace\MySetting::class)->create($name,$args,$tags ,$execTime)create($name, $args, $customID ,$tags ,$execTime, $unique=true) 代码示例
| 参数名 | 类型 | 说明 |
|---|---|---|
| $name | string | 任务名称：（字母 数组 _）等字符组成 |
| $args | array | 参数，如:['id'=>123] |
| $customID | string | 自定义ID （便于管理和定位您的任务） |
| $execTime | array | 执行时间 用来为队列延时使用的。 |
请在你的应用的CLI模式下执行
use iry\queue\Service
new Service()->listen()