josh-g / fuelphp-queue
FuelPHP 1.7.x 或更高版本,添加原始队列系统
Requires
- composer/installers: ~1.0
This package is not auto-updated.
Last update: 2018-09-21 14:37:30 UTC
README
将原始队列系统添加到 FuelPHP 1.7.x 或更高版本。
这是一个 FuelPHP 包。如果您想使用它,请将其作为包使用。
如何安装:http://fuelphp.com/docs/general/packages.html#/installing
准备
- 安装 Orm 包。
此包依赖于 fuelphp orm 包。
如果您没有 orm 包,请在使用之前安装。
php oil package install orm
- 迁移数据库。
此包需要创建 task_queue 表。
您必须准备支持 Fuel\Core\DB 类的数据库。
如果您已经有了数据库,可以通过此包进行迁移。
php oil refine migrate --packages=fuelphp-queue
简单使用
- 将队列推送到您的应用程序。
\Model_TaskQueue::save_queue(
"Static::method",
array($arg1, $arg2 ...)
);
- 通过任务运行队列。
php oil refine queue
Model_Taskqueue 文档
save_queue($method, $options, $duplicate_type = null, $priority = null)
推送任务队列。
字符串 $method
您想调用的方法名。方法必须是静态定义的。
数组 $options
方法的参数。
整数 $duplicate_type
您可以定义并设置队列类型。
如果您并行运行队列,$duplicate_type
可以设置每个类型的最大执行队列。
如果您使用此选项,请也检查配置 queue.duplicate_type
。
整数 $priority
您可以定义并设置队列的优先级。
如果您在 task_queues 中有多个任务,Model_TaskQueue::pick()
将选择优先级最低的队列。
如果您使用此选项,请也检查配置 queue.queue_default_priority
。
任务文档
php oil refine queues
运行一个队列。队列由 Model_Taskqueue::pickup()
选择。
此任务可以并行使用。您也可以通过 queue.queue_parallel_number
设置执行限制。
php oil refine queues:clean
删除超过 2 周前的成功队列。
此删除是物理删除。
如果您更改此期限,请更改配置 queue.success_queue_delete_term
。
配置文档
queue.duplicate_type
可以设置整数键和整数值。
键是数据库表中的 taks_queues.duplicate_type
值,值是并行执行限制。
如果在此配置中未设置值而在数据库中设置了值,则Model_TaskQueue::pickup()
将抛出OutOfRangeException。
注意:您不能在此配置中设置0键,因为0用作默认值。
queue.zombie_recover_time
队列执行时间限制。
如果队列状态在此时间内保持为'exec',则状态将恢复为'wait'。
当使用Model_Taskqueue::recover_zombie_queues()
或运行下一个队列任务时。
默认值是-1小时
。
queue.success_queue_delete_term
设置物理删除期限。
当调用任务php oil refine queues:clean
时,删除您设置的之前成功的老队列。
默认值是-14天
。
queue.queue_parallel_number
可以并行执行任务queues
的数量。
默认值是3
。
queue.queue_default_priority
可以设置优先级数字。0
是最高的优先级。
您可以在使用Model_TaskQueue::save_queue()
插入队列时设置任务优先级。
默认值是100
。
queue.queue_pid_prefix
任务queues
通过pid文件管理。pid文件是在您的应用程序的临时目录中创建的。
您可以为避免名称冲突而设置原始pid前缀。
默认值是queue
。
queue.logical_delete
逻辑删除模式设置。
默认值如上所述。
- 不删除 =
0
- 已删除 =
1